Réplication des objets du compte¶

Exécuter à partir du compte source¶

1. Créez un rôle et accordez-lui le privilège CREATE FAILOVER GROUP. Cette étape est facultative :

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   USE ROLE ACCOUNTADMIN;
   
   CREATE ROLE myrole;
   
   GRANT CREATE FAILOVER GROUP ON ACCOUNT
    TO ROLE myrole;
   

   Copy

2. Créez un groupe de basculement dans le compte source et activez la réplication vers des comptes cibles spécifiques.

   Note

   • Si vous avez des bases de données à ajouter à un groupe de réplication ou de basculement qui ont été précédemment activées pour la réplication de base de données et le basculement à l’aide de ALTER DATABASE, suivez les instructions Transition de la réplication de base de données à la réplication par groupe (dans cette rubrique) avant de les ajouter à un groupe.

   • Pour ajouter une base de données à un groupe de basculement, le rôle actif doit avoir le privilège MONITOR sur la base de données. Pour plus de détails sur les privilèges de la base de données, voir Privilèges de base de données (dans une rubrique distincte).

   USE ROLE myrole;
   
   -- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
   CREATE FAILOVER GROUP myfg
       OBJECT_TYPES = USERS, ROLES, WAREHOUSES, RESOURCE MONITORS, DATABASES
       ALLOWED_DATABASES = db1, db2
       ALLOWED_ACCOUNTS = myorg.myaccount2, myorg.myaccount3
       REPLICATION_SCHEDULE = '10 MINUTE';
   

   Copy

   Attention

   Si des objets de compte (par exemple des utilisateurs ou des rôles) que vous ne souhaitez pas détruire pendant la réplication existent dans le compte cible, n’incluez pas le paramètre REPLICATION_SCHEDULE lorsque vous créez un groupe de réplication ou de basculement. Pour plus de détails, voir Étape 5. Appliquer des IDs globaux à des objets créés par des scripts dans des comptes cibles — Facultatif.

Exécuté sur le compte cible¶

3. Créez un rôle dans le compte cible et accordez-lui le privilège CREATE FAILOVER GROUP. Cette étape est facultative :

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   USE ROLE ACCOUNTADMIN;
   
   CREATE ROLE myrole;
   
   GRANT CREATE FAILOVER GROUP ON ACCOUNT
       TO ROLE myrole;
   

   Copy

4. Créez un groupe de basculement dans le compte cible comme un réplica du groupe de basculement dans le compte source.

   USE ROLE myrole;
   
   -- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
   CREATE FAILOVER GROUP myfg
       AS REPLICA OF myorg.myaccount1.myfg;
   

   Copy

5. Appliquez les IDs globaux à des objets. Il s’agit d’une étape facultative pour tout objet de compte non créé par réplication.

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   SELECT SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME('myfg');
   

   Copy

   Attention

   Cette étape doit être exécutée si des objets de compte (par exemple des utilisateurs ou des rôles) que vous ne voulez pas détruire pendant la réplication existent dans le compte cible. Si vous ignorez cette étape, vous risquez de perdre les feuilles de calcul des utilisateurs ou les privilèges accordés à des rôles sur des objets (par exemple, des partages). Pour plus de détails, voir Étape 5. Appliquer des IDs globaux à des objets créés par des scripts dans des comptes cibles — Facultatif.

Actualiser manuellement un groupe secondaire¶

Pour actualiser manuellement un groupe de basculement secondaire dans le compte cible, voir Actualiser manuellement un groupe de basculement secondaire dans un compte cible (dans cette rubrique).

Activer l’aperçu de la réplication des flux et des tâches — Facultatif¶

Pour activer l’aperçu de la réplication des flux et des tâches pour un compte, une base de données ou un groupe de réplication ou de basculement, définissez le paramètre ENABLE_STREAM_TASK_REPLICATION sur true pour le compte source ou l’objet primaire.

alter database mydb set ENABLE_STREAM_TASK_REPLICATION = true;

alter replication group myrg set ENABLE_STREAM_TASK_REPLICATION = true;

alter account myorg.myaccount set ENABLE_STREAM_TASK_REPLICATION = true;

Voir tous les comptes pour lesquels la réplication est activée¶

Pour récupérer la liste des comptes de votre organisation pour lesquels la réplication est activée, utilisez SHOW REPLICATION ACCOUNTS.

-- Execute the following SQL statements using the ACCOUNTADMIN role:
SHOW REPLICATION ACCOUNTS;

+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| snowflake_region       | created_on              | account_name | account_locator |  comment        | organization_name |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_WEST_2          | 2020-07-15 21:59:25.455 | myaccount1   | myacctlocator1  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_EAST_1          | 2020-07-23 14:12:23.573 | myaccount2   | myacctlocator2  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_EAST_2          | 2020-07-25 19:25:04.412 | myaccount3   | myacctlocator3  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+

Voir la liste complète des IDs de région.

Afficher l’appartenance à un groupe de basculement et de réplication¶

Les objets de compte, de base de données et de partage ont des contraintes sur l’appartenance à un groupe. Avant de créer de nouveaux groupes ou d’ajouter des objets aux groupes existants, vous pouvez consulter la liste des groupes de basculement existants et les objets de chaque groupe.

Voir tous les groupes de basculement liés au compte actuel et les types d’objets dans chaque groupe :

SHOW FAILOVER GROUPS;

Copy

Voir toutes les bases de données du groupe de basculement myfg :

SHOW DATABASES IN FAILOVER GROUP myfg;

Copy

Voir tous les partages du groupe de basculement myfg :

SHOW SHARES IN FAILOVER GROUP myfg;

Copy

Activer la réplication d’objets de compte et de base de données d’un compte source vers un compte cible¶

Créez un groupe de basculement d’objets de compte et de base de données spécifiés dans le compte source et activez la réplication et le basculement vers une liste de comptes cibles. Pour plus d’informations sur la syntaxe, voir CREATE FAILOVER GROUP.

Par exemple, activez la réplication d’utilisateurs, de rôles, d’entrepôts, de moniteurs de ressources et de bases de données db1 et db2 du compte source vers le compte myaccount2 dans la même organisation. Définissez la planification de réplication pour actualiser automatiquement myaccount2 toutes les 10 minutes.

Exécution sur le compte source :

use role myrole;

-- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
create failover group myfg
    object_types = users, roles, warehouses, resource monitors, databases, integrations, network policies
    allowed_databases = db1, db2
    allowed_integration_types = API INTEGRATIONS
    allowed_accounts = myorg.myaccount2
    replication_schedule = '10 MINUTE';

Créer des groupes de réplication ou de basculement sans planification de réplication¶

Lorsqu’un groupe de réplication ou de basculement secondaire est créé en tant que réplica d’un groupe de réplication ou de basculement principal avec une planification de la réplication, une actualisation initiale du groupe secondaire est automatiquement exécutée lors de la création du groupe de réplication ou de basculement secondaire. Pour éviter que cela ne se produise avant que vous puissiez exécuter les instructions suivantes, créez le groupe de réplication ou de basculement principal sans définir le paramètre REPLICATION_SCHEDULE.

Une fois le groupe secondaire créé dans le compte cible, utilisez la fonction SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME pour ajouter des identificateurs globaux aux objets de compte dans le compte cible. Pour les objets de compte qui n’existent que dans le compte cible, répliquez-les manuellement dans le compte source avant d’appeler cette fonction.

Après avoir appliqué des identificateurs globaux aux objets du compte cible, ou les avoir recréés manuellement dans le compte source, utilisez la commande ALTER REPLICATION GROUP ou ALTER FAILOVER GROUP pour définir la planification de la réplication pour le groupe de réplication ou de basculement principal.

Utiliser SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME() pour appliquer des IDs globaux¶

Appliquer des identificateurs globaux aux objets du compte cible des types inclus dans la liste object_types pour le groupe de basculement myfg :

-- Execute the following SQL statements using the ACCOUNTADMIN role:
SELECT SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME('myfg');

Exemple¶

Visualiser la progression de l’opération d’actualisation la plus récente pour le groupe de basculement myfg :

SELECT PHASE_NAME, START_TIME, END_TIME, PROGRESS, DETAILS
  FROM TABLE(information_schema.replication_group_refresh_progress('myfg'));

Exemples¶

Interrogez la fonction de table Information Schema REPLICATION_GROUP_REFRESH_HISTORY pour afficher l’historique de réplication de compte du groupe de basculement myfg au cours des 7 derniers jours :

SELECT PHASE_NAME, START_TIME, END_TIME, TOTAL_BYTES, OBJECT_COUNT
  FROM TABLE(information_schema.replication_group_refresh_history('myfg'))
  WHERE START_TIME >= current_date - interval '7 days';

Interrogez la vue REPLICATION_GROUP_REFRESH_HISTORY de Account Usage pour voir l’historique de réplication de compte pour le mois en cours :

SELECT REPLICATION_GROUP_NAME, PHASE_NAME, START_TIME, END_TIME, TOTAL_BYTES, OBJECT_COUNT
  FROM snowflake.account_usage.replication_group_refresh_history
  WHERE START_TIME >= date_trunc('month', current_date());

Exemples¶

Interroger la fonction de table REPLICATION_GROUP_USAGE_HISTORY pour voir les crédits utilisés pour la réplication de compte au cours des 7 derniers jours :

SELECT start_time, end_time, replication_group_name, credits_used, bytes_transferred
  FROM table(information_schema.replication_group_usage_history(date_range_start=>dateadd('day', -7, current_date())));

Interrogez la vue Account Usage REPLICATION_GROUP_USAGE_HISTORY pour voir les crédits utilisés par la réplication ou le groupe de basculement pour l’historique de réplication de compte dans le mois en cours :

SELECT start_time, 
  end_time, 
  replication_group_name, 
  credits_used, 
  bytes_transferred
FROM snowflake.account_usage.replication_group_usage_history
WHERE start_time >= DATE_TRUNC('month', CURRENT_DATE());

Exemples¶

Exécuté sur le compte cible¶

1. Interrogez la fonction de table REPLICATION_GROUP_REFRESH_PROGRESS (dans Schéma d’information de Snowflake). Notez le primarySnapshotTimestamp dans la colonne DETAILS pour la phase PRIMARY_UPLOADING_METADATA. Il s’agit de l’horodatage du dernier instantané de la base de données principale.

   SELECT PARSE_JSON(details)['primarySnapshotTimestamp']
     FROM TABLE(information_schema.replication_group_refresh_progress('myfg'))
     WHERE PHASE_NAME = 'PRIMARY_UPLOADING_METADATA';
   

   Copy

2. Interrogez la fonction HASH_AGG pour une table spécifiée d’une base de données secondaire. La requête suivante renvoie une valeur de hachage pour toutes les lignes de la table mytable :

   SELECT HASH_AGG( * ) FROM mytable;
   

   Copy

Exécuter à partir du compte source¶

3. Interrogez la fonction HASH_AGG pour la même table dans la base de données principale. À l’aide de Time Travel, spécifiez l’horodatage auquel le dernier instantané a été pris pour la base de données secondaire :

   SELECT HASH_AGG( * ) FROM mytable AT(TIMESTAMP => '<primarySnapshotTimestamp>'::TIMESTAMP);
   

   Copy

4. Comparez les résultats des deux requêtes. La sortie doit être identique.