Connector

Base class for knowledge graph connectors.

Usage

Source

Connector()

Subclasses must implement scan() which yields Document instances. The connector tracks which documents have been seen so that sync() only re-ingests changed content.

Parameters

name: str

A short name identifying this connector instance.

Examples

import talk_box as tb

class MyConnector(tb.Connector):
    def __init__(self):
        super().__init__(name="my-source")

    def scan(self):
        yield tb.Document(title="hello", content="world")

Methods

Name	Description
scan()	Yield documents from this source.

---

scan()

Yield documents from this source.

Usage

Source

scan()

Each call should yield all currently available documents. The sync engine uses content hashes to detect changes.