Réplication de bases de données sur plusieurs comptes¶

Promouvoir une base de données locale¶

1. Connectez-vous à un compte Snowflake qui contient une base de données locale que vous souhaitez répliquer vers un ou plusieurs autres comptes.

2. Cliquez sur le menu déroulant dans le coin supérieur gauche (à côté de votre nom de connexion) » Switch Role » ACCOUNTADMIN.

3. Dans la partie gauche de la page Databases, cliquez sur une base de données locale dans l’explorateur d’objets de base de données. La page des détails de la base de données s’ouvre.

4. Cliquez sur le bouton des actions (…) dans le coin supérieur droit de la page » Enable Replication. La boîte de dialogue Enable replication s’ouvre.

   Cette boîte de dialogue vous permet d’effectuer les actions suivantes :

   • Permettre à la base de données locale de servir de base de données principale.

   • Créer une base de données secondaire dans un ou plusieurs comptes cibles.

   • Actualiser chaque base de données secondaire une fois, après sa création.

5. Pour chaque compte cible de cette base de données, cochez les options permettant de créer une base de données secondaire et d’actualiser la base de données.

6. Connectez-vous au compte cible en tant qu’utilisateur à qui on a précédemment accordé le rôle ACCOUNTADMIN dans ce compte.

   Snowflake effectue les actions demandées et affiche un message de réussite.

   Gérez la réplication pour cette base de données à partir de l’onglet Replication dans les détails de la base de données.

Créer des bases de données secondaires¶

1. Connectez-vous à un compte qui contient une base de données secondaire.

2. Cliquez sur le menu déroulant dans le coin supérieur gauche (à côté de votre nom de connexion) » Switch Role » ACCOUNTADMIN.

3. Dans la partie gauche de la page Databases cliquez sur une base de données secondaire dans l’explorateur d’objets de base de données. La page des détails de la base de données s’ouvre.

4. Cliquez sur l’onglet Replication.

   Les actions suivantes sont disponibles à partir du bouton actions (…) situé dans le coin supérieur droit de la page :

   • Promouvoir la base de données secondaire comme base de données principale. Cette fonctionnalité nécessite Business Critical (ou une version supérieure).

   • Actualiser la base de données secondaire.

   • Copier un modèle pour créer une tâche qui actualise la base de données secondaire selon une planification. Coller le modèle dans une feuille de calcul Snowsight et le modifiez pour spécifier le calendrier souhaité.

Étape 1 : Afficher tous les comptes de votre entreprise¶

Récupérez la liste des comptes de votre organisation pour lesquels la réplication a été activée. Toute base de données permanente ou transitoire existante dans ces comptes peut être modifiée pour servir de base de données primaire. Les réplicas d’une base de données principale (c.-à-d. les bases de données secondaires) ne peuvent être créés que dans ces comptes.

Pour afficher la liste des comptes de votre entreprise, interrogez SHOW REPLICATION ACCOUNTS.

SHOW REPLICATION ACCOUNTS;

+------------------+---------------------------------+---------------+------------------+---------+-------------------+
| snowflake_region | created_on                      | account_name  | account_locator  | comment | organization_name |
|------------------+---------------------------------+---------------+------------------+---------+-------------------|
| AWS_US_WEST_2    | 2018-11-19 16:11:12.720 -0700   | ACCOUNT1      | MYACCOUNT1       |         | MYORG             |
| AWS_US_EAST_1    | 2019-06-02 14:12:23.192 -0700   | ACCOUNT2      | MYACCOUNT2       |         | MYORG             |
+------------------+---------------------------------+---------------+------------------+---------+-------------------+

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

Étape 2 : Promotion d’une base de données locale pour qu’elle serve de base de données principale¶

Modifiez une base de données permanente ou transitoire existante pour qu’elle serve de base de données principale à l’aide d’une instruction ALTER DATABASE … ENABLE REPLICATION TO ACCOUNTS. Fournissez une liste de comptes de votre entreprise séparés par des virgules pouvant stocker un réplica de cette base de données (c’est-à-dire une base de données secondaire), permettant ainsi aux utilisateurs de ces comptes d’interroger des objets dans la base de données secondaire.

ALTER DATABASE mydb1 ENABLE REPLICATION TO ACCOUNTS myorg.account2, myorg.account3;

Étape 3 : Activation du basculement pour une base de données principale¶

Activez le basculement pour une base de données principale sur un ou plusieurs comptes de votre entreprise à l’aide d’une instruction ALTER DATABASE … ENABLE FAILOVER TO ACCOUNTS . Le réplica de cette base de données principale dans l’un de ces comptes (c’est-à-dire une base de données secondaire) peut être promu pour servir de base de données principale.

Notez que l’activation du basculement pour une base de données principale peut être effectuée avant ou après la création d’un réplica de la base de données principale dans un compte spécifié.

-- Executed from primary account
ALTER DATABASE mydb1 ENABLE FAILOVER TO ACCOUNTS myorg.account2, myorg.account3;

Étape 4 : Création d’une base de données secondaire¶

Créez un réplica d’une base de données principale existante dans le même compte que celui qui stocke la base de données principale, ou un compte différent (dans la même région ou dans une autre). Notez que vous ne pouvez créer une base de données secondaire que dans un compte spécifié dans l’instruction ALTER DATABASE … ENABLE REPLICATION TO ACCOUNTS de Étape 2 : Promotion d’une base de données locale pour qu’elle serve de base de données principale.

Exécutez une instruction CREATE DATABASE … AS REPLICA OF dans chaque compte cible pour créer un réplica de la base de données principale spécifiée.

Pour afficher la liste des bases de données principales et secondaires de votre entreprise, interrogez SHOW REPLICATION DATABASES. Après la création d’une base de données secondaire, un administrateur de compte peut transférer la propriété de la base de données à un autre rôle (à l’aide de GRANT OWNERSHIP.)

-- Log into the ACCOUNT2 account.

-- Query the set of primary and secondary databases in your organization.
-- In this example, the MYORG.ACCOUNT1 primary database is available to replicate.
SHOW REPLICATION DATABASES;

+------------------+-------------------------------+-----------------+----------+---------+------------+----------------------------+---------------------------------+------------------------------+-------------------+-----------------+
| snowflake_region | created_on                    | account_name    | name     | comment | is_primary | primary                    | replication_allowed_to_accounts | failover_allowed_to_accounts | organization_name | account_locator |
|------------------+-------------------------------+-----------------+----------+---------+------------+----------------------------+---------------------------------+------------------------------+-------------------+-----------------|
| AWS_US_WEST_2    | 2019-11-15 00:51:45.473 -0700 | ACCOUNT1        | MYDB1    | NULL    | true       | MYORG.ACCOUNT1.MYDB1       | MYORG.ACCOUNT2, MYORG,ACCOUNT1  | MYORG.ACCOUNT1               | MYORG             | MYACCOUNT1      |
+------------------+-------------------------------+-----------------+----------+---------+------------+----------------------------+---------------------------------+------------------------------+-------------------+-----------------+

-- Create a replica of the 'mydb1' primary database
-- If the primary database has the DATA_RETENTION_TIME_IN_DAYS parameter set to a value other than the default value,
-- set the same value for the parameter on the secondary database.
CREATE DATABASE mydb1
  AS REPLICA OF myorg.account1.mydb1
  DATA_RETENTION_TIME_IN_DAYS = 10;

-- Verify the secondary database
SHOW REPLICATION DATABASES;

+------------------+-------------------------------+---------------+----------+---------+------------+-------------------------+---------------------------------+------------------------------+-------------------+-----------------+
| snowflake_region | created_on                    | account_name  | name     | comment | is_primary | primary                 | replication_allowed_to_accounts | failover_allowed_to_accounts | organization_name | account_locator |
|------------------+-------------------------------+---------------+----------+---------+------------+------------------------------------------+----------------+------------------------------+-------------------------------------|
| AWS_US_WEST_2    | 2019-11-15 00:51:45.473 -0700 | ACCOUNT1      | MYDB1    | NULL    | true       | MYORG.ACCOUNT1.MYDB1    | MYORG.ACCOUNT2, MYORG.ACCOUNT1  | MYORG.ACCOUNT1               | MYORG             | MYACCOUNT1      |
| AWS_US_EAST_1    | 2019-08-15 15:51:49.094 -0700 | ACCOUNT2      | MYDB1    | NULL    | false      | MYORG.ACCOUNT1.MYDB1    |                                 |                              | MYORG             | MYACCOUNT2      |
+------------------+-------------------------------+---------------+----------+---------+------------+-------------------------+---------------------------------+------------------------------+-------------------+-----------------+

Étape 5 : Actualisation de chaque base de données secondaire¶

Les instructions de cette section expliquent comment actualiser une base de données secondaire à partir d’un instantané de sa base de données principale (à l’aide de ALTER DATABASE … REFRESH). Un instantané inclut les modifications apportées aux objets et aux données. Pour la réplication initiale d’une très grande base de données principale, nous recommandons d’augmenter le délai d’attente de l’instruction.

Notez que le propriétaire de la base de données secondaire (rôle doté du privilège OWNERSHIP sur la base de données) est propriétaire des nouveaux objets ajoutés à la suite d’une actualisation de la base de données.

Pour vérifier la région actuelle après vous être connecté à un compte, interrogez la fonction CURRENT_REGION .

ALTER DATABASE mydb1 REFRESH;

Vous pouvez également rafraîchir une base de données secondaire dans l’interface utilisateur Web.

Étape 6. Actualisation d’une base de données secondaire sur une planification¶

Nous vous recommandons de planifier les actualisations de votre base de données secondaire. Cette section fournit des instructions pour démarrer automatiquement une actualisation de la base de données selon un calendrier spécifié.

La fréquence à laquelle vous actualisez une base de données secondaire dépend de l’objectif du point de récupération (RPO) pour les données de la base de données secondaire. Par exemple, si les applications qui s’appuient sur les données peuvent tolérer jusqu’à 1 heure de perte de données, vous devez actualiser les données au moins toutes les heures. Si la tolérance de perte de données est de 5 minutes, actualisez la base de données secondaire au moins toutes les 5 minutes.

Suivez les étapes décrites dans cette section pour démarrer automatiquement une actualisation de la base de données selon une planification spécifiée.

Conditions préalables

Les objets Snowflake suivants sont requis dans le compte qui stocke la base de données secondaire :

• La base de données secondaire.

• Une base de données distincte pour stocker les nouveaux objets créés dans cette section. Comme les bases de données secondaires sont en lecture seule, cette base de données doit être distincte de la base de données secondaire. Cette base de données doit également inclure les objets suivants :

  • Schéma : Utilisez le schéma PUBLIC ou créez un nouveau schéma à l’aide de CREATE SCHEMA.

  • Entrepôt. Tout entrepôt peut être fourni ici pour répondre à l’exigence syntaxique, mais n’est pas utilisé pour l’actualisation de la base de données. Créez un nouvel entrepôt en utilisant CREATE WAREHOUSE.

  • Tâche qui actualise la base de données secondaire selon une planification.

Privilèges requis

Les étapes décrites dans cette section nécessitent un rôle avec les privilèges suivants dans le compte dans lequel la base de données secondaire est actualisée :

Type d’objet	Objet	Privilège	Remarques
Compte	Compte qui stocke la base de données secondaire	EXECUTE TASK	Requis pour exécuter la nouvelle tâche.
Base de données	Base de données secondaire	OWNERSHIP	Requis pour actualiser la base de données secondaire.
Base de données	Base de données qui stocke la nouvelle tâche	USAGE
Schéma	Schéma qui stocke la nouvelle tâche	USAGE, CREATE TASK
Tâche		OWNERSHIP	Le rôle qui crée la tâche possède l’objet par défaut. La propriété peut être transférée vers un rôle différent à l’aide de GRANT privileges … TO ROLE.
Entrepôt	Entrepôt utilisé pour configurer la tâche	USAGE	La spécification d’un entrepôt est nécessaire pour configurer la tâche, mais l’entrepôt n’est pas utilisé pour exécuter la tâche ou pour l’opération d’actualisation.

Étapes

Effectuez les étapes suivantes pour chaque base de données secondaire que vous souhaitez actualiser selon une planification :

1. Créez une tâche qui lance l’actualisation de la base de données selon une planification (à l’aide de CREATE TASK). Bien que la syntaxe CREATETASK pour spécifier un calendrier de réplication nécessite un entrepôt, l’entrepôt n’est pas utilisé pour la réplication.

   Par exemple, créez une tâche nommée refresh_mydb1_task qui actualise une base de données secondaire nommée mydb1 toutes les 10 minutes avec un délai d’expiration de 4 heures. La tâche est configurée en utilisant l’entrepôt existant mywh:

   CREATE TASK refresh_mydb1_task
     WAREHOUSE = mywh
     SCHEDULE = '10 minute'
     USER_TASK_TIMEOUT_MS = 14400000
   AS
     ALTER DATABASE mydb1 REFRESH;
   

   Copy

2. Une tâche est suspendue par défaut lors de sa création. Reprenez la tâche pour qu’elle puisse s’exécuter en fonction des paramètres spécifiés dans la définition de la tâche :

ALTER TASK refresh_mydb1_task RESUME;

Copy

Exemple¶

Exécutez les instructions SQL suivantes dans votre client Snowflake préféré pour activer la réplication et le basculement, effectuez une actualisation initiale de la base de données et mettez en place des actualisations programmées.

-- The commands below are executed from the source account

-- View replication enabled accounts
SHOW REPLICATION ACCOUNTS;

ALTER DATABASE mydb ENABLE REPLICATION TO ACCOUNTS myorg.account2, myorg.account3;
ALTER DATABASE mydb ENABLE FAILOVER TO ACCOUNTS myorg.account2, myorg.account3;

-- The commands below are executed from each target account

-- View replication enabled databases
-- Note the primary column of the source database for the CREATE DATABASE statement below
SHOW REPLICATION DATABASES;

-- If the primary database has the DATA_RETENTION_TIME_IN_DAYS parameter set to a value other than the default value,
-- set the same value for the parameter on the secondary database.
CREATE DATABASE mydb
  AS REPLICA OF myorg.account1.mydb
  DATA_RETENTION_TIME_IN_DAYS = 10;

-- Increase statement timeout for initial refresh
-- Optional but recommended for initial refresh of a large database
ALTER SESSION SET STATEMENT_TIMEOUT_IN_SECONDS = 604800;
-- If you have an active warehouse in current session, update warehouse statement timeout
SELECT CURRENT_WAREHOUSE();
ALTER WAREHOUSE my_wh SET STATEMENT_TIMEOUT_IN_SECONDS = 604800;
-- Reset warehouse statement timeout after initial refresh
ALTER WAREHOUSE my_wh UNSET STATEMENT_TIMEOUT_IN_SECONDS;

-- Refresh a secondary database
ALTER DATABASE mydb REFRESH;

-- Create task
-- Set up refresh schedule for each secondary database using a separate database
USE DATABASE my_db2;

-- Create a task and RESUME the task for each secondary database
-- Edit the task schedule and timeout for your specific use case
CREATE TASK my_refresh_task
  WAREHOUSE = my_wh
  SCHEDULE = '10 minute'
  USER_TASK_TIMEOUT_MS = 14400000
AS
  ALTER DATABASE mydb REFRESH;

-- Start task
ALTER TASK my_refresh_task RESUME;

Utilisation de l’ancien localisateur de comptes¶

Bien que l’ancien format snowflake_region.account_locator soit actuellement pris en charge pour l’identification d’un compte dans les commandes de réplication et de basculement, son utilisation est déconseillée, car il pourrait cesser de fonctionner à l’avenir.

Exécutée sur la base de données secondaire¶

1. Sur la base de données secondaire, interrogez la fonction de table DATABASE_REFRESH_PROGRESS (dans Schéma d’information de Snowflake). Notez le snapshot_transaction_timestamp dans la colonne DETAILS pour la phase PRIMARY_UPLOADING_DATA. Il s’agit de l’horodatage du dernier instantané de la base de données principale.

   select parse_json(details)['snapshot_transaction_timestamp']
   from table(information_schema.database_refresh_progress(mydb))
   where phase_name = 'PRIMARY_UPLOADING_DATA';
   

   Copy

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

   SELECT HASH_AGG( * ) FROM mytable;
   

   Copy

Exécutée sur la base de données principale¶

3. Sur la base de données principale, interrogez la fonction HASH_AGG pour la même table. À 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 => '<snapshot_transaction_timestamp>'::TIMESTAMP);
   

   Copy

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