Créer et gérer des flux de modifications

Cette page explique comment créer, modifier et afficher les flux de modifications Spanner. Pour en savoir plus sur les flux de modifications, consultez À propos des flux de modifications.

Les flux de modifications étant des objets de schéma, vous pouvez les créer et les gérer via les mêmes mises à jour de schéma basées sur le LDD que celles utilisées pour tout autre type de définition de base de données, tel que la création de tables ou l'ajout d'index.

Spanner lance une opération de longue durée après que vous avez envoyé une instruction LDD modifiant le schéma, y compris celles utilisées pour créer, modifier ou supprimer des flux de modifications. Un flux de modifications nouveau ou modifié commencera à surveiller les colonnes ou les tables spécifiées par sa nouvelle configuration une fois cette opération de longue durée terminée.

Créer un flux de modifications

Pour créer un flux de modifications, vous devez fournir son nom et les objets de schéma qu'il surveillera: soit la base de données complète, soit une liste de tables et de colonnes spécifiques. Vous pouvez également spécifier les éléments suivants:

GoogleSQL

La syntaxe LDD permettant de créer un flux de modifications à l'aide de GoogleSQL se présente comme suit:

CREATE CHANGE STREAM change_stream_name
  [FOR column_or_table_watching_definition[, ... ] ]
  [
    OPTIONS (
      retention_period = timespan,
      value_capture_type = type,
      exclude_ttl_deletes = boolean,
      exclude_insert = boolean,
      exclude_update = boolean,
      exclude_delete = boolean
    )
  ]

PostgreSQL

La syntaxe LDD permettant de créer un flux de modifications à l'aide de PostgreSQL se présente comme suit:

CREATE CHANGE STREAM change_stream_name
  [FOR column_or_table_watching_definition[, ... ] ]
  [
    WITH (
      retention_period = timespan,
      value_capture_type = type,
      exclude_ttl_deletes = boolean,
      exclude_insert = boolean,
      exclude_update = boolean,
      exclude_delete = boolean
    )
  ]

Un nouveau flux de modifications commence à surveiller les objets de schéma qui lui sont attribués dès que l'opération de longue durée qui l'a créé est terminée.

Les exemples suivants illustrent la création de flux de modifications avec différentes configurations.

Surveiller l'intégralité d'une base de données

Pour créer un flux de modifications qui surveille chaque modification de données effectuée dans les tables d'une base de données, utilisez le mot clé ALL:

CREATE CHANGE STREAM EverythingStream
FOR ALL;

La configuration ALL inclut implicitement toutes les futures tables et colonnes de données de la base de données, dès leur création. Il n'inclut pas les vues, les tables de schéma d'informations ni d'autres objets en dehors des tables de données normales.

Surveiller des tables spécifiques

Pour limiter le champ d'application d'un flux de modifications à des tables spécifiques plutôt qu'à une base de données entière, spécifiez une liste d'une ou plusieurs tables:

CREATE CHANGE STREAM SingerAlbumStream
FOR Singers, Albums;

Spanner met à jour automatiquement les flux de modifications qui surveillent les tables entières pour refléter les modifications de schéma affectant ces tables, telles que les colonnes ajoutées ou supprimées.

Surveiller des colonnes spécifiques

Utilisez la syntaxe table(column_1[, column_2, ...]) pour surveiller les modifications apportées à une ou plusieurs colonnes non clés spécifiques dans les tables que vous nommez:

CREATE CHANGE STREAM NamesAndTitles
FOR Singers(FirstName, LastName), Albums(Title);

Vous ne pouvez pas spécifier de colonnes de clé primaire ici, car chaque flux de modifications suit toujours les clés primaires de chaque table surveillée. Cela permet à chaque enregistrement de modification de données d'identifier la ligne modifiée à l'aide de sa clé primaire.

Surveiller des tables et des colonnes dans un seul flux

Vous pouvez combiner la syntaxe de surveillance des tables et de surveillance des colonnes des deux exemples précédents dans un seul flux de modifications:

CREATE CHANGE STREAM NamesAndAlbums
FOR Singers(FirstName, LastName), Albums;

Définir une durée de conservation plus longue

Pour spécifier une durée de conservation des données de flux de modifications supérieure à la valeur par défaut d'un jour, définissez retention_period sur une période maximale d'une semaine, exprimée en heures (h) ou en jours (d).

Deux exemples:

GoogleSQL 

CREATE CHANGE STREAM LongerDataRetention
FOR ALL
OPTIONS ( retention_period = '36h' );

CREATE CHANGE STREAM MaximumDataRetention
FOR ALL
OPTIONS ( retention_period = '7d' );

PostgreSQL 

CREATE CHANGE STREAM LongerDataRetention
FOR ALL
WITH ( retention_period = '36h' );

CREATE CHANGE STREAM MaximumDataRetention
FOR ALL
WITH ( retention_period = '7d' );

Spécifier un type de capture de valeur différent

Pour spécifier un type de capture de la valeur du flux de modifications autre que OLD_AND_NEW_VALUES, définissez value_capture_type sur NEW_VALUES ou NEW_ROW, comme illustré dans les exemples suivants:

GoogleSQL 

CREATE CHANGE STREAM NewRowChangeStream
FOR ALL
OPTIONS ( value_capture_type = 'NEW_ROW' );

CREATE CHANGE STREAM NewValuesChangeStream
FOR ALL
OPTIONS ( value_capture_type = 'NEW_VALUES' );

PostgreSQL 

CREATE CHANGE STREAM NewRowChangeStream
FOR ALL
WITH ( value_capture_type = 'NEW_ROW' );

CREATE CHANGE STREAM NewValuesChangeStream
FOR ALL
WITH ( value_capture_type = 'NEW_VALUES' );

Filtrer les suppressions basées sur la valeur TTL

Vous pouvez filtrer les suppressions basées sur la valeur TTL dans le champ d'application de votre flux de modifications à l'aide du filtre exclude_ttl_deletes.

Pour en savoir plus sur le fonctionnement de ce filtre, consultez la section Filtre des suppressions en fonction de la valeur TTL.

GoogleSQL

Pour créer un flux de modifications avec le filtre de suppressions basé sur la valeur TTL, utilisez le code suivant:

CREATE CHANGE STREAM CHANGE_STREAM_NAME FOR ALL
OPTIONS (exclude_ttl_deletes = true)

Remplacez les éléments suivants :

  • CHANGE_STREAM_NAME: nom de votre nouveau flux de modifications.

L'exemple suivant crée un flux de modifications appelé NewFilterChangeStream qui exclut toutes les suppressions basées sur la valeur TTL:

CREATE CHANGE STREAM NewFilterChangeStream FOR ALL
OPTIONS (exclude_ttl_deletes = true)

PostgreSQL

Pour créer un flux de modifications avec le filtre de suppressions basé sur la valeur TTL, utilisez le code suivant:

CREATE CHANGE STREAM CHANGE_STREAM_NAME FOR ALL
WITH (exclude_ttl_deletes = true)

Remplacez les éléments suivants :

  • STREAM_NAME: nom de votre nouveau flux de modifications.

L'exemple suivant crée un flux de modifications appelé NewFilterChangeStream qui exclut toutes les suppressions basées sur la valeur TTL:

CREATE CHANGE STREAM NewFilterChangeStream FOR ALL
WITH (exclude_ttl_deletes = true)

Pour ajouter ou supprimer le filtre de suppressions basées sur la valeur TTL dans un flux de modifications existant, consultez Modifier le filtre des suppressions basées sur la valeur TTL. Vous pouvez confirmer vos filtres de flux de modifications en affichant les définitions du flux de modifications au format LDD.

Filtrer par type de modification de tableau

Filtrez une ou plusieurs de ces modifications de table du champ d'application de votre flux de modifications à l'aide des options de filtrage disponibles suivantes:

  • exclude_insert: exclure toutes les modifications de la table INSERT
  • exclude_update: exclure toutes les modifications de la table UPDATE
  • exclude_delete: exclure toutes les modifications de la table DELETE

Pour en savoir plus sur le fonctionnement de ces filtres, consultez la section Filtres de type de modification de table.

GoogleSQL

Pour créer un flux de modifications avec un ou plusieurs filtres de type de modification de table, utilisez le code suivant:

CREATE CHANGE STREAM CHANGE_STREAM_NAME FOR ALL
OPTIONS (MOD_TYPE_FILTER_NAME = true)

Remplacez les éléments suivants :

  • CHANGE_STREAM_NAME: nom de votre nouveau flux de modifications.
  • MOD_TYPE_FILTER_NAME : filtre que vous souhaitez ajouter (exclude_insert, exclude_update ou exclude_delete). Si vous ajoutez plusieurs filtres à la fois, séparez-les par une virgule.

L'exemple suivant crée un flux de modifications appelé NewFilterChangeStream qui exclut les types de modification de table INSERT et UPDATE:

CREATE CHANGE STREAM NewFilterChangeStream FOR ALL
OPTIONS (exclude_insert = true, exclude_update = true)

PostgreSQL

Pour créer un flux de modifications avec un ou plusieurs filtres de type de modification de table, utilisez le code suivant:

CREATE CHANGE STREAM CHANGE_STREAM_NAME FOR ALL
WITH (MOD_TYPE_FILTER_NAME = true)

Remplacez les éléments suivants :

  • CHANGE_STREAM_NAME: nom de votre flux de modifications existant
  • MOD_TYPE_FILTER_NAME : filtre que vous souhaitez ajouter (exclude_insert, exclude_update ou exclude_delete). Si vous ajoutez plusieurs filtres à la fois, séparez-les par une virgule.

L'exemple suivant crée un flux de modifications appelé NewFilterChangeStream qui exclut les types de transactions de modification de table INSERT et UPDATE:

CREATE CHANGE STREAM NewFilterChangeStream FOR ALL
WITH (exclude_insert = true, exclude_update = true)

Pour ajouter ou supprimer un filtre de type de modification de table dans un flux de modifications existant, consultez Modifier le filtre par type de modification de table. Vous pouvez confirmer les filtres de type de modification de table qui existent pour votre flux de modifications en affichant les définitions du flux de modifications en tant que LDD.

Modifier un flux de modifications

Pour modifier la configuration d'un flux de modifications, utilisez une instruction LDD ALTER CHANGE STREAM. Sa syntaxe est semblable à celle de CREATE CHANGE STREAM. Vous pouvez modifier les colonnes surveillées par un flux ou la durée de conservation des données. Vous pouvez également suspendre la surveillance tout en conservant ses enregistrements de modification de données.

Modifier le contenu d'un flux de modifications

Cet exemple ajoute l'intégralité de la table Songs au flux de modifications NamesAndAlbums configuré précédemment:

ALTER CHANGE STREAM NamesAndAlbums
SET FOR Singers(FirstName, LastName), Albums, Songs;

Spanner remplace le comportement du flux de modifications nommé par la nouvelle configuration à la fin de l'opération de longue durée qui met à jour la définition du flux de modifications dans le schéma de la base de données.

Modifier la durée de conservation des données d'un flux de modifications

Pour modifier la durée de conservation des enregistrements internes d'un flux de modifications, définissez retention_period dans une instruction LDD ALTER CHANGE STREAM.

Cet exemple ajuste la durée de conservation des données au flux de modifications NamesAndAlbums créé précédemment:

GoogleSQL 

ALTER CHANGE STREAM NamesAndAlbums
SET OPTIONS ( retention_period = '36h' );

PostgreSQL 

ALTER CHANGE STREAM NamesAndAlbums
SET ( retention_period = '36h' );

Modifier le type de capture de valeur d'un flux de modifications

Pour modifier le type de capture de valeur d'un flux de modifications, définissez la clause value_capture_type dans une instruction LDD ALTER CHANGE STREAM.

Cet exemple ajuste le type de capture de valeur sur NEW_VALUES.

GoogleSQL 

ALTER CHANGE STREAM NamesAndAlbums
SET OPTIONS ( value_capture_type = 'NEW_VALUES' );

PostgreSQL 

ALTER CHANGE STREAM NamesAndAlbums
SET ( value_capture_type = 'NEW_VALUES' );

Modifier le filtre de suppressions basé sur la valeur TTL

Pour modifier le filtre Suppressions basées sur TTL pour un flux de modifications, définissez le filtre exclude_ttl_deletes dans une instruction LDD ALTER CHANGE STREAM. Vous pouvez l'utiliser pour ajouter le filtre à vos flux de modifications existants ou le supprimer.

Pour en savoir plus sur le fonctionnement de ces filtres, consultez la section Filtre des suppressions basées sur la valeur TTL.

Ajouter le filtre de suppressions basées sur la valeur TTL à un flux de modifications existant

GoogleSQL

Pour ajouter le filtre de suppressions basées sur la valeur TTL à un flux de modifications existant, définissez le filtre sur true à l'aide de la commande suivante:

ALTER CHANGE STREAM CHANGE_STREAM_NAME FOR ALL
SET OPTIONS (exclude_ttl_deletes = true)

Remplacez les éléments suivants :

  • CHANGE_STREAM_NAME: nom de votre flux de modifications existant

Dans l'exemple suivant, le filtre exclude_ttl_deletes est ajouté à un flux de modifications existant appelé NewFilterChangeStream, qui exclut toutes les suppressions basées sur la valeur TTL :

ALTER CHANGE STREAM NewFilterChangeStream FOR ALL
SET OPTIONS (exclude_ttl_deletes = true)

Cela exclut toutes les suppressions basées sur la valeur TTL du flux de modifications.

PostgreSQL

Pour ajouter le filtre de suppressions basées sur la valeur TTL à un flux de modifications existant, définissez le filtre sur True à l'aide de la commande suivante:

ALTER CHANGE STREAM STREAM_NAME FOR ALL
SET (exclude_ttl_deletes = true)

Remplacez les éléments suivants :

  • STREAM_NAME: nom de votre flux de modifications existant

Dans l'exemple suivant, le filtre exclude_ttl_deletes est ajouté à un flux de modifications existant appelé NewFilterChangeStream:

ALTER CHANGE STREAM NewFilterChangeStream FOR ALL
SET (exclude_ttl_deletes = true)

Cela exclut toutes les futures suppressions basées sur la valeur TTL du flux de modifications.

Supprimer le filtre de suppressions basées sur la valeur TTL d'un flux de modifications existant

GoogleSQL

Pour supprimer le filtre de suppressions basées sur la valeur TTL dans un flux de modifications existant, définissez le filtre sur False à l'aide de la commande suivante:

ALTER CHANGE STREAM STREAM_NAME FOR ALL
SET OPTIONS (exclude_ttl_deletes = false)

Remplacez les éléments suivants :

  • STREAM_NAME: nom de votre nouveau flux de modifications.

Dans l'exemple suivant, le filtre exclude_ttl_deletes est supprimé d'un flux de modifications existant appelé NewFilterChangeStream:

ALTER CHANGE STREAM NewFilterChangeStream FOR ALL
SET OPTIONS (exclude_ttl_deletes = false)

Cela inclut toutes les futures suppressions du flux de modifications basées sur la valeur TTL.

Vous pouvez également définir le filtre sur null pour supprimer le filtre des suppressions basé sur la valeur TTL.

PostgreSQL

Pour supprimer le filtre de suppressions basées sur la valeur TTL dans un flux de modifications existant, définissez le filtre sur False à l'aide de la commande suivante:

ALTER CHANGE STREAM STREAM_NAME FOR ALL
SET (exclude_ttl_deletes = false)

Remplacez les éléments suivants :

  • STREAM_NAME: nom de votre nouveau flux de modifications.

Dans l'exemple suivant, le filtre exclude_ttl_deletes est supprimé d'un flux de modifications existant appelé NewFilterChangeStream:

ALTER CHANGE STREAM NewFilterChangeStream FOR ALL
SET (exclude_ttl_deletes = false)

Cela inclut toutes les futures suppressions du flux de modifications basées sur la valeur TTL.

Vous pouvez également définir le filtre sur null pour supprimer le filtre des suppressions basé sur la valeur TTL.

Modifier le filtre par type de modification du tableau

Pour modifier les filtres de type de modification de table pour un flux de modifications, définissez le type de filtre dans une instruction LDD ALTER CHANGE STREAM. Vous pouvez l'utiliser pour ajouter un filtre à votre flux de modifications ou en supprimer un existant.

Ajouter un filtre de type de modification de tableau à un flux de modifications existant

GoogleSQL

Pour ajouter un ou plusieurs nouveaux filtres de type de modification de table à un flux de modifications existant, définissez le filtre sur true à l'aide de la commande suivante:

ALTER CHANGE STREAM CHANGE_STREAM_NAME
SET OPTIONS (MOD_TYPE_FILTER_NAME = true)

Remplacez les éléments suivants :

  • CHANGE_STREAM_NAME: remplacer par le nom de votre flux de modifications existant
  • MOD_TYPE_FILTER_NAME : remplacez le par le filtre que vous souhaitez ajouter (exclude_insert, exclude_update ou exclude_delete). Si vous ajoutez plusieurs filtres à la fois, séparez-les par une virgule.

Dans l'exemple suivant, le filtre exclude_delete est ajouté à un flux de modifications existant appelé NewFilterChangeStream:

ALTER CHANGE STREAM NewFilterChangeStream
SET OPTIONS (exclude_delete = true)

PostgreSQL

Pour ajouter un ou plusieurs nouveaux filtres de type de modification de table à un flux de modifications existant, définissez le filtre sur true à l'aide de la commande suivante:

ALTER CHANGE STREAM CHANGE_STREAM_NAME
SET (MOD_TYPE_FILTER_NAME = true)

Remplacez les éléments suivants :

  • CHANGE_STREAM_NAME: remplacer par le nom de votre flux de modifications existant
  • MOD_TYPE_FILTER_NAME : remplacez le par le filtre que vous souhaitez ajouter (exclude_insert, exclude_update ou exclude_delete). Si vous ajoutez plusieurs filtres à la fois, séparez-les par une virgule.

Dans l'exemple suivant, le filtre exclude_delete est ajouté à un flux de modifications existant appelé NewFilterChangeStream:

ALTER CHANGE STREAM NewFilterChangeStream
SET (exclude_delete = true)

Supprimer un filtre de type de modification de table d'un flux de modifications existant

GoogleSQL

Pour supprimer un ou plusieurs filtres de type de modification de table existants dans un flux de modifications, définissez le filtre sur false à l'aide de la commande suivante:

ALTER CHANGE STREAM CHANGE_STREAM_NAME
SET OPTIONS (MOD_TYPE_FILTER_NAME = false)

Remplacez les éléments suivants :

  • CHANGE_STREAM_NAME: remplacer par le nom de votre flux de modifications existant
  • MOD_TYPE_FILTER_NAME: remplacez-le par le filtre que vous souhaitez supprimer: exclude_insert, exclude_update ou exclude_delete. Si vous supprimez plusieurs filtres à la fois, séparez-les par une virgule.

Dans l'exemple suivant, le filtre exclude_delete est supprimé d'un flux de modifications existant appelé NewFilterChangeStream:

ALTER CHANGE STREAM NewFilterChangeStream
SET OPTIONS (exclude_delete = false)

Vous pouvez également supprimer un filtre de modification de table en rétablissant la valeur par défaut. Pour ce faire, définissez la valeur du filtre sur null.

PostgreSQL

Pour supprimer un ou plusieurs filtres de type de modification de table existants dans un flux de modifications, définissez le filtre sur False à l'aide de la commande suivante:

ALTER CHANGE STREAM CHANGE_STREAM_NAME
SET (MOD_TYPE_FILTER_NAME = false)

Remplacez les éléments suivants :

  • CHANGE_STREAM_NAME: remplacer par le nom de votre flux de modifications existant
  • MOD_TYPE_FILTER_NAME : remplacez le par le filtre que vous souhaitez ajouter (exclude_insert, exclude_update ou exclude_delete). Si vous ajoutez plusieurs filtres à la fois, séparez-les par une virgule.

Dans l'exemple suivant, le filtre exclude_delete est supprimé d'un flux de modifications existant appelé NewFilterChangeStream:

ALTER CHANGE STREAM NewFilterChangeStream
SET (exclude_delete = false)

Vous pouvez également supprimer un filtre de modification de table en rétablissant la valeur par défaut. Pour ce faire, définissez la valeur du filtre sur null.

Suspendre un flux de modifications

Si vous souhaitez qu'un flux de modifications arrête son activité, mais conserve ses enregistrements internes (au moins pendant toute la durée de conservation des données), vous pouvez le modifier afin qu'il ne surveille rien.

Pour ce faire, émettez une instruction LDD ALTER CHANGE STREAM qui remplace la définition du flux de modifications par la phrase spéciale DROP FOR ALL. Exemple :

ALTER CHANGE STREAM MyStream DROP FOR ALL;

Le flux continue d'exister dans la base de données, mais ne surveille aucun objet et ne génère aucun autre enregistrement de modification des données. Ses enregistrements de modifications existants restent intacts et sont soumis aux règles de conservation des données du flux.

Pour reprendre un flux suspendu, émettez une autre instruction ALTER CHANGE STREAM avec sa configuration précédente.

Supprimer un flux de modifications

Pour supprimer définitivement un flux de modifications, émettez une instruction DROP CHANGE STREAM incluant le nom du flux:

DROP CHANGE STREAM NamesAndAlbums;

Spanner arrête immédiatement le flux, le supprime du schéma de la base de données et supprime ses enregistrements de modification de données.

Lister et afficher des flux de modifications

La console Google Cloud fournit une interface Web permettant de répertorier et d'examiner les définitions des flux de modifications d'une base de données. Vous pouvez également afficher la structure des flux de modifications sous la forme d'instructions LDD équivalentes ou en interrogeant le schéma d'informations de la base de données.

Afficher les flux de modifications avec la console Google Cloud

Pour afficher la liste des flux de modifications d'une base de données et examiner leurs définitions:

  1. Accédez à la page "Instances Spanner" de la console Google Cloud.

    Ouvrir la page des instances

  2. Accédez à l'instance et à la base de données appropriées.

  3. Cliquez sur Flux de modifications dans le menu de navigation.

La liste de tous les flux de modifications de cette base de données s'affiche, ainsi qu'un résumé de la configuration de chacun d'eux. Cliquez sur le nom d'un flux pour afficher plus de détails sur les tables et les colonnes qu'il surveille.

Afficher les définitions des flux de modifications sous forme de LDD

L'affichage du schéma d'une base de données en tant que LDD inclut la description de tous ses flux de modifications, où ils apparaissent sous forme d'instructions CREATE CHANGE STREAM.

  • Pour ce faire, depuis la console, cliquez sur le lien Afficher les instructions LDD équivalentes sur la page de la base de données dans la console Google Cloud.

  • Pour effectuer cette opération à partir de la ligne de commande, utilisez la commande ddl describe de Google Cloud CLI.

Interroger le schéma d'informations sur les flux de modifications

Vous pouvez interroger directement le schéma d'informations d'une base de données à propos de ses flux de modifications. Les tableaux suivants contiennent les métadonnées qui définissent les noms des flux de modifications, les tables et les colonnes qu'ils surveillent, ainsi que leur durée de conservation:

Bonnes pratiques concernant les flux de modifications

Vous trouverez ci-dessous quelques bonnes pratiques pour configurer et gérer les flux de modifications.

Envisagez d'utiliser une base de données de métadonnées distincte

Les flux de modifications utilisent une base de données de métadonnées pour maintenir l'état interne. La base de données de métadonnées peut être identique ou différente de la base de données qui contient les flux de modifications. Nous vous recommandons de créer une base de données distincte pour le stockage des métadonnées.

Le connecteur de flux de modifications Spanner a besoin d'autorisations en lecture/écriture sur la base de données de métadonnées. Vous n'avez pas besoin de préparer cette base de données avec un schéma, car le connecteur s'en charge.

L'utilisation d'une base de données de métadonnées distincte permet d'éliminer les complexités pouvant découler de l'autorisation d'écriture directe par le connecteur dans la base de données de votre application:

  • En séparant la base de données de métadonnées de la base de données de production avec le flux de modifications, le connecteur n'a besoin que d'autorisations en lecture sur la base de données de production.

  • Lorsque le trafic du connecteur est limité à une base de données de métadonnées distincte, les écritures effectuées par le connecteur lui-même ne sont pas incluses dans les flux de modifications de production. Cela est particulièrement pertinent pour les flux de modifications qui surveillent l'intégralité de la base de données.

Si aucune base de données distincte n'est utilisée pour stocker les métadonnées, nous vous recommandons de surveiller l'impact du connecteur de flux de modifications sur le processeur de leurs instances.

Effectuez une analyse comparative des nouveaux flux de modifications et redimensionnez-les si nécessaire.

Avant d'ajouter des flux de modifications à votre instance de production, envisagez d'effectuer une analyse comparative d'une charge de travail réaliste sur une instance de préproduction avec les flux de modifications activés. Cela vous permet de déterminer si vous devez ajouter des nœuds à votre instance afin d'augmenter ses capacités de calcul et de stockage.

Exécutez ces tests jusqu'à ce que les métriques du processeur et du stockage se stabilisent. Idéalement, l'utilisation du processeur par l'instance doit rester inférieure aux valeurs maximales recommandées et l'espace de stockage utilisé ne doit pas dépasser la limite de stockage de l'instance.

Utiliser différentes régions pour l'équilibrage de charge

Lorsque vous utilisez des flux de modifications dans une configuration d'instance multirégionale, envisagez d'exécuter leurs pipelines de traitement dans une région différente de celle de la région principale par défaut. Cela permet de répartir la charge de flux entre les instances répliquées non principales. Toutefois, si vous devez donner la priorité au délai de flux continu le plus bas possible par rapport à l'équilibrage de charge, exécutez la charge en flux continu dans la région principale.

Étapes suivantes