Azure Cognitive Search是否支持PostgreSQL？求官方文档及对接示例

Azure Cognitive Search 目前没有内置的PostgreSQL数据源连接器，所以你在「导入数据」界面看不到该选项是正常情况，可通过以下两种方案实现对接：

方法一：通过代码直接拉取并推送数据 #

使用PostgreSQL驱动和Azure Cognitive Search SDK，编写代码从PostgreSQL提取数据并批量导入到搜索索引。

步骤与示例代码 #

1. 安装依赖NuGet包：

   • Npgsql（PostgreSQL官方.NET驱动）
   • Azure.Search.Documents（Azure Cognitive Search SDK）

2. 实现数据同步的C#示例：

using Npgsql;
using Azure.Search.Documents;
using Azure.Search.Documents.Models;
using Azure;

// 配置参数
string postgresConnStr = "Host=你的PostgreSQL主机地址;Username=用户名;Password=密码;Database=目标数据库";
string searchEndpoint = "https://你的搜索服务名称.search.windows.net";
string searchApiKey = "你的搜索服务管理员密钥";
string targetIndex = "目标索引名称";

// 初始化搜索客户端
var searchClient = new SearchClient(new Uri(searchEndpoint), targetIndex, new AzureKeyCredential(searchApiKey));

// 从PostgreSQL查询数据
using var pgConn = new NpgsqlConnection(postgresConnStr);
await pgConn.OpenAsync();
var queryCmd = new NpgsqlCommand("SELECT id, title, content FROM 你的数据表", pgConn);
using var reader = await queryCmd.ExecuteReaderAsync();

// 转换为搜索文档并批量上传
var docsToUpload = new List<SearchDocument>();
while (await reader.ReadAsync())
{
    var searchDoc = new SearchDocument
    {
        ["id"] = reader.GetInt32(0).ToString(), // 搜索索引的id字段需为字符串类型
        ["title"] = reader.GetString(1),
        ["content"] = reader.GetString(2)
    };
    docsToUpload.Add(searchDoc);
}

if (docsToUpload.Any())
{
    var uploadBatch = IndexDocumentsBatch.Upload(docsToUpload);
    await searchClient.IndexDocumentsAsync(uploadBatch);
}

方法二：通过Azure Data Factory中转 #

借助Azure Data Factory将PostgreSQL数据同步到Azure Cognitive Search支持的内置数据源（如Azure Blob存储、Azure SQL数据库），再通过「导入数据」工具完成索引创建：

• 1. 在Azure Data Factory中创建复制管道，将PostgreSQL数据同步到Blob存储或Azure SQL
• 2. 回到Azure Cognitive Search的「导入数据」界面，选择同步后的数据源，完成索引配置与数据导入

官方参考方向 #

Azure Cognitive Search官方文档中「自定义技能开发」章节包含扩展数据源的通用指导，可在Azure门户的搜索服务文档中查阅该部分内容，了解更多自定义数据接入的细节。

内容的提问来源于stack exchange，提问作者Learn AspNet