在实时中心添加 PostgreSQL 数据库 CDC 作为源（预览版）

项目
10/25/2024

本文介绍如何在 Fabric 实时中心中添加 PostgreSQL 数据库变更数据捕获 (CDC) 作为事件源。

通过用于 Microsoft Fabric 事件流的 Postgre SQL 数据库变更数据捕获 (CDC) 源连接器，你可以捕获 PostgreSQL 数据库中当前数据的快照。然后，连接器将监视并记录对此数据进行的任何未来的行级别更改。

注意

实时中心目前处于预览阶段。

先决条件

获取对拥有参与者或更高权限的 Fabric 高级工作区的访问权限。
已在 PostgreSQL 数据库中注册用户访问权限。
在 PostgreSQL 数据库中启用了 CDC。

如果你具有 Azure Database for PostgreSQL，请按照下一部分中的步骤启用 CDC。有关详细信息，请参阅逻辑复制和逻辑解码 - Azure Database for PostgreSQL – 灵活服务器。

有关其他 PostgreSQL 数据库，请参阅用于 PostgreSQL 的 Debezium 连接器 :: Debezium 文档。

注意

不支持多个表 CDC。

在 Azure Database for PostgreSQL 中启用 CDC

要在 Azure Database for PostgreSQL 中启用 CDC，请根据部署类型执行以下步骤。

Azure Database for PostgreSQL 单一服务器

转到 Azure 门户上的“复制”页。
将复制规则更改为“逻辑”。

Azure Database for PostgreSQL 灵活服务器

在 Azure 门户中 Azure Database for PostgreSQL 灵活服务器页上的导航菜单中，选择“服务器参数”。
在“服务器参数”页上：
- 将 "wal_level" 设置为“逻辑”。
- 将 "max_worker_processes" 更新为至少 "16"。
保存所做的更改并重启服务器。
确认 Azure Database for PostgreSQL 灵活服务器实例允许公用网络流量。
通过运行以下 SQL 语句授予管理员用户复制权限。
```
ALTER ROLE <admin user> WITH REPLICATION;
```

启动“添加源”体验

登录 Microsoft Fabric。
选择左侧导航栏上的“实时中心”。
在 “实时中心 ”页上，选择 页面右上角的“+ 添加源 ”。

使用“添加 PostgreSQL 数据库 CDC 作为源”部分中的说明。

Microsoft源页

在实时中心，选择 Microsoft源。
在“源”下拉列表中，选择“PostgreSQL 数据库 (CDC)”。
对于“订阅”，选择具有 Azure MySQL Database 帐户的资源组的“Azure 订阅”。
对于“资源组”，选择具有数据库的资源组。
对于“区域”，选择数据库所在的位置。
现在，将鼠标移在要连接到数据库列表中的实时中心的 PostgreSQL Database CDC 源名称上，并选择“连接”按钮，或选择 "..."（省略号），然后选择“连接”按钮。

要配置连接信息，请使用“添加 Azure MySQL DB CDC 作为源”部分中的步骤。跳过在“添加源”向导中选择 Azure MySQL DB CDC 作为源类型的第一步。

添加 Azure Database for PostgreSQL CDC 作为源

在“选择数据源”屏幕上，选择 "Azure DB for PostgreSQL (CDC)"。
在“连接”页上，选择“转到资源”以导航到 Azure PostgreSQL 数据库。在“概述”页上，记下服务器名称。其格式如下：myazurepostgresqlserver.postgres.database.azure.com。
在“连接”页上，选择“新建连接”。
在“连接设置”部分中，输入以下信息。
- 服务器：PostgreSQL 数据库的服务器地址，例如 my-pgsql-server.postgres.database.azure.com。
- 数据库：数据库名称，例如 my_database。
向下滚动，然后在“连接凭据”部分中，执行以下步骤。
1. 对于“连接名称”，为连接输入名称。
2. 对于“身份验证类型”，选择“基本”。
  
  注意
  
  目前，Fabric 事件流仅支持“基本”身份验证。
3. 输入数据库的“用户名”和“密码”。
4. 选择“连接” 。
现在，在“连接”页上，执行以下步骤：
1. 对于“表”，输入表名称。
2. 对于“端口”，输入端口号或保留默认值：5432。
3. 对于“事件流名称”，输入事件流的名称。该向导会创建一个事件流，其中所选 PostgreSQL 数据库 CDC 作为源。
4. “流名称”是通过将 -stream 追加到事件流的名称中自动为你生成的。向导完成后， 会在“所有数据流”页上看到此流 。
5. 选择页面底部的“下一步”。
在“查看并创建”屏幕上，查看摘要，然后选择“创建源”。