排查 Azure Database for PostgreSQL 灵活服务器中的 Fabric 镜像数据库问题

本文介绍镜像 Azure Database for PostgreSQL 灵活服务器的故障排除步骤。

排查在选择用于镜像的表时出现的错误或警告消息

创建新的镜像数据库时，在 “选择数据 ”页中，可能会收到有关源数据库中特定表的一些视觉反馈。 下表提供了潜在问题的列表，包括显示的消息以及有关如何解决问题的相关说明。

¹ 不支持具有空格 （' '） 字符的对象标识符。

² 镜像不支持此表类型。 目前不支持视图、物化视图、外部表和分区表。 TimescaleDB 超表不支持 Fabric 镜像。

³ 有关不支持的数据类型的列表，请参阅 “限制”。 仅支持具有以下类型的列：

• bigint
• bigserial
• boolean
• bytea
• character
• character varying
• date
• double precision
• integer
• numeric
• real
• serial
• oid
• money
• smallint
• smallserial
• text
• time without time zone
• time with time zone （* 不作为主键）
• timestamp without time zone
• timestamp with time zone
• uuid
• xml
• json
• jsonb
• inet
• cidr
• macaddr
• macaddr8
• tsvector
• tsquery
• int4range
• int8range
• numrange
• tsrange
• tstzrange
• daterange
• circle
• line
• lseg
• box
• path
• point
• polygon
• interval

在 Postgres 中，两个对应完全相同时刻但属于不同时区的“带时区的时间”值被认为是不同的。 例如： 06:24:00.59+05 对应于 05:24:00.59+04 同一时期的时间，但 Postgres 以不同的方式对待它们。

在将源数据库架构中的默认不受约束（无定义精度和规模）数字列复制到 OneLake 表之前，这些列将转换为 Decimal128(38, 0)，与 SQL 标准惯例保持一致，未指定规模意味着整数精度。

源数据库支持的数据定义语言（DDL）操作

• Rename column：新名称的列将添加到Fabric中的镜像表中，并包含新插入行的数据（对于现有行将为 NULL）。 旧列仍然保留现有行的值，而新行的值为空。
• 添加列：添加的列在镜像表中可见，并包含新插入行的数据（对于现有行是 NULL）。
• 删除列：被删除的列在镜像表中仍然可见，并包含现有行的数据（对于新行，其值为 NULL）。
• 更改主键：镜像会话会定期继续。

当前不支持对源表执行任何其他 DDL 操作，并可能导致复制失败。

Fabric 容量或工作区的更改

用于故障排除的 SQL 查询

如果遇到镜像问题，请连接到源Azure Database for PostgreSQL服务器，并使用系统视图和函数执行这些检查以验证配置。

1. 执行以下查询，验证启动 CDC 镜像之前是否满足所有先决条件。 此函数检查各种系统和配置要求，以确保服务器已准备好执行 CDC 操作。

-- Check if all prerequisites are met
SELECT * FROM azure_cdc.check_prerequisites();

-- Example output when all checks pass (on mock mode with identity configured):
 status |                                                               data
--------+----------------------------------------------------------------------------------------------------------------------------------
 ERROR  | [{"status": "ERROR", "details": {"current_value": "12", "required_value": "13"}, "status_code": "MAX_WORKER_PROCESSES_TOO_LOW"}]

-- Example output on standby replica:
 status |                                               data
--------+---------------------------------------------------------------------------------------------------
 ERROR  | [{"status": "ERROR", "status_code": "SERVER_IN_RECOVERY"}]

-- Example output when identity not configured:
 status |                                data
--------+---------------------------------------------------------------------
 ERROR  | [{"status": "ERROR", "status_code": "IDENTITY_NOT_CONFIGURED"}]

返回：(status text, data jsonb)

• status：总体状态 - 如果所有检查都通过，则为 OK，如果有任何检查失败，则为 ERROR
• data：包含具有statusstatus_code和可选details的详细状态条目的 JSONB 数组。

状态代码：

2. 执行以下查询以验证源数据库中的表是否有资格进行复制。 排除系统架构（pg_catalog、 information_schema、 pg_toast）和扩展拥有的表。

SELECT * FROM azure_cdc.get_all_tables_mirror_status();
 table_schema | table_name | mirroring_status |                      mirroring_data
--------------+------------+------------------+------------------------------------------------------
 public       | customers  | OK               | [{"status": "OK", "status_code": "HAS_PRIMARY_KEY"}]
 public       | orders     | OK               | [{"status": "OK", "status_code": "HAS_UNIQUE_INDEX"}]
 public       | logs       | WARNING          | [{"status": "WARNING", "status_code": "NO_INDEX_FULL_IDENTITY"}]

返回： 集 (table_schema text, table_name text, mirroring_status text, mirroring_data jsonb)

• table_schema：表的架构名称
• table_name：表的名称
• mirroring_status：总体状态 - OK、 WARNING或 ERROR
• mirroring_data：JSONB 数组，包含详细状态条目，并包括status、status_code，以及可选的details。

状态代码：

3. 执行以下查询以返回复制操作期间检测到的错误和问题，包括系统范围内的错误、发布特定的错误和每个表的错误。

-- Get only system-wide errors
SELECT * FROM azure_cdc.get_health_status('', '');

-- Get system-wide errors and publication-specific errors
SELECT * FROM azure_cdc.get_health_status('my_database', 'my_publication');

参数：

• db_name （文本）：数据库名称
• pub_name （text）：出版物名称

行为：

• 使用两个参数的空字符串调用时（azure_cdc.get_health_status('', '')）：仅返回系统范围错误（错误类型“S”）。
• 使用有效的数据库和发布名称进行调用时：返回指定发布的系统级错误和发布/表格特定错误。

返回： 集合(error_time timestamptz, schema_name text, table_name text, error_type char(1), error_code text, params jsonb)

错误类型：

错误代码：

4. 执行以下查询，以检查发布是否已正确创建，以及复制更改是否正常流动:

   select * from azure_cdc.tracked_publications;
   

   检查发布是否处于活动状态，并且已生成快照。 还可以通过查询检查后续更改批处理是否已生成：

   select * from azure_cdc.tracked_batches;
   

5. azure_cdc.tracked_publications如果视图在处理增量更改时未显示任何进度，请执行以下 SQL 查询来检查是否报告了任何问题：

   SELECT * FROM pg_stat_activity WHERE state = 'idle in transaction';
   

6. 如果没有报告任何问题，请执行以下命令以查看镜像 PostgreSQL 数据库的当前配置。 确认它已正确启用。

   SELECT * FROM pg_replication_slots;
   

   要在此处查找的键列是 slot_name 和 active。 除 （true） 之外 t 的任何值都表示存在潜在问题。

7. 如果需要故障排除，请联系支持人员。

托管标识

需要启用 Azure Database for PostgreSQL 灵活服务器的系统分配托管身份（SAMI），并将其设为主身份。 有关详细信息，请参阅 PostgreSQL 弹性服务器的系统分配托管标识。

启用后，如果稍后禁用再重新启用 SAMI 设置状态，将导致将 Azure Database for PostgreSQL 灵活服务器镜像到 Fabric OneLake 的过程失败。

使用以下查询验证是否已启用 SAMI： show azure.service_principal_id;

SAMI 权限

请勿删除 Fabric 镜像数据库项上的 Azure Database for PostgreSQL 灵活服务器系统分配的托管标识（SAMI）参与者权限。

如果误删了 SAMI 权限，Azure Database for PostgreSQL 灵活服务器的镜像功能将无法按预期运行。 无法从源数据库镜像新数据。

如果删除 适用于 PostgreSQL 的 Azure 数据库灵活服务器 SAMI 权限，或者权限未正确设置，请使用以下步骤。

1. 通过选择 ... 镜像数据库项上的省略号选项，将灵活服务器 SAMI 添加为用户。
2. 选择“ 管理权限 ”选项。
3. 输入 Azure Database for PostgreSQL 灵活服务器的名称。 提供 读取 和 写入 权限。

相关内容

• Microsoft Fabric 数据仓库的限制
• 关于在 Microsoft Fabric 中镜像处理 Azure Database for PostgreSQL 灵活服务器的常见问题