Mit Sammlungen den Überblick behalten
Sie können Inhalte basierend auf Ihren Einstellungen speichern und kategorisieren.
In den folgenden Abschnitten wird beschrieben, wie Sie eine Cloud SQL for PostgreSQL-Datenbank konfigurieren.
Logische Replikation aktivieren
Rufen Sie Cloud SQL in der Google Cloud Konsole auf.
Öffnen Sie die Cloud SQL-Instanz und klicken Sie auf BEARBEITEN.
Gehen Sie zum Abschnitt Flags.
Klicken Sie auf Flag hinzufügen.
Wählen Sie im Drop-down-Menü das Flag cloudsql.logical_decoding aus.
Setzen Sie den Flag-Wert auf on.
Klicken Sie auf Speichern, um die Änderungen zu speichern. Sie müssen die Instanz neu starten, damit die Änderungen übernommen werden.
Nachdem die Instanz neu gestartet wurde, prüfen Sie die Änderungen auf der Seite Übersicht unter Datenbank-Flags.
Publikation und Replikationsslot erstellen
Stellen Sie eine Verbindung zur Datenbank als Nutzer mit ausreichenden Berechtigungen zum Erstellen eines Replikationsslots her. Führen Sie andernfalls den folgenden Befehl aus:
ALTER USER USER_NAME WITH REPLICATION;
Ersetzen Sie Folgendes:
USER_NAME: Der Name des Nutzers, dem Sie Replikationsberechtigungen erteilen möchten.
Publikation erstellen Wir empfehlen, eine Publikation nur für die Tabellen zu erstellen, die Sie replizieren möchten. So kann Datastream nur die relevanten Daten lesen. Das verringert die Belastung der Datenbank und von Datastream:
CREATE PUBLICATION PUBLICATION_NAME
FOR TABLE SCHEMA1.TABLE1, SCHEMA2.TABLE2;
Ersetzen Sie Folgendes:
PUBLICATION_NAME: Der Name Ihrer Publikation. Sie müssen diesen Namen angeben, wenn Sie einen Stream im Assistenten zum Erstellen von Datastream-Streams erstellen.
SCHEMA: Der Name des Schemas, das die Tabelle enthält.
TABLE: Der Name der Tabelle, die Sie replizieren möchten.
Sie können auch eine Publikation für alle Tabellen in Ihrer Datenbank erstellen. Bei diesem Ansatz wird die Last sowohl für die Quelldatenbank als auch für Datastream erhöht:
CREATE PUBLICATION PUBLICATION_NAME FOR ALL TABLES;
Erstellen Sie mit dem folgenden SQL-Befehl einen Replikationsslot:
REPLICATION_SLOT_NAME: Der Name Ihres Replikations-Slots.
Sie müssen diesen Namen angeben, wenn Sie im Assistenten zum Erstellen von Datastream-Streams einen Stream erstellen.
Datastream-Nutzer erstellen
Stellen Sie eine Verbindung zur Datenbank über einen PostgreSQL-Client her.
Geben Sie den folgenden PostgreSQL-Befehl ein:
CREATE USER USER_NAME WITH REPLICATION LOGIN PASSWORD 'USER_PASSWORD';
Ersetzen Sie Folgendes:
USER_NAME: Der Name des Datastream-Nutzers, den Sie erstellen möchten.
USER_PASSWORD: Das Anmeldepasswort für den Datastream-Nutzer, den Sie erstellen möchten.
Gewähren Sie dem erstellten Nutzer die folgenden Berechtigungen:
GRANT SELECT ON ALL TABLES IN SCHEMA SCHEMA_NAME TO USER_NAME;
GRANT USAGE ON SCHEMA SCHEMA_NAME TO USER_NAME;
ALTER DEFAULT PRIVILEGES IN SCHEMA SCHEMA_NAME
GRANT SELECT ON TABLES TO USER_NAME;
Ersetzen Sie Folgendes:
SCHEMA_NAME: Der Name des Schemas, für das Sie die Berechtigungen gewähren möchten.
USER_NAME: Der Nutzer, dem Sie die Berechtigungen gewähren möchten.
[[["Leicht verständlich","easyToUnderstand","thumb-up"],["Mein Problem wurde gelöst","solvedMyProblem","thumb-up"],["Sonstiges","otherUp","thumb-up"]],[["Schwer verständlich","hardToUnderstand","thumb-down"],["Informationen oder Beispielcode falsch","incorrectInformationOrSampleCode","thumb-down"],["Benötigte Informationen/Beispiele nicht gefunden","missingTheInformationSamplesINeed","thumb-down"],["Problem mit der Übersetzung","translationIssue","thumb-down"],["Sonstiges","otherDown","thumb-down"]],["Zuletzt aktualisiert: 2025-09-04 (UTC)."],[[["\u003cp\u003eEnable logical replication in Cloud SQL by setting the \u003ccode\u003ecloudsql.logical_decoding\u003c/code\u003e flag to 'on' and restarting the instance to apply the changes.\u003c/p\u003e\n"],["\u003cp\u003eCreate a publication for specific tables or all tables, using the \u003ccode\u003eCREATE PUBLICATION\u003c/code\u003e command, to manage the data intended for replication.\u003c/p\u003e\n"],["\u003cp\u003eEstablish a replication slot with a unique name using the \u003ccode\u003ePG_CREATE_LOGICAL_REPLICATION_SLOT\u003c/code\u003e function for each stream replicating from the database.\u003c/p\u003e\n"],["\u003cp\u003eCreate a dedicated Datastream user with replication and login privileges, then grant it necessary \u003ccode\u003eSELECT\u003c/code\u003e and \u003ccode\u003eUSAGE\u003c/code\u003e privileges on the required schemas.\u003c/p\u003e\n"]]],[],null,["# Configure a Cloud SQL for PostgreSQL database\n\nThe following sections cover how to configure a Cloud SQL for PostgreSQL database.\n\n### Enable logical replication\n\n1. Navigate to Cloud SQL in the Google Cloud console.\n\n2. Open the Cloud SQL instance and click **EDIT**.\n\n3. Go to the **Flags** section.\n\n4. Click **ADD FLAG**.\n\n5. Choose the `cloudsql.logical_decoding` flag from the drop-down menu.\n\n6. Set the flag value to **on**.\n\n7. Click **SAVE** to save your changes. You'll need to restart your instance to\n update your instance with the changes.\n\n8. Once your instance has been restarted, confirm your changes under\n **Database flags** on the **Overview** page.\n\n### Create a publication and a replication slot\n\n1. Connect to the database as a user with sufficient privileges to create a replication slot; otherwise, run the following command:\n\n ```\n ALTER USER USER_NAME WITH REPLICATION;\n ```\n\n Replace the following:\n - \u003cvar translate=\"no\"\u003eUSER_NAME\u003c/var\u003e: The name of the user to whom you want to grant replication privileges.\n\n | If your current user can't run the command, then reconnect to the database with the default `postgres` username and run the command.\n2. Create a publication. We recommend that you create a publication only for the\n tables that you want to replicate. This allows Datastream to read-only\n the relevant data, and lowers the load on the database and Datastream:\n\n ```\n CREATE PUBLICATION PUBLICATION_NAME\n FOR TABLE SCHEMA1.TABLE1, SCHEMA2.TABLE2;\n ```\n\n Replace the following:\n - \u003cvar translate=\"no\"\u003ePUBLICATION_NAME\u003c/var\u003e: The name of your publication. You'll need to provide this name when you create a stream in the Datastream stream creation wizard.\n - \u003cvar translate=\"no\"\u003eSCHEMA\u003c/var\u003e: The name of the schema that contains the table.\n - \u003cvar translate=\"no\"\u003eTABLE\u003c/var\u003e: The name of the table that you want to replicate.\n\n You can also create a publication for all tables in your database. Note that\n this approach increases the load on both the source database and Datastream: \n\n ```\n CREATE PUBLICATION PUBLICATION_NAME FOR ALL TABLES;\n ```\n | For PostgreSQL 15 and later, you can create a publication for all tables in a schema. This approach lets you replicate changes for tables in the specified list of schemas, including tables that you create in the future: \n |\n | ```\n | CREATE PUBLICATION PUBLICATION_NAME\n | FOR TABLES IN SCHEMA SCHEMA1, SCHEMA2;\n | ```\n3. Create a replication slot by entering the following SQL command:\n\n ```\n SELECT PG_CREATE_LOGICAL_REPLICATION_SLOT('REPLICATION_SLOT_NAME', 'pgoutput');\n ```\n\n \u003cbr /\u003e\n\n Replace the following:\n - \u003cvar translate=\"no\"\u003eREPLICATION_SLOT_NAME\u003c/var\u003e: The name of your replication slot. You'll need to provide this name when you create a stream in the Datastream stream creation wizard.\n\n | The replication slot name must be unique for each stream that's replicating from this database.\n\n### Create a Datastream user\n\n1. Connect to the database using a PostgreSQL client.\n\n2. Enter the following PostgreSQL command:\n\n ```\n CREATE USER USER_NAME WITH REPLICATION LOGIN PASSWORD 'USER_PASSWORD';\n ```\n\n \u003cbr /\u003e\n\n Replace the following:\n - \u003cvar translate=\"no\"\u003eUSER_NAME\u003c/var\u003e: The name of the Datastream user that you want to create.\n - \u003cvar translate=\"no\"\u003eUSER_PASSWORD\u003c/var\u003e: The login password for the Datastream user that you want to create.\n3. Grant the following privileges to the user you created:\n\n ```\n GRANT SELECT ON ALL TABLES IN SCHEMA SCHEMA_NAME TO USER_NAME;\n GRANT USAGE ON SCHEMA SCHEMA_NAME TO USER_NAME;\n ALTER DEFAULT PRIVILEGES IN SCHEMA SCHEMA_NAME\n GRANT SELECT ON TABLES TO USER_NAME;\n ```\n\n Replace the following:\n - \u003cvar translate=\"no\"\u003eSCHEMA_NAME\u003c/var\u003e: The name of the schema to which you want to grant the privileges.\n - \u003cvar translate=\"no\"\u003eUSER_NAME\u003c/var\u003e: The user to whom you want to grant the privileges.\n\nWhat's next\n-----------\n\n- Learn more about how Datastream works with [PostgreSQL sources](/datastream/docs/sources-postgresql)."]]
