scripts/create_qdrant.py

# scripts/create_qdrant.py
import asyncio, os
from qdrant_client import AsyncQdrantClient

QDRANT_URL   = os.getenv("QDRANT_URL")
QDRANT_API_KEY = os.getenv("QDRANT_API_KEY")

async def main():
    client = AsyncQdrantClient(url=QDRANT_URL, api_key=QDRANT_API_KEY)
    await client.create_collection(
        collection_name="listings",
        vectors_config={"size": 1536, "distance": "Cosine"},
    )
    print("✅ Qdrant 'listings' collection created (1536-dim, Cosine)")

if __name__ == "__main__":
    asyncio.run(main())