Replizieren von Datenbanken über mehrere Konten¶

Primärdatenbanken verwalten¶

1. Melden Sie sich über Snowsight bei einem Snowflake-Konto an, das eine Primärdatenbank enthält.

2. Wählen Sie das Dropdown-Menü oben links aus (neben Ihrem Anmeldenamen) » Switch Role » ACCOUNTADMIN.

3. Wählen Sie im linken Navigationsbereich Data » Databases aus. Wählen Sie im Datenbank-Objekt-Explorer eine Primärdatenbank aus. Die Datenbank-Detailseite wird geöffnet.

   Wenn Sie nur Datenbanken anzeigen möchten, die für die Replikation aktiviert wurden, können Sie alternativ den Filter Replication Status » Primary verwenden, um die Primärdatenbank im Konto aufzulisten. Wählen Sie eine Datenbank in der Liste aus, um die zugehörige Detailseite zu öffnen.

   Bemerkung

   Der Filter Replication Status ist nur verfügbar, wenn ein Konto ein Quell- oder Zielkonto für die Datenbankreplikation ist.

4. Wählen Sie » Enable Replication aus. Das Dialogfenster Enable replication wird geöffnet.

   Wählen Sie die Aktion aus, die Sie ausführen möchten:

   • Aktivieren des Failover. Außerdem erfordert dieses Feature die Business Critical Edition (oder höher).

   • Erstellen einer Sekundärdatenbank in einem oder mehreren Zielkonten.

     Wenn in einem anderen Konto eine Primärdatenbank für die Replikation in das aktuelle Konto aktiviert ist, können Sie eine Sekundärdatenbank im aktuellen Konto erstellen. Um weitere Zielkonten hinzuzufügen, aktualisieren Sie im Quellkonto mit dem Befehl ALTER DATABASE die Primärdatenbank.

   • Aktualisieren jeder Sekundärdatenbank einmal, nachdem sie erstellt wurde.

5. Aktivieren Sie für jedes Zielkonto dieser Datenbank die Optionen zum Erstellen einer Sekundärdatenbank und zum Aktualisieren der Datenbank.

6. Melden Sie sich beim Zielkonto als Benutzer an, dem zuvor die Rolle ACCOUNTADMIN in diesem Konto zugewiesen wurde.

   Snowflake führt die angeforderten Aktionen aus und zeigt einen Erfolgsdialog an.

   Verwalten Sie die Replikation für diese Datenbank auf der Registerkarte Replication der Datenbankdetails.

Sekundärdatenbanken verwalten¶

1. Melden Sie sich über Snowsight bei einem Snowflake-Konto an, das eine Sekundärdatenbank enthält.

2. Wählen Sie das Dropdown-Menü oben links aus (neben Ihrem Anmeldenamen) » Switch Role » ACCOUNTADMIN.

3. Wählen Sie im linken Navigationsbereich Data » Databases aus.

   Die folgenden Aktionen sind über die Aktionsschaltfläche (…) in der oberen rechten Ecke der Seite verfügbar:

   • Sekundärdatenbank erstellen.

     Bemerkung

     Diese Option ist nur verfügbar, wenn ein Konto ein Quell- oder Zielkonto für die Datenbankreplikation ist.

     Wenn in einem anderen Konto eine Primärdatenbank für die Replikation in das aktuelle Konto aktiviert ist, können Sie eine Sekundärdatenbank im aktuellen Konto erstellen. Um weitere Zielkonten hinzuzufügen, aktualisieren Sie im Quellkonto mit dem Befehl ALTER DATABASE die Primärdatenbank.

4. Wählen Sie im Datenbankobjekt-Explorer eine Sekundärdatenbank aus. Die Datenbank-Detailseite wird geöffnet.

5. Wählen Sie die Registerkarte Replication aus.

   Die folgenden Aktionen sind über die Aktionsschaltfläche (…) in der oberen rechten Ecke der Seite verfügbar:

   • Heraufstufen der sekundären Datenbank zur primären Datenbank. Außerdem erfordert dieses Feature die Business Critical Edition (oder höher).

     Bemerkung

     Um eine Sekundärdatenbank zur Primärdatenbank heraufzustufen, muss für die Primärdatenbank das Failover für das Zielkonto, in dem sich die Sekundärdatenbank befindet, aktiviert sein.

     Wenn diese Option nicht verfügbar ist, können Sie den Befehl ALTER DATABASE im Quellkonto verwenden, um das Failover für die Primärdatenbank auf dem Zielkonto zu aktivieren. Weitere Informationen dazu finden Sie unter Schritt 3: Aktivieren des Failovers für eine Primärdatenbank.

   • Aktualisieren Sie die Sekundärdatenbank.

   • Kopieren Sie eine Vorlage, um eine Aufgabe zu erstellen, mit der die Sekundärdatenbank nach einem Zeitplan aktualisiert wird. Fügen Sie die Vorlage in ein Snowsight-Arbeitsblatt ein, und bearbeiten Sie sie, um den gewünschten Zeitplan festzulegen.

Schritt 1: Anzeigen aller Konten Ihrer Organisation¶

Rufen Sie die Liste der Konten in Ihrer Organisation anzuzeigen, in der die Replikation aktiviert wurde. Jede in diesen Konten vorhandene permanente oder transiente Datenbank kann so geändert werden, dass sie als Primärdatenbank dient. Replikate einer Primärdatenbank (d. h. Sekundärdatenbanken) können nur in diesen Konten erstellt werden.

Fragen Sie SHOW REPLICATION ACCOUNTS ab, um die Liste der Konten in Ihrer Organisation anzuzeigen.

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             |
+------------------+---------------------------------+---------------+------------------+---------+-------------------+

Verwenden Sie auch die vollständige Liste der Regions-IDs.

Schritt 2: Heraufstufen einer lokalen Datenbank zur Verwendung als Primärdatenbank¶

Ändern Sie eine vorhandene permanente oder transiente Datenbank, um sie als Primärdatenbank zu verwenden. Verwenden Sie dafür die Anweisung ALTER DATABASE … ENABLE REPLICATION TO ACCOUNTS. Stellen Sie eine durch Kommas getrennte Liste der Konten Ihrer Organisation bereit, in denen ein Replikat dieser Datenbank (d. h. eine Sekundärdatenbank) gespeichert werden kann, sodass Benutzer in diesen Konten Objekte der Sekundärdatenbank abfragen können.

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

Schritt 3: Aktivieren des Failovers für eine Primärdatenbank¶

Aktivieren Sie das Failover einer Primärdatenbank für ein oder mehrere Konten Ihrer Organisation mithilfe einer Anweisung ALTER DATABASE … ENABLE FAILOVER TO ACCOUNTS. Das Replikat dieser Primärdatenbank in einem der Konten (d. h. eine Sekundärdatenbank) kann heraufgestuft werden, um als Primärdatenbank zu dienen.

Beachten Sie, dass das Aktivieren des Failovers für eine Primärdatenbank entweder vor oder nach dem Erstellen des Replikats der Primärdatenbank in einem angegebenen Konto erfolgen kann.

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

Schritt 4: Erstellen einer Sekundärdatenbank¶

Erstellen Sie ein Replikat einer vorhandenen Primärdatenbank entweder in demselben Konto, in dem die Primärdatenbank gespeichert ist, oder in einem anderen Konto (in derselben oder in einer anderen Region). Beachten Sie, dass Sie eine Sekundärdatenbank nur in einem Konto erstellen können, das in der Anweisung ALTER DATABASE … ENABLE REPLICATION TO ACCOUNTS in Schritt 2: Heraufstufen einer lokalen Datenbank zur Verwendung als Primärdatenbank angegeben ist.

Führen Sie eine CREATE DATABASE … AS REPLICA OF-Anweisung in jedem Zielkonto aus, um ein Replikat der angegebenen Primärdatenbank zu erstellen.

Verwenden Sie die Funktion SHOW REPLICATION DATABASES, um die Liste der Primär- und Sekundärdatenbanken Ihrer Organisation abzufragen. Nachdem eine Sekundärdatenbank erstellt wurde, kann ein Kontoadministrator die Eigentümerschaft der Datenbank auf eine andere Rolle übertragen (mithilfe von 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      |
+------------------+-------------------------------+---------------+----------+---------+------------+-------------------------+---------------------------------+------------------------------+-------------------+-----------------+

Schritt 5: Aktualisieren jeder Sekundärdatenbank¶

In den Anweisungen in diesem Abschnitt wird erläutert, wie eine Sekundärdatenbank aus einem Snapshot ihrer Primärdatenbank aktualisiert wird (mithilfe von ALTER DATABASE … REFRESH). Ein Snapshot enthält Änderungen an den Objekten und Daten. Für die erste Replikation einer sehr großen Primärdatenbank empfehlen wir das Erhöhen des Anweisungstimeouts.

Verwenden Sie nach der Anmeldung bei einem Konto die Funktion CURRENT_REGION, um die aktuelle Region abzufragen.

ALTER DATABASE mydb1 REFRESH;

Sie können auch eine Sekundärdatenbank über die Weboberfläche aktualisieren.

Schritt 6: Aktualisieren einer Sekundärdatenbank nach einem Zeitplan¶

Als bewährte Methode empfehlen wir, für die Aktualisierung Ihrer Sekundärdatenbank einen Zeitplan einzurichten. Dieser Abschnitt enthält eine Anleitung zum automatischen Starten einer Datenbankaktualisierung nach einem festgelegten Zeitplan.

Die Häufigkeit, mit der Sie eine Sekundärdatenbank aktualisieren, hängt vom Wiederanlaufzeitpunkt nach einem Ausfall (Recovery Point Objective, RPO) für die Daten in der Sekundärdatenbank ab. Wenn beispielsweise Anwendungen, die auf den Daten basieren, Datenverluste von bis zu 1 Stunden tolerieren können, müssen Sie die Daten mindestens stündlich aktualisieren. Wenn die Datenverlusttoleranz 5 Minuten beträgt, aktualisieren Sie die Sekundärdatenbank mindestens alle 5 Minuten.

Führen Sie die Schritte in diesem Abschnitt aus, um eine Datenbankaktualisierung nach einem festgelegten Zeitplan automatisch zu starten.

Voraussetzungen:

Die folgenden Snowflake-Objekte sind in dem Konto erforderlich, in dem die Sekundärdatenbank gespeichert ist:

• Die Sekundärdatenbank.

• Eine separate Datenbank zum Speichern der in diesem Abschnitt erstellten neuen Objekte. Da Sekundärdatenbanken schreibgeschützt sind, muss diese Datenbank von der Sekundärdatenbank getrennt sein. Diese Datenbank muss auch die folgenden Objekte enthalten:

  • Schema. Verwenden Sie das Schema PUBLIC, oder erstellen Sie mit CREATE SCHEMA ein neues Schema.

  • Warehouse. Hier kann ein beliebiges Warehouse bereitgestellt werden, um die Syntaxanforderung zu erfüllen, das aber nicht für die Datenbankaktualisierung verwendet wird. Erstellen Sie ein neues Warehouse mit CREATE WAREHOUSE.

  • Aufgabe, die die Sekundärdatenbank nach einem Zeitplan aktualisiert.

Erforderliche Berechtigungen:

Für die Schritte in diesem Abschnitt ist eine Rolle erforderlich, die in dem Konto, in dem die Sekundärdatenbank aktualisiert wird, die folgenden Berechtigungen aufweist:

Objekttyp	Objekt	Berechtigung	Anmerkungen
Konto	Konto, in dem die Sekundärdatenbank gespeichert ist	EXECUTE TASK	Erforderlich, um die neue Aufgabe auszuführen.
Datenbank	Sekundärdatenbank	OWNERSHIP	Erforderlich, um die Sekundärdatenbank zu aktualisieren.
Datenbank	Datenbank, in der die neue Aufgabe gespeichert wird.	USAGE
Schema	Schema, in dem die neue Aufgabe gespeichert wird.	USAGE, CREATE TASK
Aufgabe		OWNERSHIP	Die Rolle, die die Aufgabe erstellt, besitzt standardmäßig das Objekt. Die Eigentümerschaft kann mit GRANT privileges … TO ROLE auf eine andere Rolle übertragen werden.
Warehouse	Warehouse, das zur Konfiguration der Aufgabe verwendet wird	USAGE	Die Angabe eines Warehouses ist für die Konfiguration der Aufgabe erforderlich, auch wenn das Warehouse nicht für die Ausführung der Aufgabe oder für die Aktualisierungsoperation verwendet wird.

Schritte:

Führen Sie die folgenden Schritte für jede Sekundärdatenbank aus, die Sie nach einem Zeitplan aktualisieren möchten:

1. Erstellen Sie eine Aufgabe, mit der die Datenbankaktualisierung nach einem Zeitplan gestartet wird (mithilfe von CREATE TASK). Beachten Sie, dass obwohl die CREATE TASK-Syntax zur Angabe eines Replikationsplans ein Warehouse erfordert, das Warehouse nicht für die Replikation verwendet wird.

   Erstellen Sie beispielsweise eine Aufgabe mit dem Namen refresh_mydb1_task, die alle 10 Minuten und einem Timeout von 4 Stunden eine Sekundärdatenbank mit dem Namen mydb1 aktualisiert. Die Aufgabe wird mit dem vorhandenen Warehouse mywh konfiguriert:

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

   Copy

2. Eine Aufgabe wird bei ihrer Erstellung standardmäßig angehalten. Setzen Sie die Aufgabe fort, um sie auf Grundlage der in der Aufgabendefinition angegebenen Parameter auszuführen:

ALTER TASK refresh_mydb1_task RESUME;

Copy

Beispiel¶

Führen Sie die folgenden SQL-Anweisungen in Ihrem bevorzugten Snowflake-Client aus, um Replikation und Failover zu aktivieren, eine erste Datenbankaktualisierung durchzuführen und geplante Aktualisierungen einzurichten.

-- 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;

Verwenden des veralteten Konto-Locators¶

Obwohl das alte Format snowflake_region.account_locator derzeit bei der Identifizierung eines Kontos in Replikations- und Failover-Befehlen unterstützt wird, wird von seiner Verwendung abgeraten, da es in Zukunft nicht mehr funktionieren könnte.

Ausgeführt auf der Sekundärdatenbank¶

1. Fragen Sie in der Sekundärdatenbank die Tabellenfunktion DATABASE_REFRESH_PROGRESS ab (im Snowflake Information Schema). Beachten Sie den Wert snapshot_transaction_timestamp in der Spalte DETAILS für die Phase PRIMARY_UPLOADING_DATA. Dies ist der Zeitstempel für den neuesten Snapshot der Primärdatenbank.

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

   Copy

2. Fragen Sie die Funktion HASH_AGG für eine angegebene Tabelle ab. Die folgende Abfrage gibt einen Hash-Wert für alle Zeilen der Tabelle mytable zurück:

   SELECT HASH_AGG( * ) FROM mytable;
   

   Copy

Ausgeführt auf der Primärdatenbank¶

3. Fragen Sie in der Primärdatenbank auf derselben Tabelle die Funktion HASH_AGG ab. Geben Sie mithilfe von Time Travel den Zeitstempel an, zu dem der letzte Snapshot der Sekundärdatenbank erstellt wurde:

   SELECT HASH_AGG( * ) FROM mytable AT(TIMESTAMP => '<snapshot_transaction_timestamp>'::TIMESTAMP);
   

   Copy

4. Vergleichen Sie die Ergebnisse der beiden Abfragen. Die Ausgabe sollte identisch sein.