故障转移账户对象¶

先决条件¶

1. 在同一组织内的一组账户中、在一个云服务提供商的多个区域或不同的云服务提供商之间启用复制。

2. 创建一个主故障转移组，该组可用于定义要复制的对象类型，并指定要复制的目标账户。您可选择将复制的对象划分到多个故障转移组中，例如，某些数据库的复制频率应高于其他数据库。

3. 在至少一个辅助账户中，为每个主故障转移组创建至少一个辅助故障转移组（副本）。

4. 刷新（同步）每个副本，使其与故障转移组中对象的最新更新保持一致。执行初始刷新，并设置计划，定期为每个辅助账户提供最新变更。

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

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

您可以使用 Snowsight 或 SQL 将目标账户提升为源账户（故障转移）。

有关可以在故障转移组中指定的对象类型的更多信息，请参阅 复制组和故障转移组。

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、REPLICATION_GROUP_REFRESH_PROGRESS_ALL 表函数。

例如，要查看故障转移组 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. 从提取的偏移令牌中为通道重新插入数据行。