Qdrantで始めるベクトル検索：Docker起動からPythonでの検索・フィルタまで

export QDRANT_API_KEY=$(openssl rand -hex 24)
docker run -d --name qdrant --restart unless-stopped \
  -p 127.0.0.1:6333:6333 -p 127.0.0.1:6334:6334 \
  -e QDRANT__SERVICE__API_KEY="$QDRANT_API_KEY" \
  -e QDRANT__TELEMETRY_DISABLED=true \
  -v qdrant_storage:/qdrant/storage \
  -v qdrant_snapshots:/qdrant/snapshots \
  qdrant/qdrant:v1.19.1

curl -s http://127.0.0.1:6333/
# {"title":"qdrant - vector search engine","version":"1.19.1","commit":"6ab21cac..."}
curl -s http://127.0.0.1:6333/collections
# Must provide an API key or an Authorization bearer token
curl -s -H "api-key: $QDRANT_API_KEY" http://127.0.0.1:6333/collections
# {"result":{"collections":[]},"status":"ok","time":...}

python3 -m venv .venv && . .venv/bin/activate
pip install "qdrant-client[fastembed]==1.19.1"

{"id": 1, "text": "VPNに接続できないときは、クライアントのバージョンと端末証明書の有効期限を先に確認する。", "dept": "情シス", "doc_type": "手順書", "groups": ["all"], "updated_at": "2026-08-01T09:00:00Z"}
{"id": 2, "text": "在宅勤務でリモート接続が遅い場合は、自宅ルーターの再起動と有線接続での再試行を案内する。", "dept": "情シス", "doc_type": "FAQ", "groups": ["all"], "updated_at": "2026-05-12T09:00:00Z"}
{"id": 3, "text": "VPN装置の管理画面への接続はIT管理者のみ許可し、操作ログは一年間保管する。", "dept": "情シス", "doc_type": "規程", "groups": ["it-admin"], "updated_at": "2026-07-20T09:00:00Z"}
{"id": 4, "text": "ノートパソコンを紛失したときは、ただちに情報システム部へ連絡し、リモートワイプを依頼する。", "dept": "情シス", "doc_type": "手順書", "groups": ["all"], "updated_at": "2025-11-02T09:00:00Z"}
{"id": 5, "text": "交通費の精算は、利用日の翌月十日までに経費システムから申請する。", "dept": "総務", "doc_type": "規程", "groups": ["all"], "updated_at": "2026-04-01T09:00:00Z"}
{"id": 6, "text": "入社手続きでは、初日にアカウント発行と多要素認証の登録を行う。", "dept": "人事", "doc_type": "手順書", "groups": ["all"], "updated_at": "2026-06-15T09:00:00Z"}
{"id": 7, "text": "社外からファイルサーバーに接続するには、VPN接続後に社内DNSで名前解決できることを確認する。", "dept": "情シス", "doc_type": "FAQ", "groups": ["all"], "updated_at": "2024-12-10T09:00:00Z"}
{"id": 8, "text": "証明書の更新作業は、期限の二週間前までに変更申請を出し、夜間の保守時間帯に実施する。", "dept": "情シス", "doc_type": "手順書", "groups": ["it-admin"], "updated_at": "2026-09-01T09:00:00Z"}

import json
import os

from fastembed import TextEmbedding
from qdrant_client import QdrantClient, models

COLLECTION = "it_docs"
MODEL = "sentence-transformers/paraphrase-multilingual-MiniLM-L12-v2"  # 384次元

client = QdrantClient(url=os.environ.get("QDRANT_URL", "http://127.0.0.1:6333"),
                      api_key=os.environ["QDRANT_API_KEY"])
embedder = TextEmbedding(MODEL)

docs = [json.loads(line) for line in open("docs.jsonl", encoding="utf-8")]

if not client.collection_exists(COLLECTION):
    client.create_collection(
        COLLECTION,
        vectors_config=models.VectorParams(size=384, distance=models.Distance.COSINE),
    )
    # フィルタに使うフィールドには先にインデックスを作る
    client.create_payload_index(COLLECTION, "dept", models.PayloadSchemaType.KEYWORD)
    client.create_payload_index(COLLECTION, "groups", models.PayloadSchemaType.KEYWORD)
    client.create_payload_index(COLLECTION, "updated_at", models.PayloadSchemaType.DATETIME)

vectors = embedder.embed([d["text"] for d in docs])  # ジェネレーター
points = [
    models.PointStruct(id=d["id"], vector=v.tolist(),
                       payload={k: v2 for k, v2 in d.items() if k != "id"})
    for d, v in zip(docs, vectors)
]
client.upsert(COLLECTION, points=points, wait=True)
info = client.get_collection(COLLECTION)
print(f"{COLLECTION}: points={info.points_count} status={info.status}")

$ export QDRANT_API_KEY=...   # 起動時に設定した値
$ python ingest.py
it_docs: points=8 status=green

import argparse
import os

from fastembed import TextEmbedding
from qdrant_client import QdrantClient, models

COLLECTION = "it_docs"
MODEL = "sentence-transformers/paraphrase-multilingual-MiniLM-L12-v2"

p = argparse.ArgumentParser()
p.add_argument("query")
p.add_argument("--group", action="append", default=["all"])  # 利用者の所属グループ
p.add_argument("--dept")
p.add_argument("--since")  # 例: 2026-01-01T00:00:00Z
p.add_argument("--min-score", type=float)
args = p.parse_args()

client = QdrantClient(url=os.environ.get("QDRANT_URL", "http://127.0.0.1:6333"),
                      api_key=os.environ["QDRANT_API_KEY"])
qvec = next(TextEmbedding(MODEL).query_embed(args.query)).tolist()

must = [models.FieldCondition(key="groups", match=models.MatchAny(any=args.group))]
if args.dept:
    must.append(models.FieldCondition(key="dept", match=models.MatchValue(value=args.dept)))
if args.since:
    must.append(models.FieldCondition(key="updated_at",
                                      range=models.DatetimeRange(gte=args.since)))

hits = client.query_points(
    COLLECTION,
    query=qvec,
    query_filter=models.Filter(must=must),
    score_threshold=args.min_score,
    limit=3,
    with_payload=True,
).points
for h in hits:
    d = h.payload
    print(f"{h.score:.3f}  id={h.id}  [{d['dept']}/{d['doc_type']}] {d['text']}")

$ python search.py "VPNがつながらない"
0.663  id=1  [情シス/手順書] VPNに接続できないときは、クライアントのバージョンと端末証明書の有効期限を先に確認する。
0.543  id=7  [情シス/FAQ] 社外からファイルサーバーに接続するには、VPN接続後に社内DNSで名前解決できることを確認する。
0.304  id=2  [情シス/FAQ] 在宅勤務でリモート接続が遅い場合は、自宅ルーターの再起動と有線接続での再試行を案内する。

$ python search.py "VPNがつながらない" --group it-admin
0.663  id=1  [情シス/手順書] VPNに接続できないときは、クライアントのバージョンと端末証明書の有効期限を先に確認する。
0.598  id=3  [情シス/規程] VPN装置の管理画面への接続はIT管理者のみ許可し、操作ログは一年間保管する。
0.543  id=7  [情シス/FAQ] 社外からファイルサーバーに接続するには、VPN接続後に社内DNSで名前解決できることを確認する。

$ python search.py "VPNがつながらない" --since 2026-06-01T00:00:00Z
0.663  id=1  [情シス/手順書] VPNに接続できないときは、クライアントのバージョンと端末証明書の有効期限を先に確認する。
0.086  id=6  [人事/手順書] 入社手続きでは、初日にアカウント発行と多要素認証の登録を行う。

$ python search.py "パソコンをなくした" --min-score 0.3
0.599  id=4  [情シス/手順書] ノートパソコンを紛失したときは、ただちに情報システム部へ連絡し、リモートワイプを依頼する。

# 1. サーバーの版と認証
curl -s http://127.0.0.1:6333/ | jq -r .version        # 期待: 1.19.1
curl -s -o /dev/null -w '%{http_code}\n' http://127.0.0.1:6333/collections   # 期待: 401

# 2. 登録件数と状態
curl -s -H "api-key: $QDRANT_API_KEY" http://127.0.0.1:6333/collections/it_docs \
  | jq '.result | {points_count, status}'
# 期待: {"points_count": 8, "status": "green"}

# 3. 権限フィルタ（it-admin だけに見える文書 id=3 の出し分け）
python search.py "VPNがつながらない" | grep -c 'id=3'                    # 期待: 0
python search.py "VPNがつながらない" --group it-admin | grep -c 'id=3'   # 期待: 1