このページでは、コンテナ デプロイオプションを使用する AlloyDB Omni バージョン 16.8.0 について説明します。別のデプロイオプションを選択してください。

Google は AI 技術を使用して、コンテンツをご希望の言語に翻訳しています。AI 翻訳には誤りが含まれる場合があります。

AlloyDB Omni から OpenSearch データにアクセスする

ドキュメントのバージョンを選択:

AlloyDB Omni の外部検索統合を使用して、 OpenSearch に保存されているデータにアクセスして検索できます。この統合により、データをコピーまたは移動することなく、既存の OpenSearch インデックスとリレーショナルテーブルに対してフェデレーション検索を実行できます。

始める前に

始める前に、次の操作を完了してください。

コンテナを使用して AlloyDB Omni をインストールする。
アクセス可能なパブリックエンドポイントを使用して OpenSearch をデプロイして構成する。
OpenSearch クラスタでセキュリティプラグインを有効にして、内部ユーザーデータベースに読み取り権限のみのユーザーを作成する。AlloyDB Omni は、これらの認証情報を使用して OpenSearch クラスタにアクセスします。

OpenSearch の認証情報を Secret Manager に保存する

AlloyDB Omni は、OpenSearch の認証情報を Secret Manager に保存して読み取ります。HTTP 基本認証の場合、Secret Manager の Secret の値は username:password という形式の文字列にする必要があります。Secret Manager の使用方法の詳細については、 Secret Manager を使用して Secret を作成してアクセスするをご覧ください。

AlloyDB Omni が使用するサービスアカウントに、Secret Manager から Secret を読み取るための secretmanager.secretAccessor 権限があることを確認してください。詳細については、 Secret へのアクセスを管理するをご覧ください。

`external_search_fdw` 拡張機能を有効にして構成する

OpenSearch との統合を開始するには、外部データサーバーを介して OpenSearch クラスタへのアクセスを構成します。

データベースに接続して拡張機能を有効にします。
```
CREATE EXTENSION external_search_fdw;
```
外部サーバーを作成します。
```
CREATE SERVER OPENSEARCH_SERVER_NAME
FOREIGN DATA WRAPPER external_search_fdw
OPTIONS (
  server 'OPENSEARCH_SERVER_HOST_PORT',
  search_provider 'opensearch',
  auth_mode 'secret_manager',
  auth_method 'AUTH_METHOD',
  secret_path 'SECRET_PATH'
);
```
次の変数を置き換えます。
- OPENSEARCH_SERVER_NAME: 外部データサーバーの名前。例: opensearch
- OPENSEARCH_SERVER_HOST_PORT: OpenSearch クラスタの公開 URL。例: https://search-my-domain.us-east-1.es.amazonaws.com:443
- AUTH_METHOD: 使用する認証のタイプ。例: Basic
- SECRET_PATH: OpenSearch 認証情報の Secret Manager パス。例: projects/PROJECT_ID/secrets/opensearch-credentials/versions/1

OpenSearch サーバーのユーザーマッピングを定義します。

CREATE USER MAPPING FOR CURRENT_USER
SERVER OPENSEARCH_SERVER_NAME;

OpenSearch インデックスのスキーマを PostgreSQL 外部テーブルにマッピングします。
```
CREATE FOREIGN TABLE OPENSEARCH_FD_TABLE(
    metadata external_search_fdw_schema.OpaqueMetadata,
    OPENSEARCH_FIELDS)
       SERVER OPENSEARCH_SERVER_NAME
       OPTIONS(
            remote_table_name 'OPENSEARCH_INDEX_NAME'
       );
```
次の変数を置き換えます。
- OPENSEARCH_FD_TABLE: OpenSearch テーブルを表す外部データテーブルの名前。例: my-fd-opensearch-table
- OPENSEARCH_FIELDS: 各エントリが opensearch_field_name PG_DATA_TYPE 形式に従うカンマ区切りのリスト。サポートされている OpenSearch データ型と対応する PostgreSQL 型の一覧については、サポートされているデータ型をご覧ください。
- OPENSEARCH_INDEX_NAME: OpenSearch インデックスの名前。例: my-opensearch-index

OpenSearch データをクエリする

AlloyDB Omni は、SQL クエリを OpenSearch REST API クエリに変換します。

標準 SQL クエリ

検索式には、Lucene 構文で標準 SQL を使用できます。

SELECT id, body
FROM OPENSEARCH_FD_TABLE
WHERE FILTER
ORDER BY metadata <@> 'QUERY';

次の変数を置き換えます。

OPENSEARCH_FD_TABLE: OpenSearch テーブルを表す外部データテーブルの名前。例: my-fd-opensearch-table
FILTER: （省略可）OpenSearch クエリに適用するフィルタ。例: a = 10 AND b < 105
QUERY: OpenSearch に送信するクエリ。例: body:database

クエリ DSL

高度なユースケースでは、OpenSearch JSON スタイルのクエリドメイン固有言語（DSL）を使用します。

SELECT id, title
FROM OPENSEARCH_FD_TABLE
ORDER BY metadata <@> $${
  "query": {
    "bool": {
      "must": { "match": { "title": "opensearch" } },
      "filter": { "term": { "category": "software" } }
    }
  },
  "sort": [
    { "price": { "order": "desc" } }
  ]
}$$
LIMIT 1;

OPENSEARCH_FD_TABLE は、OpenSearch テーブルを表す外部データテーブルの名前に置き換えます。例: my-fd-opensearch-table

ハイブリッド検索

OpenSearch データに対してハイブリッド検索を実行するには、OpenSearch トークン検索の結果を AlloyDB Omni ベクトル検索の結果と結合します。

SELECT *
FROM ai.hybrid_search(
  ARRAY[
    '{"limit": LIMIT,
      "weight": WEIGHT,
      "table_name": "OPENSEARCH_FD_TABLE",
      "key_column": "id",
      "query_text_input": "QUERY"}'::jsonb
  ])
ORDER BY score DESC;