Categories:

Information Schema , Table functions

REPLICATION_GROUP_REFRESH_PROGRESS、REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB、REPLICATION_GROUP_REFRESH_PROGRESS_ALL¶

您可以使用 REPLICATION_GROUP_REFRESH_PROGRESS 系列表函数来查询复制或故障转移组的刷新操作状态：

• REPLICATION_GROUP_REFRESH_PROGRESS returns a JSON object indicating the refresh status for a secondary replication or failover group by name.
• REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB returns a JSON object indicating the refresh status for a secondary replication or failover group by query ID.
• REPLICATION_GROUP_REFRESH_PROGRESS_ALL returns a JSON object indicating the refresh status for all the secondary replication and failover groups.

语法

REPLICATION_GROUP_REFRESH_PROGRESS( '<secondary_group_name>' )

REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB( '<query_id>' )

REPLICATION_GROUP_REFRESH_PROGRESS_ALL(
      [ DATE_RANGE_START => <constant_expr> ]
      [ , DATE_RANGE_END => <constant_expr> ] )

实参

'secondary_group_name'

辅助复制或故障转移组的名称。请注意，整个名称必须放在单引号内。

'query_id'

ID of the replication group refresh query. The query ID can be obtained from the History page in the web interface.

以下实参对于 REPLICATION_GROUP_REFRESH_PROGRESS_ALL 是可选的。

DATE_RANGE_START => constant_expr ,
DATE_RANGE_END => constant_expr

返回复制刷新进度的日期/时间范围。

• 如果既未指定开始日期，也未指定结束日期，则默认值为过去 12 小时。
• If a start date is specified but no end date, CURRENT_DATE at midnight is used as the end of the range.
• If an end date is specified but no start date, the range starts 12 hours prior to the start of DATE_RANGE_END.

数据保留 14 天。如果请求的范围超出了 14 天的保留期，则该函数将返回错误。

输出

该函数返回以下各列。REPLICATION_GROUP_REFRESH_PROGRESS_ALL 还有其他列，分别为结果集的前两列。

使用说明

• When no DATE_RANGE_START or DATE_RANGE_END arguments are provided, REPLICATION_GROUP_REFRESH_PROGRESS_ALL returns data for the last 12 hours. To retrieve data beyond the last 12 hours, specify the date range explicitly. Data is available for up to 14 days.
• 仅返回对复制组或故障转移组具有任何权限的角色的行。
• 仅返回当前账户中辅助复制或故障转移组的行。
• When calling an Information Schema table function, the session must have an INFORMATION_SCHEMA schema in use or the function name must be fully-qualified. For more details, see Snowflake Information Schema.

• 以下是所处理订单中的阶段列表：

  #	Phase name	Description
  1	SECONDARY_SYNCHRONIZING_MEMBERSHIP	The secondary replication or failover group receives information from the primary group about the objects included in the group, and updates its membership metadata.
  2	SECONDARY_UPLOADING_INVENTORY	The secondary replication or failover group sends an inventory of its objects in the target account to the primary group.
  3	PRIMARY_UPLOADING_METADATA	The primary replication or failover group creates a snapshot of metadata in the source account and sends it to the secondary group.
  4	PRIMARY_UPLOADING_DATA	The primary replication or failover group copies the files the secondary group needs to reconcile any deltas between the objects in the source and target accounts.
  5	SECONDARY_DOWNLOADING_METADATA	The secondary replication or failover group applies the snapshot of the metadata that was sent by the primary. The metadata updates are not applied atomically and instead applied over time.
  6	SECONDARY_DOWNLOADING_DATA	The secondary replication or failover group copies the files sent by the primary group to the target account.
  7	COMPLETED / FAILED / CANCELED	Refresh operation status.

  Expand

  Show lessSee more

• In the PRIMARY_UPLOADING_DATA and SECONDARY_DOWNLOADING_DATA phases, the totalBytesToReplicate value is estimated prior to the replication operation. This value may differ from the totalBytesToUpload or totalBytesToDownload value in the respective phase.

  For example, if during the PRIMARY_UPLOADING_DATA phase, a previous replication operation uploaded some bytes but was canceled before the operation completed, those bytes would not be uploaded again. In that case, totalBytesToUpload would be lower than totalBytesToReplicate.

示例

To retrieve the current refresh progress for replication group rg1, execute the following statement:

SELECT phase_name, start_time, end_time, progress, details
  FROM TABLE(INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_PROGRESS('rg1'));

要通过查询 ID 检索复制组刷新进度，请替换示例中的查询 ID 并执行以下语句：

SELECT phase_name, start_time, end_time, progress, details
  FROM TABLE(
    INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB(
      '012a3b45-1234-a12b-0000-1aa200012345'));

要检索所有故障转移组和复制组过去 12 小时（默认）的刷新进度，请执行以下语句：

SELECT phase_name, start_time, end_time, progress, details
  FROM TABLE(INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_PROGRESS_ALL());

要检索所有组过去 7 天的刷新进度，请执行以下操作：

SELECT phase_name, start_time, end_time, progress, details
  FROM TABLE(
    INFORMATION_SCHEMA.REPLICATION_GROUP_REFRESH_PROGRESS_ALL(
        DATE_RANGE_START => DATEADD(D, -7, CURRENT_DATE),
        DATE_RANGE_END => CURRENT_DATE));