langchain_community.document_loaders.airbyte.AirbyteSalesforceLoader

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

使用 Airbyte 源连接程序从 Salesforce 加载。

初始化加载器。

参数
  • config (Mapping[str, Any]) – 传递给源连接器的配置。

  • stream_name (str) – 要加载的流名称。

  • record_handler (Optional[Callable[[Any, Optional[str]], Document]]) – 函数,用于将记录和可选的id作为输入,并返回一个Document。如果为None,则将记录用作文档。默认为None。

  • state (Optional[Any]) – 传递给源连接器的状态。默认为None。

属性

last_state

方法

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

初始化加载器。

alazy_load()

Documents的懒加载。

aload()

将数据加载到Document对象中。

lazy_load()

Documents的懒加载。

load()

将数据加载到Document对象中。

load_and_split([text_splitter])

加载Documents并将其分割成块。

初始化加载器。

参数
  • config (Mapping[str, Any]) – 传递给源连接器的配置。

  • stream_name (str) – 要加载的流名称。

  • record_handler (Optional[Callable[[Any, Optional[str]], Document]]) – 函数,用于将记录和可选的id作为输入,并返回一个Document。如果为None,则将记录用作文档。默认为None。

  • state (Optional[Any]) – 传递给源连接器的状态。默认为None。

返回类型

None

Documents的懒加载。

返回类型

将数据加载到Document对象中。

返回类型

Documents的懒加载。

返回类型

load() List[Document]

将数据加载到Document对象中。

返回类型

load_and_split(text_splitter: Optional[TextSplitter] = None) List[Document]

加载文档并将它们拆分成块。块作为文档返回。

不要重写此方法。应该考虑将其作为已弃用!

参数

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

返回

文档列表。

返回类型

List[Document]

使用AirbyteSalesforceLoader的示例