- Schéma :
Vue REPLICATION_GROUP_REFRESH_HISTORY¶
Important
Cette vue n’est disponible que dans le compte de l’organisation. Pour plus d’informations, voir Vues premium dans le compte de l’organisation.
Cette vue Utilisation de l’organisation peut être utilisée pour interroger l’historique d’actualisation d’un groupe de basculement ou de réplication spécifié.
- Voir aussi :
REPLICATION_GROUP_REFRESH_HISTORY, REPLICATION_GROUP_REFRESH_HISTORY_ALL (fonction de table d’Information Schema)
Colonnes¶
Colonnes au niveau de l’organisation
Nom de la colonne |
Type de données |
Description |
---|---|---|
ORGANIZATION_NAME |
VARCHAR |
Nom de l’organisation. |
ACCOUNT_LOCATOR |
VARCHAR |
Identificateur du compte généré par le système. |
ACCOUNT_NAME |
VARCHAR |
Identificateur défini par l’utilisateur pour le compte. |
Colonnes supplémentaires
Nom de la colonne |
Type de données |
Description |
---|---|---|
REPLICATION_GROUP_NAME |
TEXT |
Nom du groupe de réplication ou de basculement secondaire. |
REPLICATION_GROUP_ID |
NUMBER |
Identificateur interne/généré par le système du groupe de réplication ou de basculement. |
PHASE_NAME |
TEXT |
Phase actuelle de l’opération de réplication. Pour la liste des phases, voir les notes sur l’utilisation. |
START_TIME |
TIMESTAMP_LTZ |
Heure à laquelle l’opération de réplication a commencé. |
END_TIME |
TIMESTAMP_LTZ |
Heure à laquelle l’opération de réplication s’est terminée, le cas échéant. |
JOB_UUID |
TEXT |
ID de requête pour la tâche d’actualisation. |
TOTAL_BYTES |
VARIANT |
Un objet JSON qui fournit des informations détaillées sur les bases de données actualisées :
|
OBJECT_COUNT |
VARIANT |
Un objet JSON qui fournit des informations détaillées sur les objets actualisés :
|
PRIMARY_SNAPSHOT_TIMESTAMP |
TIMESTAMP_LTZ |
Horodatage de la création de l’instantané principal. |
ERROR |
VARIANT |
NULL si l’opération d’actualisation est réussie. Si l’opération d’actualisation échoue, elle renvoie un objet JSON qui fournit des informations détaillées sur l’erreur :
|
Notes sur l’utilisation¶
La latence pour la vue peut atteindre 24 heures.
Pour voir la progression de l’actualisation en temps réel, utilisez la fonction de table REPLICATION_GROUP_REFRESH_HISTORY, REPLICATION_GROUP_REFRESH_HISTORY_ALL.
Les résultats sont uniquement renvoyés pour les groupes de basculement ou de réplication secondaires dans le compte actuel (le compte cible).
Voici la liste des phases de traitement dans l’ordre :
#
Nom de la phase
Description
1
SECONDARY_SYNCHRONIZING_MEMBERSHIP
Le groupe de réplication secondaire ou de basculement reçoit des informations du groupe principal sur les objets inclus dans le groupe et met à jour ses métadonnées d’appartenance.
2
SECONDARY_UPLOADING_INVENTORY
Le groupe de réplication secondaire ou de basculement envoie un inventaire de ses objets dans le compte cible au groupe principal.
3
PRIMARY_UPLOADING_METADATA
Le groupe de réplication ou de basculement principal crée un instantané des métadonnées dans le compte source et l’envoie au groupe secondaire.
4
PRIMARY_UPLOADING_DATA
Le groupe de réplication principal ou de basculement copie les fichiers dont le groupe secondaire a besoin pour réconcilier les deltas entre les objets des comptes source et cible.
5
SECONDARY_DOWNLOADING_METADATA
Le groupe de réplication ou de basculement secondaire applique l’instantané des métadonnées envoyées par le groupe principal. Les mises à jour des métadonnées ne sont pas appliquées de manière atomique mais au fil du temps.
6
SECONDARY_DOWNLOADING_DATA
Le groupe de réplication secondaire ou de basculement copie les fichiers envoyés par le groupe principal vers le compte cible.
7
COMPLETED
/FAILED
/CANCELED
Actualiser le statut de l’opération.
Exemples¶
Pour récupérer l’historique d’actualisation du groupe de basculement secondaire myfg
, exécutez l’instruction suivante :
SELECT account_name, phase_name, start_time, end_time,
total_bytes, object_count, error
FROM SNOWFLAKE.ORGANIZATION_USAGE.REPLICATION_GROUP_REFRESH_HISTORY
WHERE replication_group_name = 'MYFG';
Pour récupérer le dernier enregistrement d’actualisation pour chaque groupe de réplication ou de basculement, exécutez l’instruction suivante :
SELECT account_name, 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.ORGANIZATION_USAGE.REPLICATION_GROUP_REFRESH_HISTORY
QUALIFY row_num = 1;