Qdrant

from xparse_client import QdrantDestination

destination = QdrantDestination(
    url='https://xxxxxxxxx.xxxxx.xxxxx.cloud.qdrant.io',  # Qdrant Cloud 连接地址
    collection_name='my_collection',      # 集合名称
    dimension=1024,                      # 向量维度
    api_key='your-qdrant-api-key'        # Qdrant Cloud API Key
)

from xparse_client import QdrantDestination, Pipeline

destination = QdrantDestination(
    url='https://xxxxxxxxx.xxxxx.xxxxx.cloud.qdrant.io',
    collection_name='my_collection',
    dimension=1024,
    api_key='your-qdrant-api-key'
)

# ... 其他配置

pipeline = Pipeline(
    source=source,
    destination=destination,
    # ...其他配置
)
pipeline.run()

from qdrant_client import QdrantClient
from qdrant_client.models import Filter, FieldCondition, MatchValue

client = QdrantClient(
    url='https://xxxxxxxxx.xxxxx.xxxxx.cloud.qdrant.io',
    api_key='your-qdrant-api-key'
)

query_vector = [0.1, 0.2, 0.3, ...]  # 1024 维向量

search_result = client.query_points(
    collection_name="test_collection",
    query=query_vector,
    query_filter=Filter(
        must=[FieldCondition(key="city", match=MatchValue(value="London"))]
    ),
    with_payload=True,
    limit=3,
).points

print(search_result)