Réplication de notebooks¶

Activer la réplication¶

Un utilisateur disposant du rôle ORGADMIN doit activer la réplication pour chaque compte source et cible dans l’organisation :

USE ROLE ORGADMIN;
SELECT SYSTEM$GLOBAL_ACCOUNT_SET_PARAMETER(
    '<organization_name>.<account_name>',
    'ENABLE_ACCOUNT_DATABASE_REPLICATION',
    'true');

Pour plus d’informations, voir. Conditions préalables : Activer la réplication pour les comptes de votre organisation.

Créer un groupe de réplication dans le compte principal¶

Pour répliquer un notebook, indiquez la base de données qui contient le notebook dans le groupe de réplication :

USE ROLE ACCOUNTADMIN;

CREATE REPLICATION GROUP myrg
    OBJECT_TYPES = DATABASES
    ALLOWED_DATABASES = db1
    ALLOWED_ACCOUNTS = myorg.myaccount2
    REPLICATION_SCHEDULE = '10 MINUTE';

Dans cet exemple :

• ALLOWED_DATABASES - le nom de la base de données qui contient le notebook.

• ALLOWED_ACCOUNTS - le compte secondaire vers lequel la réplication doit être effectuée.

• REPLICATION_SCHEDULE - à quelle fréquence la réplication a lieu (par exemple, “10 MINUTE” ou “1 HOUR”).

-- Create a new warehouse if required
CREATE WAREHOUSE IF NOT EXISTS mywarehouse
  WAREHOUSE_SIZE = 'X-SMALL'
  AUTO_SUSPEND = 60
  AUTO_RESUME = TRUE
  COMMENT = 'Warehouse for Snowflake Notebooks';

-- Set up warehouse replication
CREATE REPLICATION GROUP mywarehouserg
  OBJECT_TYPES = WAREHOUSES
  ALLOWED_ACCOUNTS = myorg.myaccount2
  REPLICATION_SCHEDULE = '10 MINUTE';

Comportement du compte secondaire¶

Dans un compte secondaire, vous pouvez créer de nouveaux notebooks uniquement dans des bases de données non répliquées. Ces notebooks ne sont pas inclus dans le groupe de réplication et sont entièrement en lecture-écriture.

Les notebooks répliqués sont en lecture seule. Toutefois, les utilisateurs peuvent modifier les ressources de calcul associées et les intégrations d’accès externes (EAIs). Ces ressources doivent être créées ou répliquées séparément. Si elles ne sont pas disponibles, le notebook ne sera pas lié à ces ressources.

Créez un groupe de réplication dans le compte cible en tant que réplica du groupe de réplication myrg dans le compte source :

CREATE REPLICATION GROUP myrg
    AS REPLICA OF myorg.myaccount1.myrg;

Vous pouvez également créer un groupe de réplication pour les entrepôts si nécessaire. Notez que tous les entrepôts du compte seront répliqués :

CREATE REPLICATION GROUP mywarehouserg
    AS REPLICA OF myorg.myaccount1.mywarehouserg;

Le groupe de réplication peut aussi être actualisé manuellement en exécutant la commande suivante :

ALTER REPLICATION GROUP myrg REFRESH;

Créer un groupe de basculement¶

Pour permettre la promotion du compte secondaire au statut de compte principal pendant une panne, utilisez un groupe de basculement :

USE ROLE ACCOUNTADMIN;
CREATE FAILOVER GROUP myfg
  OBJECT_TYPES = DATABASES
  ALLOWED_DATABASES = db1
  ALLOWED_ACCOUNTS = myorg.myaccount2
  REPLICATION_SCHEDULE = '10 MINUTE';

Dans cet exemple, ALLOWED_DATABASES est la base de données à créer dans le groupe de basculement. Le notebook répliqué dans le groupe de basculement est en lecture seule, mais toujours exécutable. Si vous faites passer le groupe de basculement en tant que groupe principal, le notebook devient accessible en lecture et en écriture.

Considérations¶

• Les notebooks planifiés dans un compte secondaire sont mis en pause jusqu’au basculement. Après le basculement, la planification reprend.

• Pour la réplication et le comportement des tâches, voir Considérations relatives à la réplication.

• Les résultats du notebook ne sont stockés que dans le compte dans lequel le notebook a été exécuté. Les résultats du notebook ne sont pas répliqués.

Limitations¶

• L’intégration Git n’est actuellement pas prise en charge après un basculement. Pour que les notebooks d’un compte secondaire promu puissent se reconnecter à Git, vous devez reconfigurer Git.

-- In the secondary account, create a new compute pool with a matching name and configuration

CREATE COMPUTE POOL compute_pool
  MIN_NODES = 1
  MAX_NODES = 10
  INSTANCE_FAMILY = CPU_X64_XS;