架构：

ACCOUNT_USAGE

REPLICATION_GROUP_REFRESH_HISTORY 视图

此 Account Usage 视图可用于查询指定 复制组或故障转移组 的刷新历史记录。

另请参阅：

REPLICATION_GROUP_REFRESH_HISTORY （Information Schema 表函数）

列

列名称

数据类型

描述

REPLICATION_GROUP_NAME

TEXT

辅助复制或故障转移组的名称。

REPLICATION_GROUP_ID

NUMBER

复制组或故障转移组的内部/系统生成的标识符。

PHASE_NAME

TEXT

复制操作的当前阶段。有关阶段列表，请参阅 使用说明。

START_TIME

TIMESTAMP_LTZ

复制操作开始的时间。

END_TIME

TIMESTAMP_LTZ

复制操作完成的时间（如果适用）。如果正在进行中，则为 NULL。

JOB_UUID

TEXT

用于刷新作业的查询 ID。

TOTAL_BYTES

VARIANT

一个 JSON 对象，提供有关刷新数据库的详细信息：

  • totalBytesToReplicate：预计要复制的字节总数。

  • bytesUploaded：实际上传的字节数。

  • bytesDownloaded：实际下载的字节数。

  • databases：每个成员数据库包含以下字段的 JSON 对象列表：

    • name：数据库的名称。

    • totalBytesToReplicate：数据库预计要复制的总字节数。

OBJECT_COUNT

VARIANT

一个 JSON 对象，提供有关刷新对象的详细信息：

  • totalObjects：复制或故障转移组中的对象总数。

  • completedObjects：完成的对象总数。

  • objectTypes：包含每种类型的以下字段的 JSON 对象列表：

    • objectType：对象的类型（例如用户、角色、授权、仓库、架构、表、列等）。

    • totalObjects：复制或故障转移组中此类型的对象总数。

    • completedObjects：已完成的此类型对象总数。

PRIMARY_SNAPSHOT_TIMESTAMP

TIMESTAMP_LTZ

创建主快照的时间戳。

ERROR

VARIANT

如果刷新操作成功，则为 NULL。如果刷新操作失败，则返回提供有关错误的详细信息的 JSON 对象：

  • errorCode：失败的错误代码。

  • errorMessage：失败的错误消息。

使用说明

  • 仅为当前账户（目标账户）中的辅助故障转移组或复制组返回结果。

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

    #

    阶段名称

    描述

    1

    SECONDARY_SYNCHRONIZING_MEMBERSHIP

    辅助复制或故障转移组从主组接收有关该组中包括的对象的信息，并更新其成员元数据。

    2

    SECONDARY_UPLOADING_INVENTORY

    辅助复制或故障转移组将目标账户中其对象的清单发送到主组。

    3

    PRIMARY_UPLOADING_METADATA

    主复制或故障转移组在源账户中创建元数据快照并将其发送到辅助组。

    4

    PRIMARY_UPLOADING_DATA

    主复制或故障转移组复制辅助组需要的文件，以协调源账户和目标账户中的对象之间的任何增量。

    5

    SECONDARY_DOWNLOADING_METADATA

    辅助复制或故障转移组应用主复制或故障转移组发送的元数据快照。元数据更新不是以原子方式应用，而是随着时间的推移逐步应用。

    6

    SECONDARY_DOWNLOADING_DATA

    辅助复制或故障转移组将主组发送的文件复制到目标账户。

    7

    COMPLETED / FAILED / CANCELED

    刷新运行状态。

示例

要检索辅助故障转移组 myfg 的刷新历史记录，请执行以下语句：

SELECT phase_name, start_time, end_time,
       total_bytes, object_count, error
  FROM SNOWFLAKE.ACCOUNT_USAGE.REPLICATION_GROUP_REFRESH_HISTORY
  WHERE replication_group_name = 'MYFG';
Copy

要检索每个复制或故障转移组的上次刷新记录，请执行以下语句：

SELECT replication_group_name, phase_name,
       start_time, end_time,
       total_bytes, object_count, error,
       ROW_NUMBER() OVER (
         PARTITION BY replication_group_name
         ORDER BY end_time DESC
       ) AS row_num
  FROM SNOWFLAKE.ACCOUNT_USAGE.REPLICATION_GROUP_REFRESH_HISTORY
  QUALIFY row_num = 1;
Copy
语言: 中文