QdrantIngestOperator¶

使用 QdrantIngestOperator 將資料匯入 Qdrant 實例。

使用 Operators¶

QdrantIngestOperator 需要 vectors 作為輸入，以匯入 Qdrant。使用 conn_id 參數指定要連線至 Qdrant 實例的 Qdrant 連線。向量也可以包含參考原始文字的中繼資料，這些中繼資料可以匯入到資料庫中。

以這種方式使用 operator 的範例

tests/system/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,
)