类别:

Information Schema表函数

REPLICATION_GROUP_REFRESH_PROGRESS、REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB

REPLICATION_GROUP_REFRESH_PROGRESS 函数系列可用于查询复制组或故障转移组刷新的状态:

  • REPLICATION_GROUP_REFRESH_PROGRESS 返回一个 JSON 对象,该对象按名称指示辅助复制或故障转移组的刷新状态。

  • REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB 返回一个 JSON 对象,该对象按查询 ID 指示辅助复制或故障转移组的刷新状态。

备注

  • REPLICATION_GROUP_REFRESH_PROGRESS 仅返回最近 14 天内发生的复制或故障转移组刷新活动。

  • REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB 返回过去 14 天内的复制或故障转移组刷新活动。

语法

REPLICATION_GROUP_REFRESH_PROGRESS( '<secondary_group_name>' )

REPLICATION_GROUP_REFRESH_PROGRESS_BY_JOB( '<query_id>' )
Copy

实参

secondary_group_name

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

query_id

复制组刷新查询的 ID。可以从 Web 界面中的 History History 选项卡 页面获取查询 ID。

输出

该函数返回以下列:

列名称

数据类型

描述

PHASE_NAME

TEXT

到目前为止已完成(或正在进行)的复制阶段的名称。有关阶段列表,请参阅使用说明。

START_TIME

TIMESTAMP_LTZ

复制阶段开始的时间。

END_TIME

TIMESTAMP_LTZ

该阶段结束的时间(如果适用)。如果该阶段正在进行或者是终止阶段(COMPLETED/FAILED/CANCELED),则为 NULL

PROGRESS

TEXT

  • PRIMARY_UPLOADING_DATA:复制的总字节数的百分比。

  • SECONDARY_DOWNLOADING_METADATA:复制的总对象数的百分比。

  • SECONDARY_DOWNLOADING_DATA:复制的总字节数的百分比。

剩余阶段为空

DETAILS

VARIANT

  • 对于阶段 PRIMARY_UPLOADING_METADATA

    • primarySnapshotTimestamp:主快照的创建时间。格式为纪元时间。

  • 对于阶段 PRIMARY_UPLOADING_DATA

    • totalBytesToReplicate:预计上传的总字节数。

    • totalBytesToUpload:需要上传的总字节数。

    • bytesUploaded:迄今为止上传的总字节数。

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

      • name:数据库名称。

      • totalBytesToReplicate:预计上传到数据库的总字节数。

  • 对于阶段 SECONDARY_DOWNLOADING_DATA

    • totalBytesToReplicate:预计下载的总字节数。

    • totalBytesToDownload:需要下载的实际字节数。

    • bytesDownloaded:迄今为止下载的实际字节数。

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

      • name:数据库名称。

      • totalBytesToReplicate:预计下载数据库的总字节数。

  • 对于阶段 SECONDARY_DOWNLOADING_METADATA

    • totalObjects:要下载的总对象数。

    • completedObjects:迄今为止下载的总对象数。

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

      • objectType:对象的类型(例如,用户、角色、授权、仓库、架构、表、列等)。

      • totalObjects:此类型对象的总数。

      • completedObjects:此类型已完成对象的数量。

  • 对于阶段 FAILED

    • errorCode:失败的错误代码。

    • errorMessage:失败的错误消息。

使用说明

  • 仅返回对复制组或故障转移组具有任何权限的角色的行。

  • 仅返回当前账户中辅助复制或故障转移组的行。

  • 当调用 Information Schema 表函数时,会话必须具有正在使用的 INFORMATION_SCHEMA 架构,或者 函数名称必须受到完全限定。有关更多详细信息,请参阅 Snowflake Information Schema

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

    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

  • PRIMARY_UPLOADING_DATASECONDARY_DOWNLOADING_DATA 阶段,totalBytesToReplicate 值是在复制操作之前估计的。该值可能不同于相应阶段的 totalBytesToUploadtotalBytesToDownload 值。

    例如,如果在 PRIMARY_UPLOADING_DATA 阶段,先前的复制操作上传了一些字节,但在操作完成前被取消,则这些字节将不会再次上传。在这种情况下,totalBytesToUpload 将低于 totalBytesToReplicate

示例

检索 rg1 复制组的复制组刷新的当前进度:

select *
from table(information_schema.replication_group_refresh_progress('rg1'));
Copy

按查询 ID 检索复制组刷新的当前进度:

select *
from table(information_schema.replication_group_refresh_progress_by_job('012a3b45-1234-a12b-0000-1aa200012345'));
Copy
语言: 中文