QdrantIngestOperator¶

使用 QdrantIngestOperator 将数据摄取到 Qdrant 实例中。

使用操作符¶

QdrantIngestOperator 需要将 vectors 作为输入摄取到 Qdrant 中。使用 conn_id 参数指定 Qdrant 连接以连接到 Qdrant 实例。向量还可以包含引用与向量对应的原始文本的元数据，这些元数据可以被摄取到数据库中。

以下是以这种方式使用操作符的示例

tests/system/providers/qdrant/example_dag_qdrant.py[源代码]

vectors = [[0.732, 0.611, 0.289, 0.421], [0.217, 0.526, 0.416, 0.981], [0.326, 0.483, 0.376, 0.136]]
ids: list[str | int] = [32, 21, "b626f6a9-b14d-4af9-b7c3-43d8deb719a6"]
payload = [{"meta": "data"}, {"meta": "data_2"}, {"meta": "data_3", "extra": "data"}]

QdrantIngestOperator(
    task_id="qdrant_ingest",
    collection_name="test_collection",
    vectors=vectors,
    ids=ids,
    payload=payload,
    batch_size=1,
)