- 스키마:
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 |
해당하는 경우, 복제 작업이 완료된 시간입니다. 진행 중인 경우 |
JOB_UUID |
TEXT |
새로 고침 작업의 쿼리 ID입니다. |
TOTAL_BYTES |
VARIANT |
새로 고친 데이터베이스에 대한 자세한 정보를 제공하는 JSON 오브젝트:
|
OBJECT_COUNT |
VARIANT |
새로 고친 오브젝트에 대한 자세한 정보를 제공하는 JSON 오브젝트:
|
PRIMARY_SNAPSHOT_TIMESTAMP |
TIMESTAMP_LTZ |
기본 스냅샷이 생성된 타임스탬프입니다. |
ERROR |
VARIANT |
새로 고침 작업이 성공한 경우 NULL입니다. 새로 고침 작업이 실패하는 경우, 오류에 대한 자세한 정보를 제공하는 JSON 오브젝트를 반환합니다.
|
사용법 노트¶
뷰의 지연 시간은 최대 180분(3시간)이 될 수 있습니다.
실시간 새로 고침 진행 상황을 확인하려면 REPLICATION_GROUP_REFRESH_HISTORY 테이블 함수를 사용합니다.
결과는 현재 계정(대상 계정)의 보조 장애 조치 또는 복제 그룹에 대해서만 반환됩니다.
다음은 처리된 순서의 단계 목록입니다.
#
단계 이름
설명
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';
각 복제 또는 장애 조치 그룹의 마지막 새로 고침 레코드를 검색하려면 다음 문을 실행합니다.
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;