langchain_community.document_loaders.airbyte.AirbyteShopifyLoader

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

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

初始化加载数据器。

参数

• 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()	用于Document的懒加载器。
aload()	将数据加载到Document对象中。
lazy_load()	用于Document的懒加载器。
load()	将数据加载到Document对象中。
load_and_split([text_splitter])	加载Documents并将它们分割成块。

__init__(config: Mapping[str, Any], stream_name: str, record_handler: Optional[Callable[[Any, Optional[str]], Document]], state: Optional[Any] = None) → None

初始化加载数据器。

参数

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

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

• record_handler (Optional[Callable[[Any, Optional[str]], Document]]) – 接收记录和可选的ID并返回Document的函数。如果为None，则将记录用作文档。默认值为None。

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

返回类型

None

async alazy_load() → AsyncIterator[Document]

用于Document的懒加载器。

返回类型

AsyncIterator[Document]

async aload() → List[Document]

将数据加载到Document对象中。

返回类型

List[Document]

lazy_load() → Iterator[Document]

用于Document的懒加载器。

返回类型

Iterator[Document]

load() → List[Document]¶

将数据加载到Document对象中。

返回类型

List[Document]

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

加载文档并将其分割成块。块作为文档返回。

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

参数

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

返回

文档列表。

返回类型

List[Document]

使用AirbyteShopifyLoader的示例

• Airbyte Shopify (已弃用)