langchain_community.document_loaders.airbyte.AirbyteGongLoader

class langchain_community.document_loaders.airbyte.AirbyteGongLoader(config: Mapping[str, Any], stream_name: str, record_handler: Optional[Callable[[Any, Optional[str]], Document]] = None, state: Optional[Any] = None)[source]

使用Airbyte源连接器从Gong加载数据。

初始化加载数据器。

参数

  • config (映射[字符串, 任何事物]) – 传递给源连接器的配置。

  • stream_name (字符串) – 要加载数据的流名称。

  • record_handler (可选[Callable[[任何事物, 可选[字符串]], 文档]]) – 传入记录和一个可选的id，然后返回一个Document的函数。如果为None，则将记录用作文档。默认为None。

  • state (可选[任何事物]) – 传递给源连接器的状态。默认为None。

属性

最后状态

方法

__init__(config, stream_name[, ...])

初始化加载数据器。

alazy_load()

Document的懒加载器。

aload()

将数据加载到Document对象中。

lazy_load()

Document的懒加载器。

load()

将数据加载到Document对象中。

load_and_split([text_splitter])

加载数据并分割成块。
(config: Mapping[str, Any], stream_name: str, record_handler: Optional[Callable[[Any, Optional[str]], Document]], state: Optional[Any] = None) → None[source]

初始化加载数据器。

参数

  • config (映射[字符串, 任何事物]) – 传递给源连接器的配置。

  • stream_name (字符串) – 要加载数据的流名称。

  • record_handler (可选[Callable[[任何事物, 可选[字符串]], 文档]]) – 传入记录和一个可选的id，然后返回一个Document的函数。如果为None，则将记录用作文档。默认为None。

  • state (可选[任何事物]) – 传递给源连接器的状态。默认为None。

返回类型

无

async alazy_load() → AsyncIterator[Document]

Document的懒加载器。

返回类型

AsyncIterator[Document]

async aload() → List[Document]

将数据加载到Document对象中。

返回类型

List[Document]

lazy_load() → Iterator[Document]

Document的懒加载器。

返回类型

迭代器[文档]

load() → 列表[文档]

将数据加载到Document对象中。

返回类型

List[Document]

load_and_split(text_splitter: 可选[TextSplitter]) → 列表[文档]

加载文档并分成块。块以文档的形式返回。

不要覆盖此方法。应考虑将其弃用！

参数

text_splitter (可选[TextSplitter]) – 用于分割文档的TextSplitter实例。默认为RecursiveCharacterTextSplitter。

返回

文档列表。

返回类型

列表[文档]

使用AirbyteGongLoader的示例