故障转移账户对象¶

先决条件要求¶

1. 为一组账户中的主要故障转移组启用复制。

2. 在一个或多个账户中创建至少一个主要故障转移组的辅助故障转移组（即副本），并定期使用故障转移组中对象的最新更新刷新（即同步）该副本。

有关说明，请参阅 跨多个账户复制数据库和账户对象。

将目标账户提升为源账户¶

要将目标账户提升为源账户，必须登录到要提升为新源账户的目标账户，并执行 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.

ALTER FAILOVER GROUP myfg RESUME;

查看正在进行的刷新操作的当前阶段¶

在刷新操作的大部分阶段，都可以安全地取消刷新操作。不过，在 SECONDARY_DOWNLOADING_METADATA 或 SECONDARY_DOWNLOADING_DATA 阶段取消刷新操作可能会导致目标账户的状态不一致。 如果刷新操作已启动其中一个阶段，则无论源账户是否可用，都会继续完成该阶段。在进行故障切换之前，允许该阶段完成，可确保副本处于一致的状态。在副本处于一致状态后，可以恢复或重放引入和转换管道，将副本更新为当前状态。

要查看故障转移组正在进行的刷新操作的当前阶段，请使用 Information Schema REPLICATION_GROUP_REFRESH_PROGRESS、REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB 表函数。

例如，要查看故障转移组 myfg 正在进行的刷新操作的当前阶段，请执行以下语句：

SELECT phase_name, start_time, end_time
  FROM TABLE(
    INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_PROGRESS('myfg')
  );

有关刷新操作阶段的列表，请参阅该函数的 使用说明。

取消未自动安排的正在进行的刷新操作¶

要取消并非由复制计划自动触发的正在进行的刷新操作，必须使用 SYSTEM$CANCEL_QUERY 函数：

1. 使用以下选项之一查找用于运行刷新操作的查询 ID 或 JOB_UUID：

   1. 查找所有正在运行的刷新操作的查询 IDs：

      SELECT query_id, query_text
        FROM TABLE(INFORMATION_SCHEMA.QUERY_HISTORY())
        WHERE query_type = 'REFRESH REPLICATION GROUP'
        AND execution_status = 'RUNNING'
        ORDER BY start_time;
      

      Copy

      使用 QUERY_TEXT 列从列表中确定用于故障转移组刷新操作的 QUERY_ID。

   2. 查找特定故障转移组 myfg 正在进行的刷新操作的 JOB_UUID：

      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

2. 使用 SYSTEM$CANCEL_QUERY 函数以及 QUERY_ID 或 JOB_UUID 取消刷新操作：

   SELECT SYSTEM$CANCEL_QUERY('<QUERY_ID | JOB_UUID>');
   

   Copy

   返回以下输出结果：

   query [<QUERY_ID>] terminated.
   

3. 取消正在进行的刷新操作后，继续执行 后续步骤。

在新提升的源账户中重新打开 Snowpipe Streaming 的活动通道¶

主数据库中由 Snowpipe Streaming 填充的表会复制 到辅助数据库。故障转移后，为表重新打开活动的 Snowpipe Streaming 通道，并为通道重新插入任何缺失的数据行：

1. 通过调用 openChannel (https://javadoc.io/doc/net.snowflake/snowflake-ingest-sdk/latest/net/snowflake/ingest/streaming/SnowflakeStreamingIngestClient.html) API 可重新打开表的活动通道。

2. 提取偏移令牌：

   1. 调用 getLatestCommittedOffsetToken (https://javadoc.io/doc/net.snowflake/snowflake-ingest-sdk/latest/net/snowflake/ingest/streaming/SnowflakeStreamingIngestChannel.html#getLatestCommittedOffsetToken()) API 或

   2. 执行 SHOW CHANNELS 命令检索表中活动通道的列表。

3. 从提取的偏移令牌中为通道重新插入数据行。