故障转移账户对象¶

将辅助故障转移组提升为主要故障转移组¶

以下示例将当前 myorg 组织中的 myaccount2 提升为源账户。

1. 登录到目标账户 myaccount2。

2. 列出账户中的故障转移组：

   SHOW FAILOVER GROUPS;
   

   Copy

3. 对要提升为主故障转移组的每个辅助故障转移组，执行以下语句：

   ALTER FAILOVER GROUP myfg PRIMARY;
   

   Copy

   备注

   在源区域发生部分中断期间，复制服务可能仍可用，并且可能仍刷新目标区域中的辅助故障转移组。

   为确保数据完整性，如果正在进行刷新操作，Snowflake 会阻止故障转移。这意味着，如果复制操作正在刷新辅助故障转移组，则无法将其提升为主故障转移组。在这种情况下，ALTER FAILOVER GROUP ...PRIMARY 命令将返回错误。

解决因刷新操作正在进行而引起的故障转移语句失败的问题¶

如果正在对尝试提升的辅助故障转移组执行刷新操作，则故障转移语句将生成以下错误：

Replication group "<GROUP_NAME>" cannot currently be set as primary because it is being
refreshed. Either wait for the refresh to finish or cancel the refresh and try again.

要成功进行故障转移，必须完成以下步骤。

1. 选择并完成以下选项之一：

   1. 暂停以后的故障转移组刷新操作。如果刷新操作正在进行，则必须等待该操作完成，然后才能进行故障转移：

      ALTER FAILOVER GROUP myfg SUSPEND;
      

      Copy

   2. 暂停以后的刷新操作，并且 如果当前正在执行刷新操作，取消正在进行的操作：

      ALTER FAILOVER GROUP myfg SUSPEND IMMEDIATE;
      

      Copy

      备注

      在语句返回的时间与取消刷新操作完成的时间之间可能会有稍许延迟。

2. 验证故障转移组 myfg 未进行任何刷新操作。以下查询不应返回任何结果：

   SELECT phase_name, start_time, job_uuid
     FROM TABLE(INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_HISTORY('myfg'))
     WHERE phase_name <> 'COMPLETED' and phase_name <> 'CANCELED';
   

   Copy

   要查看故障转移组 myfg 的已取消刷新操作，可以执行以下语句：

   SELECT phase_name, start_time, job_uuid
     FROM TABLE(information_schema.replication_group_refresh_history('myfg'))
     WHERE phase_name = 'CANCELED';
   

   Copy

3. 现在，可以将辅助故障转移组 myfg 提升为主故障转移组：

   ALTER FAILOVER GROUP myfg PRIMARY;
   

   Copy

恢复目标账户中的计划复制¶

故障转移时，所有辅助故障转移组上的计划刷新都会暂停。ALTER FAILOVER GROUP ...RESUME 必须在具有辅助故障转移组的每个 目标账户 中执行，以恢复自动刷新。

ALTER FAILOVER GROUP myfg RESUME;

Snowpipe Streaming 和 Kafka Connector¶

如果使用 Kafka Connector 和 Snowpipe Streaming，请在故障转移后按照以下步骤操作：

1. 更新 Kafka Connector 配置，以指向新提升的源账户。

2. 执行 SHOW CHANNELS 命令，检索活动通道列表和偏移令牌。每个通道都属于 Kafka 主题中的一个分区。

3. 为每个分区（通道）手动重置 Kafka 主题中的偏移。

4. 重新启动 Kafka Connector。

有关更多信息，请参阅：

• 结合使用 Snowflake Connector for Kafka 和 Snowpipe Streaming。

• 复制和 Snowpipe 流。