メインコンテンツまでスキップ

ランダムサンプリング

大規模なデータセットを扱う際、インサイトを得たりフィルタリングロジックをテストしたりするために、必ずしもすべてのデータを処理する必要はありません。ランダムサンプリングは、統計的に代表性のあるデータのサブセットを利用できるようにすることで、この課題を解決し、クエリ時間とリソース消費を大幅に削減します。

Random sampling operates at the segment level, ensuring efficient performance while maintaining the randomness of the sample across your コレクション's data distribution.

主なユースケース:

  • Data exploration: Quickly preview コレクション structure and content with minimal resource usage

  • 開発テスト: 本番デプロイ前に、扱いやすいデータサンプルで複雑なフィルタリングロジックをテスト

  • リソース最適化: 探索的クエリや統計分析における計算コストを削減

Syntax​

python
filter = "RANDOM_SAMPLE(sampling_factor)"

パラメータ:

  • sampling_factor: 境界値を含まない (0, 1) の範囲のサンプリング係数。たとえば、RANDOM_SAMPLE(0.001) は結果の約 0.1% を選択します。

重要なルール:

  • この式は大文字小文字を区別しません（RANDOM_SAMPLE または random_sample）

  • サンプリング係数は、境界値を含まない (0, 1) の範囲でなければなりません

Combine with other filters​

ランダムサンプリング演算子は、論理 AND を使用して他のフィルタリング式と組み合わせる必要があります。フィルタを組み合わせる場合、Milvus はまず他の条件を適用し、その後に結果セットに対してランダムサンプリングを実行します。

python
# Correct: Filter first, then sample
filter = 'color == "red" AND RANDOM_SAMPLE(0.001)'
# Processing: Find all red items → Sample 0.1% of those red items

# Incorrect: OR doesn't make logical sense
filter = 'color == "red" OR RANDOM_SAMPLE(0.001)'  # ❌ Invalid logic
# This would mean: "Either red items OR sample everything" - which is meaningless

Examples​

Example 1: Data exploration​

Quickly preview your コレクション structure:

python
from pymilvus import MilvusClient

client = MilvusClient(uri="YOUR_CLUSTER_ENDPOINT")

# Sample approximately 1% of the entire collection
result = client.query(
    collection_name="product_catalog",
    filter="RANDOM_SAMPLE(0.01)",
    output_fields=["id", "product_name"],
    limit=10
)

print(f"Sampled {len(result)} products from collection")

Example 2: Combined filtering with random sampling​

扱いやすいサブセットでフィルタリングロジックをテストします:

python
# First filter by category and price, then sample 0.5% of results
filter_expression = 'category == "electronics" AND price > 100 AND RANDOM_SAMPLE(0.005)'

result = client.query(
    collection_name="product_catalog",
    filter=filter_expression,
    output_fields=["product_name", "price", "rating"],
    limit=10
)

print(f"Found {len(result)} electronics products in sample")

Example 3: Quick analytics​

フィルタリングされたデータに対して迅速な統計分析を実行します:

python
# Get insights from ~0.1% of premium customer data
filter_expression = 'customer_tier == "premium" AND region == "North America" AND RANDOM_SAMPLE(0.001)'

result = client.query(
    collection_name="customer_profiles",
    filter=filter_expression,
    output_fields=["purchase_amount", "satisfaction_score", "last_purchase_date"],
    limit=10
)

# Analyze sample for quick insights
if result:
    average_purchase = sum(r["purchase_amount"] for r in result) / len(result)
    average_satisfaction = sum(r["satisfaction_score"] for r in result) / len(result)

    print(f"Sample size: {len(result)}")
    print(f"Average purchase amount: ${average_purchase:.2f}")
    print(f"Average satisfaction score: ${average_satisfaction:.2f}")

フィルタリングされた検索シナリオでランダムサンプリングを使用します:

python
# Search for similar products within a sampled subset
search_results = client.search(
    collection_name="product_catalog",
    data=[[0.1, 0.2, 0.3, 0.4, 0.5]],  # query vector
    filter='category == "books" AND RANDOM_SAMPLE(0.01)',
    search_params={"params": {}},
    output_fields=["title", "author", "price"],
    limit=10
)

print(f"Found {len(search_results[0])} similar books in sample")

Best practices​

  • 小さく始める: 初期探索では、より小さいサンプリング係数（0.001〜0.01）から開始する

  • 開発ワークフロー: 開発中はサンプリングを使用し、本番クエリでは削除する

  • 統計的妥当性: より大きなサンプルほど、より正確な統計的表現を得られる

  • パフォーマンステスト: クエリパフォーマンスを監視し、必要に応じてサンプリング係数を調整する

Ctrl I