airflow.providers.qdrant.operators.qdrant¶

类¶

QdrantIngestOperator

将点上传到 Qdrant 集合。

模块内容¶

class airflow.providers.qdrant.operators.qdrant.QdrantIngestOperator(*, conn_id=QdrantHook.default_conn_name, collection_name, vectors, payload=None, ids=None, batch_size=64, parallel=1, method=None, max_retries=3, wait=True, **kwargs)[source]¶

基类: airflow.models.BaseOperator

将点上传到 Qdrant 集合。

另请参阅

有关如何使用此 Operator 的更多信息，请参阅指南：QdrantIngestOperator

参数:

conn_id (str) – 用于连接 Qdrant 实例的连接 ID。
collection_name (str) – 要导入数据的集合名称。
vectors (collections.abc.Iterable[qdrant_client.models.VectorStruct]) – 可迭代的待上传向量。
payload (collections.abc.Iterable[dict[str, Any]] | None) – 可迭代的向量 payload，可选。默认为 None。
ids (collections.abc.Iterable[int | str] | None) – 可迭代的自定义向量 ID，可选。默认为 None。
batch_size (int) – 每次请求上传的点数。默认为 64。
parallel (int) – 并行上传进程数。默认为 1。
method (str | None) – 并行进程的启动方法。默认为 ‘forkserver’。
max_retries (int) – 失败请求的重试次数。默认为 3。
wait (bool) – 等待结果在服务器端应用。默认为 True。
kwargs (Any) – 传递给 BaseOperator 构造函数的其他关键字参数。

template_fields: collections.abc.Sequence[str] = ('collection_name', 'vectors', 'payload', 'ids', 'batch_size', 'parallel', 'method',...[source]¶

conn_id = 'qdrant_default'[source]¶

collection_name[source]¶

vectors[source]¶

payload = None[source]¶

ids = None[source]¶

batch_size = 64[source]¶

parallel = 1[source]¶

method = None[source]¶

max_retries = 3[source]¶

wait = True[source]¶

property hook: airflow.providers.qdrant.hooks.qdrant.QdrantHook[source]¶

返回 QdrantHook 实例。

execute(context)[source]¶

将点上传到 Qdrant 集合。