从 AlloyDB 访问 OpenSearch 数据

您可以使用 AlloyDB 中的外部搜索集成来访问和搜索存储在 OpenSearch 中的数据。借助此集成，您可以将 OpenSearch 索引与 AlloyDB 中的关系表联接，而无需移动或复制数据。

准备工作

在开始之前，请确保您已完成以下操作：

• 创建集群。

• 启用出站连接 在主 AlloyDB 实例上。

• 创建和配置 OpenSearch 并使用可访问的公共端点。

• 在 OpenSearch 集群上启用安全插件，并在内部用户数据库中创建拥有只读权限的用户。AlloyDB 使用这些凭据来访问您的 OpenSearch 集群。

在 Secret Manager 中存储 OpenSearch 凭据

AlloyDB 会从 Secret Manager 中存储和读取您的 OpenSearch 凭据。如需详细了解如何使用 Secret Manager，请参阅 使用 Secret Manager 创建和访问 Secret。

确保您的 AlloyDB 服务帐号具有 Secret Manager Secret Accessor (roles/secretmanager.secretAccessor) 角色，以便从 Secret Manager 中读取 Secret。如需了解详情，请参阅 使用 Secret Manager 创建和访问 Secret。

启用和配置 external_search_fdw 扩展程序

如需开始与 OpenSearch 集成，请通过外部数据服务器配置对 OpenSearch 集群的访问权限。

1. 启用 external_search_fdw 扩展程序。

   CREATE EXTENSION external_search_fdw;
   

2. 为 OpenSearch 集群创建服务器。

   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 'Basic',
     secret_path 'SECRET_PATH'
   );
   

   执行以下变量替换操作：

   • OPENSEARCH_SERVER_NAME：外部数据服务器的名称。例如，opensearch。

   • OPENSEARCH_SERVER_HOST_PORT：OpenSearch 集群的面向公众的网址（端点）。

   • SECRET_PATH：OpenSearch 身份验证凭据的 Secret Manager 路径。例如，projects/123456789012/secrets/opensearch-credentials/versions/1。123456789012 表示您的 Google Cloud 项目 ID。

3. 为 OpenSearch 服务器定义 PostgreSQL 用户映射。请注意，PostgreSQL FDW 需要此用户映射才能正常运行。AlloyDB 使用 REST 授权标头进行身份验证。

   CREATE USER MAPPING FOR CURRENT_USER
   SERVER OPENSEARCH_SERVER_NAME;
   

4. 将 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。

支持的数据类型

AlloyDB 支持以下 OpenSearch 数据类型：

查询 OpenSearch 数据

AlloyDB 接受 SQL 查询，并将其转换为 OpenSearch REST API 查询。

如需查询 OpenSearch 数据，您可以使用以下选项：

• 标准 SQL 查询
• 查询 DSL
• 混合搜索

标准 SQL 查询

您可以将标准 SQL 与 Lucene 语法搭配使用作为搜索表达式。

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。