Cette page explique comment créer, modifier et afficher les modifications apportées à Spanner flux. Pour en savoir plus, consultez À propos des flux de modifications.
Les flux de modifications étant des objets de schéma, vous les créez et les gérez via le même schéma basé sur le LDD mises à jour utilisées pour tout autre type de base de données, comme la création de tables ou l'ajout d'index.
Spanner initie une opération de longue durée opération après avoir effectué envoyer 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é commencer à surveiller les colonnes ou les tableaux spécifiés 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 le schéma des objets qu'il surveillera: soit la base de données dans son intégralité, soit une liste de tableaux et de colonnes. Vous pouvez éventuellement spécifier les éléments suivants:
- durée de conservation pour remplacer la valeur durée de conservation par défaut
- value capture type pour remplacer la valeur par défaut
Type de capture
OLD_AND_NEW_VALUES
. - Filtre des suppressions basées sur la valeur TTL si vous souhaitez exclure Suppressions basées sur la valeur TTL de vos flux de modifications
exclure les modifications de table pour exclure toutes les modifications de table
INSERT
,UPDATE
ouDELETE
GoogleSQL
La syntaxe LDD pour créer un flux de modifications à l'aide de GoogleSQL ressemble comme ceci:
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 utilisée pour créer un flux de modifications à l'aide de PostgreSQL est comme ceci:
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 que l'opération de longue durée qui a été créé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
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
implicitement
inclut toutes les futures données de la base de données
de tableaux et de colonnes, dès leur création. Il ne permet pas
inclure des vues, des tables de schémas d'informations ou
à d'autres objets autres que
les tables de données normales.
Surveiller des tableaux spécifiques
Pour limiter le champ d'application d'un flux de modifications à des tables spécifiques, qu'une base de données entière, spécifiez une liste comportant un ou plusieurs tableaux:
CREATE CHANGE STREAM SingerAlbumStream
FOR Singers, Albums;
Spanner met à jour automatiquement les modifications qui surveillent des tables entières pour refléter les modifications de schéma affectant telles que l'ajout ou la suppression de colonnes.
Colonnes spécifiques à la surveillance
Utilisez la syntaxe table(column_1[, column_2,
...])
pour surveiller les modifications apportées à un ou plusieurs éléments
des colonnes non clés 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 effectue toujours le suivi des clés primaires de chaque table qu'il surveille. Cela permet chaque enregistrement de modification de données pour identifier la ligne modifiée par sa clé primaire.
Surveiller les tables et les colonnes dans un seul flux
Vous pouvez combiner la syntaxe d'observation des tables et 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
que la valeur par défaut d'un jour, définissez retention_period
sur un point
d'une semaine maximum, 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 autre type de capture de valeur
spécifier un type de capture des valeurs 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 des valeurs TTL.
du 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 Filtre des suppressions basées sur la valeur TTL.
GoogleSQL
Pour créer un flux de modifications avec le filtre de suppressions basées 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 des valeurs 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ées 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 des valeurs TTL:
CREATE CHANGE STREAM NewFilterChangeStream FOR ALL
WITH (exclude_ttl_deletes = true)
Pour ajouter ou supprimer le filtre des suppressions basées sur la valeur TTL dans un consultez Modifier le filtre des suppressions basées sur la valeur TTL. Pour confirmer vos filtres de flux de modifications, procédez comme suit : afficher les définitions du flux de modifications en tant que LDD.
Filtrer par type de modification de la table
Filtrez une ou plusieurs de ces modifications de table de votre modifiez le champ d'application du flux à l'aide des options de filtre disponibles suivantes:
exclude_insert
: exclure toutes les modifications de tableINSERT
exclude_update
: exclure toutes les modifications de tableUPDATE
exclude_delete
: exclure toutes les modifications de tableDELETE
Pour en savoir plus sur le fonctionnement de ces filtres, consultez Filtres de type de modification de table.
GoogleSQL
Créer un flux de modifications avec un ou plusieurs types de modifications 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: le filtre que vous
que vous souhaitez ajouter:
exclude_insert
,exclude_update
ouexclude_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
Créer un flux de modifications avec un ou plusieurs types de modifications 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
- MOD_TYPE_FILTER_NAME: le filtre que vous
que vous souhaitez ajouter:
exclude_insert
,exclude_update
ouexclude_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 la modification de table INSERT
et UPDATE
types de transactions:
CREATE CHANGE STREAM NewFilterChangeStream FOR ALL
WITH (exclude_insert = true, exclude_update = true)
Pour ajouter ou supprimer un filtre de type de modification de tableau dans un tableau existant flux de modifications, consultez Modifier le filtre par type de modification de table. Vous pouvez confirmer les filtres de type de modification de tableau qui existent pour votre modifier le flux de afficher 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 un 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 longueur de ses données
et la durée de conservation. Vous pouvez également suspendre le visionnage
la conservation de ses enregistrements
de modifications de données.
Modifier les éléments surveillés par un flux de modifications
Dans cet exemple, l'intégralité de la table Songs
est ajoutée au fichier NamesAndAlbums
.
flux de modifications 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 une fois l'opération de longue durée terminée. qui met à jour la définition du flux de modifications dans le du schéma.
Modifier la durée de conservation des données d'un flux de modifications
Pour modifier la durée de conservation d'un flux de modifications
les enregistrements, définissez retention_period
dans une instruction LDD ALTER CHANGE STREAM
.
Cet exemple ajuste la durée de conservation des données sur NamesAndAlbums
flux de modifications 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 valeurs d'un flux de modifications
Pour modifier le type de capture de valeur d'un flux de modifications, définissez le
La clause value_capture_type
dans une instruction LDD ALTER CHANGE STREAM
.
Dans cet exemple, le type de capture de valeur est défini 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ées sur la valeur TTL
Modifier le filtre Suppressions basées sur la valeur TTL pour une modification
stream, définissez le filtre exclude_ttl_deletes
dans un LDD ALTER CHANGE STREAM
. Cela vous permet d'ajouter le filtre à un filtre ou de l'en supprimer
vos flux de modifications existants.
Pour en savoir plus sur le fonctionnement de ces filtres, consultez 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 TTL à un flux de modifications existant,
Utilisez la commande suivante pour définir le filtre sur true
:
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
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 des valeurs 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 TTL à un flux de modifications existant,
Utilisez la commande suivante pour définir le filtre sur True
:
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
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,
Utilisez la commande suivante pour définir le filtre sur False
:
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'une
flux de modifications existant appelé NewFilterChangeStream
:
ALTER CHANGE STREAM NewFilterChangeStream FOR ALL
SET OPTIONS (exclude_ttl_deletes = false)
Cela inclut toutes les futures suppressions basées sur la valeur TTL du flux de modifications.
Vous pouvez également définir le filtre sur null
pour supprimer le filtre des suppressions basées sur la valeur TTL.
PostgreSQL
Pour supprimer le filtre de suppressions basées
sur la valeur TTL dans un flux de modifications existant,
Utilisez la commande suivante pour définir le filtre sur False
:
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'une
flux de modifications existant appelé NewFilterChangeStream
:
ALTER CHANGE STREAM NewFilterChangeStream FOR ALL
SET (exclude_ttl_deletes = false)
Cela inclut toutes les futures suppressions basées sur la valeur TTL du flux de modifications.
Vous pouvez également définir le filtre sur null
pour supprimer le filtre des suppressions basées sur la valeur TTL.
Modifier le filtre par type de modification de table
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 utiliser cette
pour ajouter ou supprimer un filtre existant dans votre flux de modifications.
Ajouter un filtre de type de modification de table à un flux de modifications existant
GoogleSQL
Pour ajouter un ou plusieurs nouveaux filtres de type de modification de tableau à une table existante
modifier le flux, utilisez le code suivant pour définir le filtre sur true
:
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 l'instance existante flux de modifications
- MOD_TYPE_FILTER_NAME: remplacer par le filtre que vous
que vous souhaitez ajouter:
exclude_insert
,exclude_update
ouexclude_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 appelé NewFilterChangeStream
:
ALTER CHANGE STREAM NewFilterChangeStream
SET OPTIONS (exclude_delete = true)
PostgreSQL
Pour ajouter un ou plusieurs nouveaux filtres de type de modification de tableau à une table existante
modifier le flux, utilisez le code suivant pour définir le filtre sur true
:
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 l'instance existante flux de modifications
- MOD_TYPE_FILTER_NAME: remplacer par le filtre que vous
que vous souhaitez ajouter:
exclude_insert
,exclude_update
ouexclude_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 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 tableau existants dans
modifier le flux, utilisez le code suivant pour définir le filtre sur false
:
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 l'instance existante flux de modifications
- MOD_TYPE_FILTER_NAME: remplacer par le filtre que vous
que vous souhaitez supprimer:
exclude_insert
,exclude_update
ouexclude_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 appelé NewFilterChangeStream
:
ALTER CHANGE STREAM NewFilterChangeStream
SET OPTIONS (exclude_delete = false)
Vous pouvez également supprimer un filtre de modification de tableau en le définissant
à 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 tableau existants dans
modifier le flux, utilisez le code suivant pour définir le filtre sur False
:
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 l'instance existante flux de modifications
- MOD_TYPE_FILTER_NAME: remplacer par le filtre que vous
que vous souhaitez ajouter:
exclude_insert
,exclude_update
ouexclude_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 appelé NewFilterChangeStream
:
ALTER CHANGE STREAM NewFilterChangeStream
SET (exclude_delete = false)
Vous pouvez également supprimer un filtre de modification de tableau en le définissant
à 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 interrompt son activité tout en conservant vos dossiers internes, du moins pendant toute la durée de conservation des données, vous pour 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 l'expression 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 plus d'enregistrements de modifications de données. Sa modification les enregistrements restent intacts, conformément aux règles de conservation des données du flux.
Pour réactiver une diffusion suspendue, émettez un autre ALTER CHANGE STREAM
par sa configuration précédente.
Supprimer un flux de modifications
Pour supprimer définitivement un flux de modifications, envoyez une DROP CHANGE STREAM
qui inclut 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 des données.
Lister et afficher les flux de modifications
La console Google Cloud fournit une interface Web permettant de répertorier examiner les définitions de flux de modifications d'une base de données. Vous pouvez également consulter structure des flux de modifications sous la forme d'instructions LDD équivalentes, ou par 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:
Accédez à la page "Instances Spanner" de la console Google Cloud.
Accédez à l'instance et à la base de données appropriées.
Cliquez sur Modifier les flux dans le menu de navigation.
Une liste de tous les flux de modifications de cette base de données s'affiche. la configuration de chacune d'entre elles. En cliquant sur le nom d'un flux révèle plus de détails sur les tableaux et les colonnes qu'il surveille.
Afficher les définitions des flux de modifications en tant que LDD
L'affichage du schéma d'une base de données en tant que LDD inclut la description de tous ses
les flux de modifications, où ils apparaissent sous forme d'instructions CREATE CHANGE STREAM
.
Pour ce faire, à partir de 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 ce faire à 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 les informations d'une base de données schéma sur ses flux de modifications. La les tableaux suivants contiennent les métadonnées qui définissent les flux de modifications noms, les tables et les colonnes qu'ils surveillent et leur conservation périodes:
Bonnes pratiques concernant les flux de modifications
Voici quelques bonnes pratiques pour configurer et gérer le changement flux.
Envisager 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 qui contient les flux de modifications. Nous vous recommandons de créer une base de données distincte stockage de métadonnées.
Le connecteur de flux de modifications Spanner nécessite un accès en lecture/écriture à la base de données de métadonnées. Vous n'avez pas besoin de préparer avec un schéma. le connecteur s'en charge.
L'utilisation d'une base de données de métadonnées distincte élimine les difficultés qui peuvent survenir d'autoriser le connecteur à écrire directement dans la base de données de votre application:
En séparant la base de données de métadonnées la base de données de production avec le flux de modifications, le connecteur n'a besoin les autorisations de lecture sur la base de données de production.
En limitant le trafic du connecteur à des métadonnées distinctes base de données, 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 important 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 sur ses instances.
Analysez de nouveaux flux de modifications et redimensionnez-les si nécessaire
Avant d'ajouter de nouveaux flux de modifications à votre instance de production, une analyse comparative d'une charge de travail réaliste sur une instance de préproduction avec modifications flux 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 capacités.
Exécutez ces tests jusqu'à ce que les métriques de processeur et de stockage se stabilisent. Dans l'idéal, l'utilisation du processeur de l'instance les valeurs maximales recommandées ; l'espace de stockage utilisé ne doit pas dépasser la limite de stockage de l'instance.
Utiliser différentes régions pour équilibrer la charge
Lorsque vous utilisez des flux de modifications configuration d'instance multirégionale, envisagez de courir ses pipelines de traitement dans une région différente de celle de l'instance principale par défaut dans la même région. Cela permet de répartir la charge en flux continu entre les instances répliquées non principales. Si vous devez privilégier le délai le plus bas possible mais l'équilibrage de charge exécute la charge en flux continu dans la région principale.
Étape suivante
Utiliser des modèles pour connecter rapidement un flux de modifications à BigQuery, Cloud Storage, ou Pub/Sub.