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

Analyzer Overview

テキスト処理において、アナライザーは生のテキストを構造化された検索可能な形式に変換する重要なコンポーネントです。各アナライザーは通常、トークナイザーフィルターという2つのコア要素で構成されます。これらが連携して入力テキストをトークンに変換・加工し、効率的なインデックス作成と検索に備えます。

Zilliz Cloudでは、アナライザーはコレクション作成時にVARCHARフィールドをコレクションスキーマに追加する際に設定されます。アナライザーによって生成されたトークンは、キーワードマッチング用のインデックスを構築するために使用したり、全文検索用のスパース埋め込みに変換したりできます。詳細については、Full Text SearchまたはText Matchを参照してください。

📘Notes

アナライザーの使用はパフォーマンスに影響を与える可能性があります。

  • 全文検索: 全文検索では、DataNodeおよびQueryNodeのチャネルがトークン化の完了を待つ必要があるため、データの消費速度が低下します。その結果、新しく取り込まれたデータが検索可能になるまでの時間が長くなります。

  • キーワードマッチ: キーワードマッチングでも、インデックス構築前にトークン化を完了する必要があるため、インデックス作成に時間がかかります。

アナライザーの構造

Zilliz Cloudのアナライザーは、1つのトークナイザー0個以上のフィルターで構成されます。

  • トークナイザー: トークナイザーは、入力テキストをトークンと呼ばれる個別の単位に分割します。トークンは、トークナイザーの種類に応じて単語やフレーズになります。

  • フィルター: フィルターを適用することで、小文字への変換や一般的な単語の除去など、トークンをさらに加工できます。

📘Notes

トークナイザーはUTF-8形式のみをサポートしています。他の形式への対応は、今後のリリースで追加される予定です。

以下のワークフローは、アナライザーによるテキスト処理の流れを示しています。

Ke6jw8437hjR8hbZCvEcQtIIn1e

アナライザーの種類

Zilliz Cloudは、さまざまなテキスト処理ニーズに対応するため、2種類のアナライザーを提供しています。

  • 組み込みアナライザー: 最小限の設定で一般的なテキスト処理タスクをカバーする事前定義済みの構成です。複雑な設定が不要なため、汎用的な検索に最適です。

  • カスタムアナライザー: より高度な要件には、トークナイザーと0個以上のフィルターを指定して独自の構成を定義できるカスタムアナライザーを使用します。このカスタマイズ性は、テキスト処理を細かく制御したい特殊なユースケースで特に有効です。

📘Notes
  • コレクション作成時にアナライザーの設定を省略した場合、Zilliz Cloudはデフォルトでstandardアナライザーを使用してすべてのテキスト処理を行います。詳細については、Standardを参照してください。

  • 最適な検索・クエリパフォーマンスを得るには、テキストデータの言語に適したアナライザーを選択してください。たとえば、standardアナライザーは汎用性が高いものの、中国語、日本語、韓国語など独自の文法構造を持つ言語には不向きな場合があります。そのような場合は、chineseのような言語固有のアナライザーや、専用のトークナイザー(linderaicuなど)とフィルターを組み合わせたカスタムアナライザーを使用することを強く推奨します。これにより、正確なトークン化とより良い検索結果が得られます。

Built-in analyzer

Zilliz Cloud クラスターの Built-in analyzer には、特定のトークナイザーとフィルターが事前に設定されており、これらのコンポーネントを自ら定義することなくすぐに利用できます。各 Built-in analyzer は、プリセットのトークナイザーとフィルターを含むテンプレートとして機能し、カスタマイズ用のオプションパラメーターも備えています。

たとえば、standard Built-in analyzer を使用するには、その名前 standardtype として指定するだけで済みます。必要に応じて、stop_words など、この analyzer タイプ固有の追加設定を含めることもできます。

python
analyzer_params = {
"type": "standard", # Uses the standard built-in analyzer
"stop_words": ["a", "an", "for"] # Defines a list of common words (stop words) to exclude from tokenization
}

analyzer の実行結果を確認するには、run_analyzer メソッドを使用します。

python
# Sample text to analyze
text = "An efficient system relies on a robust analyzer to correctly process text for various applications."

# Run analyzer
result = client.run_analyzer(
text,
analyzer_params
)

出力は次のようになります。

sql
['efficient', 'system', 'relies', 'on', 'robust', 'analyzer', 'to', 'correctly', 'process', 'text', 'various', 'applications']

この結果は、analyzer がストップワードである "a""an""for" を除外して入力テキストを適切にトークン化し、意味のあるトークンのみを返していることを示しています。

上記の standard Built-in analyzer の設定は、以下のパラメーターで custom analyzer を構築する場合と同等です。ここでは、tokenizer オプションと filter オプションを明示的に定義することで、同様の機能を実現しています。

python
analyzer_params = {
"tokenizer": "standard",
"filter": [
"lowercase",
{
"type": "stop",
"stop_words": ["a", "an", "for"]
}
]
}

Zilliz Cloud では、特定のテキスト処理ニーズに合わせて設計された、以下の Built-in analyzer を提供しています。

  • standard: 標準的なトークン化と小文字化フィルタリングを適用する、汎用的なテキスト処理に適しています。

  • english: 英語のストップワードに対応しており、英語テキストの処理に最適化されています。

  • chinese: 中国語の言語構造に適したトークン化など、中国語テキストの処理に特化しています。

Custom analyzer

より高度なテキスト処理を行う場合、Zilliz Cloud の Custom analyzer を使用すると、tokenizerfilters の両方を指定して、目的に合わせたテキスト処理パイプラインを構築できます。この構成は、細かな制御が求められる特殊なユースケースに最適です。

Tokenizer

tokenizer はカスタムアナライザーに必須のコンポーネントであり、入力テキストを個別の単位(トークン)に分割してアナライザーパイプラインを開始します。トークン化は tokenizer の種類に応じて、空白や句読点での分割など特定のルールに従って行われます。この処理により、各単語やフレーズをより精密かつ独立して扱えるようになります。

たとえば、tokenizer はテキスト "Vector Database Built for Scale" を個別のトークンに変換します。

plaintext
["Vector", "Database", "Built", "for", "Scale"]

tokenizer の指定例:

python
analyzer_params = {
"tokenizer": "whitespace",
}

Filter

フィルターは、tokenizer が生成したトークンに対して動作するオプションのコンポーネントであり、必要に応じてトークンを変換または調整します。たとえば、トークン化された用語 ["Vector", "Database", "Built", "for", "Scale"]lowercase フィルターを適用すると、結果は次のようになります。

sql
["vector", "database", "built", "for", "scale"]

カスタムアナライザーのフィルターは、設定要件に応じて組み込みまたはカスタムのいずれかを選択できます。

  • 組み込みフィルター: Zilliz Cloud によって事前設定されており、最小限のセットアップで利用できます。名前を指定するだけでそのまま使用でき、以下のフィルターが組み込みとして提供されています。

    • lowercase: テキストを小文字に変換し、大文字・小文字を区別しないマッチングを実現します。詳細は Lowercase を参照してください。

    • asciifolding: 非 ASCII 文字を対応する ASCII 文字に変換し、多言語テキストの処理を簡素化します。詳細は ASCII folding を参照してください。

    • alphanumonly: 英数字以外の文字を除去し、英数字のみを保持します。詳細は Alphanumonly を参照してください。

    • cnalphanumonly: 中国語の文字、英字、数字以外の文字を含むトークンを削除します。詳細は Cnalphanumonly を参照してください。

    • cncharonly: 中国語以外の文字を含むトークンを削除します。詳細は Cncharonly を参照してください。

    • pinyin: 中国語トークンにピンイン形式を追加し、中国語テキストでのピンインベースのマッチングを可能にします。詳細は Pinyin を参照してください。

    組み込みフィルターの使用例:

    python
    analyzer_params = {
    "tokenizer": "standard", # Mandatory: Specifies tokenizer
    "filter": ["lowercase"], # Optional: Built-in filter that converts text to lowercase
    }
  • カスタムフィルター: カスタムフィルターでは専用の設定が行えます。有効なフィルタータイプ(filter.type)を選択し、各タイプに固有の設定を追加することで定義できます。カスタマイズ可能なフィルタータイプの例は以下のとおりです。

    • stop: ストップワードのリスト(例: "stop_words": ["of", "to"])を設定し、指定された一般的な単語を削除します。詳細は Stop を参照してください。

    • length: 最大トークン長などの長さの条件に基づいてトークンを除外します。詳細は Length を参照してください。

    • stemmer: 単語を語幹に変換し、より柔軟なマッチングを実現します。詳細は Stemmer を参照してください。

    カスタムフィルターの設定例:

    python
    analyzer_params = {
    "tokenizer": "standard", # Mandatory: Specifies tokenizer
    "filter": [
    {
    "type": "stop", # Specifies 'stop' as the filter type
    "stop_words": ["of", "to"], # Customizes stop words for this filter type
    }
    ]
    }

使用例

この例では、以下を含むコレクションスキーマを作成します。

  • 埋め込み用のベクトルフィールド

  • テキスト処理用の 2 つの VARCHAR フィールド:

    • 1 つのフィールドは組み込みアナライザーを使用します。

    • もう 1 つのフィールドはカスタムアナライザーを使用します。

これらの設定をコレクションに組み込む前に、run_analyzer メソッドを使用して各アナライザーを検証します。

ステップ 1: MilvusClient の初期化とスキーマの作成

まず、Milvus client を設定し、新しいスキーマを作成します。

python
from pymilvus import MilvusClient, DataType

# Set up a Milvus client
client = MilvusClient(
uri="YOUR_CLUSTER_ENDPOINT"
token="YOUR_CLUSTER_TOKEN"
)

# Create a new schema
schema = client.create_schema(auto_id=True, enable_dynamic_field=False)

ステップ 2: アナライザー設定の定義と検証

  1. 組み込みアナライザーの設定と検証 (english):

    • 設定: 組み込みの英語アナライザーのパラメーターを定義します。

    • 検証: run_analyzer を使用して、設定により期待どおりのトークン化が得られることを確認します。

    python
    # Built-in analyzer configuration for English text processing
    analyzer_params_built_in = {
    "type": "english"
    }
    # Verify built-in analyzer configuration
    sample_text = "Milvus simplifies text analysis for search."
    result = client.run_analyzer(sample_text, analyzer_params_built_in)
    print("Built-in analyzer output:", result)

    # Expected output:
    # Built-in analyzer output: ['milvus', 'simplifi', 'text', 'analysi', 'search']
  2. カスタムアナライザーの設定と検証:

    • 設定: 標準トークナイザーに加え、組み込みの小文字化フィルター、およびトークン長とストップワードのカスタムフィルターを使用するカスタムアナライザーを定義します。

    • 検証: run_analyzer を使用して、カスタム設定が意図どおりにテキストを処理することを確認します。

    python
    # Custom analyzer configuration with a standard tokenizer and custom filters
    analyzer_params_custom = {
    "tokenizer": "standard",
    "filter": [
    "lowercase", # Built-in filter: convert tokens to lowercase
    {
    "type": "length", # Custom filter: restrict token length
    "max": 40
    },
    {
    "type": "stop", # Custom filter: remove specified stop words
    "stop_words": ["of", "for"]
    }
    ]
    }

    # Verify custom analyzer configuration
    sample_text = "Milvus provides flexible, customizable analyzers for robust text processing."
    result = client.run_analyzer(sample_text, analyzer_params_custom)
    print("Custom analyzer output:", result)

    # Expected output:
    # Custom analyzer output: ['milvus', 'provides', 'flexible', 'customizable', 'analyzers', 'robust', 'text', 'processing']

ステップ 3: スキーマフィールドにアナライザーを追加する

アナライザー設定の検証が完了したら、スキーマフィールドに追加します。

python
# Add VARCHAR field 'title_en' using the built-in analyzer configuration
schema.add_field(
field_name='title_en',
datatype=DataType.VARCHAR,
max_length=1000,
enable_analyzer=True,
analyzer_params=analyzer_params_built_in,
enable_match=True,
)

# Add VARCHAR field 'title' using the custom analyzer configuration
schema.add_field(
field_name='title',
datatype=DataType.VARCHAR,
max_length=1000,
enable_analyzer=True,
analyzer_params=analyzer_params_custom,
enable_match=True,
)

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

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

ステップ 4: インデックスパラメーターを準備してコレクションを作成する

python
# Set up index parameters for the vector field
index_params = client.prepare_index_params()
index_params.add_index(field_name="embedding", metric_type="COSINE", index_type="AUTOINDEX")

# Create the collection with the defined schema and index parameters
client.create_collection(
collection_name="my_collection",
schema=schema,
index_params=index_params
)

Zilliz Cloud コンソールでの使用例

上記の操作は、Zilliz Cloud コンソールでも実行できます。詳しくは以下のデモをご覧ください。

📘**Note**

アナライザーの設定は、コレクションの作成後は変更できません。設定を変更する場合は、新しいコレクションを desired な設定で作成し、データを移行してください。

次のステップ

アナライザーを設定する際は、ユースケースに最適な構成を検討するため、以下のベストプラクティス記事をご参照ください。

アナライザーの設定後、Zilliz Cloud が提供するテキスト検索機能を利用できます。詳細は以下をご覧ください。

Ctrl I