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

Phrase Match

Phrase match を使用すると、クエリ語を完全なフレーズとして含むドキュメントを検索できます。デフォルトでは、単語は同じ順序で、互いに直接隣接して出現する必要があります。たとえば、"robotics machine learning" というクエリは、"…typical robotics machine learning models…" のようなテキストに一致します。ここでは、"robotics""machine""learning" という単語が、間にほかの単語を挟まずに連続して出現しています。

ただし、実際のシナリオでは、厳密なフレーズ一致は硬直的すぎる場合があります。たとえば、"…machine learning models widely adopted in robotics…" のようなテキストにも一致させたいことがあります。この場合、同じキーワードは含まれていますが、隣接しておらず、元の順序でもありません。これに対応するため、phrase match は slop パラメーターをサポートしています。これにより柔軟性が加わります。slop の値は、フレーズ内の語句間で許容される位置のずれの数を定義します。たとえば、slop が 1 の場合、"machine learning" というクエリは、元の語の間に 1 語("deep")が入る "...machine deep learning..." のようなテキストにも一致できます。

概要

Tantivy 検索エンジンライブラリを基盤とする phrase match は、ドキュメント内の単語の位置情報を解析して動作します。以下の図はそのプロセスを示しています。

AFrdwVT8ChT11ibs9lpcuN7onZc

  1. ドキュメントのトークン化: ドキュメントを Zilliz Cloud に挿入すると、テキストは analyzer によってトークン(個々の単語または語句)に分割され、各トークンの位置情報が記録されます。たとえば、doc_1["machine" (pos=0), "learning" (pos=1), "boosts" (pos=2), "efficiency" (pos=3)] にトークン化されます。analyzer の詳細については、Analyzer Overview を参照してください。

  2. 転置インデックスの作成: Zilliz Cloud は転置インデックスを構築し、各トークンを、そのトークンが出現するドキュメントと、そのドキュメント内でのトークンの位置に対応付けます。

  3. フレーズ一致: フレーズクエリが実行されると、Zilliz Cloud は転置インデックス内で各トークンを検索し、それらの位置を確認して、正しい順序と近接性で出現しているかを判断します。slop パラメーターは、一致するトークン間に許容される最大位置数を制御します。

    • slop = 0 は、トークンが 正確な順序で、かつ直ちに隣接して 出現する必要があることを意味します(つまり、間に余分な単語は許可されません)。

      • この例では、doc_1 のみが正確に一致します("machine"pos=0"learning"pos=1)。
    • slop = 2 は、一致するトークン間で最大 2 位置分の柔軟性または並び替えを許可します。

      • これにより、逆順("learning machine")や、トークン間に少し間隔がある場合も許可されます。

      • その結果、doc_1doc_2"learning"pos=0"machine"pos=1)、および doc_3"learning"pos=1"machine"pos=2)のすべてが一致します。

phrase match を有効にする

Phrase match は、Zilliz Cloud の文字列データ型である VARCHAR フィールド型で動作します。

phrase matching を有効にするには、collection schema を設定し、enable_analyzerenable_match の両方のパラメーターを True に設定します。この設定により、テキストがトークン化され、位置情報を含む転置インデックスが構築されるため、効率的なフレーズ検索が可能になります。

schema フィールドを定義する

特定の VARCHAR フィールドで phrase match を有効にするには、フィールド schema を定義する際に enable_analyzerenable_match の両方を True に設定します。

python
from pymilvus import MilvusClient, DataType

# Set up a MilvusClient
CLUSTER_ENDPOINT = "YOUR_CLUSTER_ENDPOINT"
TOKEN = "YOUR_CLUSTER_TOKEN"

client = MilvusClient(
uri=CLUSTER_ENDPOINT,
token=TOKEN
)

# Create a schema for a new collection
schema = client.create_schema(enable_dynamic_field=False)

# Add a primary key field
schema.add_field(
field_name="id",
datatype=DataType.INT64,
is_primary=True,
auto_id=True
)

# Add a VARCHAR field configured for phrase matching
schema.add_field(
field_name="text", # Name of the field
datatype=DataType.VARCHAR, # Field data type set as VARCHAR (string)
max_length=1000, # Maximum string length
enable_analyzer=True, # Required. Enables text analysis
enable_match=True, # Required. Enables inverted indexing for phrase matching
# Optional: Use a custom analyzer for better phrase matching in specific languages.
# analyzer_params = {"type": "english"} # Example: English analyzer; uncomment to apply custom analyzer
)

# Add a vector field for embeddings
schema.add_field(
field_name="embeddings",
datatype=DataType.FLOAT_VECTOR,
dim=5
)

デフォルトでは、Zilliz Cloud は standard analyzer を使用します。これは、空白と句読点でテキストをトークン化し、テキストを小文字に変換します。

テキストデータが特定の言語や形式である場合は、analyzer_params パラメーターを使用してカスタム analyzer を設定できます(たとえば、{ "type": "english" }{ "type": "jieba" })。

詳細については、Analyzer Overview を参照してください。

collection を作成する

必要なフィールドを定義したら、次のコードを使用して collection を作成します。

python
# Create the collection
COLLECTION_NAME = "tech_articles" # Name your collection

if client.has_collection(COLLECTION_NAME):
client.drop_collection(COLLECTION_NAME)

client.create_collection(
collection_name=COLLECTION_NAME,
schema=schema
)

collection の作成後、phrase match の使用 の前に、以下の必要な手順が実行されていることを確認してください。

  • エンティティが collection に挿入されていること。

  • 各 vector フィールドに index が作成されていること。

  • collection がメモリにロードされていること。

コード例を表示
python
# Insert sample data with text containing "machine learning" phrases
sample_data = [
{
"text": "Machine learning is a subset of artificial intelligence that focuses on algorithms.",
"embeddings": [0.1, 0.2, 0.3, 0.4, 0.5]
},
{
"text": "Deep learning machine algorithms require large datasets for training.",
"embeddings": [0.2, 0.3, 0.4, 0.5, 0.6]
},
{
"text": "The machine learning model showed excellent performance on the test set.",
"embeddings": [0.3, 0.4, 0.5, 0.6, 0.7]
},
{
"text": "Natural language processing and machine learning go hand in hand.",
"embeddings": [0.4, 0.5, 0.6, 0.7, 0.8]
},
{
"text": "This article discusses various learning machine techniques and applications.",
"embeddings": [0.5, 0.6, 0.7, 0.8, 0.9]
}
]

# Insert the data
client.insert(
collection_name=COLLECTION_NAME,
data=sample_data
)

# Index the vector field and load the collection
index_params = client.prepare_index_params()
index_params.add_index(
field_name="embeddings",
index_type="AUTOINDEX",
index_name="embeddings_index",
metric_type="COSINE"
)

client.create_index(collection_name=COLLECTION_NAME, index_params=index_params)

client.load_collection(collection_name=COLLECTION_NAME)

フレーズ一致を使用する

collection スキーマ内の VARCHAR フィールドで match を有効にすると、PHRASE_MATCH 式を使用してフレーズ一致を実行できます。

📘注記

PHRASE_MATCH 式では大文字と小文字は区別されません。PHRASE_MATCHphrase_match のどちらも使用できます。

PHRASE_MATCH 式の構文

検索時にフィールド、フレーズ、およびオプションの柔軟性(slop)を指定するには、PHRASE_MATCH 式を使用します。構文は次のとおりです。

python
PHRASE_MATCH(field_name, phrase, slop)
  • field_name: フレーズ一致を実行する VARCHAR フィールドの名前。

  • phrase: 検索する完全なフレーズ。

  • slop (optional): 一致する token 間で許可される最大位置数を指定する整数。

    • 0(デフォルト): 完全一致するフレーズのみを一致させます。例: "machine learning" に対する filter は "machine learning" に正確に一致しますが、"machine boosts learning""learning machine" には一致しません。

    • 1: 1 つの追加語句や位置のわずかなずれなど、軽微な変化を許可します。例: "machine learning" に対する filter は "machine boosts learning""machine""learning" の間に 1 token ある)には一致しますが、"learning machine"(語順が逆)には一致しません。

    • 2: 語順の逆転や、その間に最大 2 つの token が入るケースを含む、より高い柔軟性を許可します。例: "machine learning" に対する filter は "learning machine"(語順が逆)や "machine quickly boosts learning""machine""learning" の間に 2 token ある)に一致します。

フレーズ一致を使った query

query() メソッドを使用する場合、PHRASE_MATCH は scalar filter として機能します。指定したフレーズを含むドキュメントのみが返されます(許可された slop に従います)。

例: slop = 0(完全一致)

この例では、間に余分な token を含まない、完全なフレーズ "machine learning" を含むドキュメントを返します。

python
# Match documents containing exactly "machine learning"
filter = "PHRASE_MATCH(text, 'machine learning')"

result = client.query(
collection_name=COLLECTION_NAME,
filter=filter,
output_fields=["id", "text"]
)

print("Query result: ", result)

# Expected output:
# Query result: data: ["{'id': 461366973343948097, 'text': 'Machine learning is a subset of artificial intelligence that focuses on algorithms.'}", "{'id': 461366973343948099, 'text': 'The machine learning model showed excellent performance on the test set.'}", "{'id': 461366973343948100, 'text': 'Natural language processing and machine learning go hand in hand.'}"]

フレーズ一致を使った search

search 操作では、PHRASE_MATCH は vector 類似度ランキングを適用する前にドキュメントを事前に絞り込むために使用されます。この 2 段階のアプローチでは、まずテキスト一致によって候補セットを絞り込み、その後、それらの候補を vector embeddings に基づいて再ランキングします。

例: slop = 1

ここでは、slop を 1 に設定します。この filter は、わずかな柔軟性を持ってフレーズ "learning machine" を含むドキュメントに適用されます。

python
# Example: Filter documents containing "learning machine" with slop=1
filter_slop1 = "PHRASE_MATCH(text, 'learning machine', 1)"

result_slop1 = client.search(
collection_name=COLLECTION_NAME,
anns_field="embeddings",
data=[[0.1, 0.2, 0.3, 0.4, 0.5]],
filter=filter_slop1,
search_params={},
limit=10,
output_fields=["id", "text"]
)

print("Slop 1 result: ", result_slop1)

# Expected output:
# Slop 1 result: data: [[{'id': 461366973343948098, 'distance': 0.9949367046356201, 'entity': {'text': 'Deep learning machine algorithms require large datasets for training.', 'id': 461366973343948098}}, {'id': 461366973343948101, 'distance': 0.9710607528686523, 'entity': {'text': 'This article discusses various learning machine techniques and applications.', 'id': 461366973343948101}}]]

例: slop = 2

この例では slop を 2 に設定します。つまり、"machine""learning" の間に最大 2 つの追加 token(または語順が逆の語)が許可されます。

python
# Example: Filter documents containing "machine learning" with slop=2
filter_slop2 = "PHRASE_MATCH(text, 'machine learning', 2)"

result_slop2 = client.search(
collection_name=COLLECTION_NAME,
anns_field="embeddings", # Vector field name
data=[[0.1, 0.2, 0.3, 0.4, 0.5]], # Query vector
filter=filter_slop2, # Filter expression
search_params={},
limit=10, # Maximum results to return
output_fields=["id", "text"]
)

print("Slop 2 result: ", result_slop2)

# Expected output:
# Slop 2 result: data: [[{'id': 461366973343948097, 'distance': 0.9999999403953552, 'entity': {'text': 'Machine learning is a subset of artificial intelligence that focuses on algorithms.', 'id': 461366973343948097}}, {'id': 461366973343948098, 'distance': 0.9949367046356201, 'entity': {'text': 'Deep learning machine algorithms require large datasets for training.', 'id': 461366973343948098}}, {'id': 461366973343948099, 'distance': 0.9864400029182434, 'entity': {'text': 'The machine learning model showed excellent performance on the test set.', 'id': 461366973343948099}}, {'id': 461366973343948100, 'distance': 0.9782319068908691, 'entity': {'text': 'Natural language processing and machine learning go hand in hand.', 'id': 461366973343948100}}, {'id': 461366973343948101, 'distance': 0.9710607528686523, 'entity': {'text': 'This article discusses various learning machine techniques and applications.', 'id': 461366973343948101}}]]

例: slop = 3

この例では、slop を 3 にするとさらに柔軟性が高まります。この filter は、単語間に最大 3 token の位置を許可して "machine learning" を検索します。

python
# Example: Filter documents containing "machine learning" with slop=3
filter_slop3 = "PHRASE_MATCH(text, 'machine learning', 3)"

result_slop3 = client.search(
collection_name=COLLECTION_NAME,
anns_field="embeddings", # Vector field name
data=[[0.1, 0.2, 0.3, 0.4, 0.5]], # Query vector
filter=filter_slop3, # Filter expression
search_params={},
limit=10, # Maximum results to return
output_fields=["id", "text"]
)

print("Slop 3 result: ", result_slop3)

# Expected output:
# Slop 3 result: data: [[{'id': 461366973343948097, 'distance': 0.9999999403953552, 'entity': {'text': 'Machine learning is a subset of artificial intelligence that focuses on algorithms.', 'id': 461366973343948097}}, {'id': 461366973343948098, 'distance': 0.9949367046356201, 'entity': {'text': 'Deep learning machine algorithms require large datasets for training.', 'id': 461366973343948098}}, {'id': 461366973343948099, 'distance': 0.9864400029182434, 'entity': {'text': 'The machine learning model showed excellent performance on the test set.', 'id': 461366973343948099}}, {'id': 461366973343948100, 'distance': 0.9782319068908691, 'entity': {'text': 'Natural language processing and machine learning go hand in hand.', 'id': 461366973343948100}}, {'id': 461366973343948101, 'distance': 0.9710607528686523, 'entity': {'text': 'This article discusses various learning machine techniques and applications.', 'id': 461366973343948101}}]]

考慮事項

  • フィールドに対してフレーズ一致を有効にすると、ストレージリソースを消費する反転 index が作成されます。この機能を有効にするかどうかを決める際は、ストレージへの影響を考慮してください。影響は、テキストサイズ、一意なトークン数、使用する analyzer によって異なります。

  • スキーマで analyzer を定義すると、その設定はその collection に対して永続的になります。別の analyzer の方が要件に適していると判断した場合は、既存の collection を削除し、希望する analyzer 設定で新しい collection を作成することを検討してください。

  • フレーズ一致のパフォーマンスは、テキストがどのようにトークン化されるかに依存します。analyzer を collection 全体に適用する前に、run_analyzer メソッドを使用してトークン化の出力を確認してください。詳細については、Analyzer Overview を参照してください。

  • filter 式におけるエスケープ規則:

    • 式内でダブルクォートまたはシングルクォートで囲まれた文字は、文字列定数として解釈されます。文字列定数にエスケープ文字が含まれる場合、それらのエスケープ文字はエスケープシーケンスで表現する必要があります。たとえば、\\\、タブ \t\\t、改行は \\n を使用して表現します。

    • 文字列定数がシングルクォートで囲まれている場合、定数内のシングルクォートは \\' で表現し、ダブルクォートは " または \\" のいずれかで表現できます。例: 'It\\'s milvus'

    • 文字列定数がダブルクォートで囲まれている場合、定数内のダブルクォートは \\" で表現し、シングルクォートは ' または \\' のいずれかで表現できます。例: "He said \\"Hi\\""

Ctrl I