Replizieren von Kontoobjekten¶

Von Quellkonto ausführen¶

1. Erstellen Sie eine Rolle, und erteilen Sie dieser Rolle die Berechtigung CREATE FAILOVER GROUP. Der folgende Schritt ist optional:

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   USE ROLE ACCOUNTADMIN;
   
   CREATE ROLE myrole;
   
   GRANT CREATE FAILOVER GROUP ON ACCOUNT
    TO ROLE myrole;
   

   Copy

2. Erstellen Sie eine Failover-Gruppe im Quellkonto, und aktivieren Sie die Replikation in bestimmte Zielkonten:

   Bemerkung

   • Wenn Sie einer Replikations- oder Failover-Gruppe Datenbanken hinzufügen möchten, bei denen Datenbankreplikation und Failover zuvor mit ALTER DATABASE aktiviert worden war, befolgen Sie vor dem Hinzufügen der Datenbanken zu einer Gruppe die Anleitung unter Umstellen von Datenbankreplikation auf gruppenbasierte Replikation (unter diesem Thema).

   • Um eine Datenbank zu einer Failover-Gruppe hinzuzufügen, muss die aktive Rolle über die MONITOR-Berechtigung für die Datenbank verfügen. Weitere Informationen zu Berechtigungen für Datenbanken finden Sie unter Datenbankberechtigungen (untere einem anderen Thema).

   USE ROLE myrole;
   
   -- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
   CREATE FAILOVER GROUP myfg
       OBJECT_TYPES = USERS, ROLES, WAREHOUSES, RESOURCE MONITORS, DATABASES
       ALLOWED_DATABASES = db1, db2
       ALLOWED_ACCOUNTS = myorg.myaccount2, myorg.myaccount3
       REPLICATION_SCHEDULE = '10 MINUTE';
   

   Copy

   Achtung

   Wenn Kontoobjekte (z. B. Benutzer oder Rollen), die Sie während der Replikation nicht löschen möchten, im Zielkonto vorhanden sind, geben Sie beim Erstellen einer Replikations- oder Failover-Gruppe keinen Parameter in REPLICATION_SCHEDULE an. Weitere Details dazu finden Sie unter Schritt 5: Globale IDs auf Objekte anwenden, die von Skripten in Zielkonten erstellt wurden – Optional.

Von Zielkonto ausführen¶

3. Erstellen Sie eine Rolle im Zielkonto, und erteilen Sie dieser Rolle die Berechtigung CREATE FAILOVER GROUP. Der folgende Schritt ist optional:

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   USE ROLE ACCOUNTADMIN;
   
   CREATE ROLE myrole;
   
   GRANT CREATE FAILOVER GROUP ON ACCOUNT
       TO ROLE myrole;
   

   Copy

4. Erstellen Sie eine Failover-Gruppe im Zielkonto als Replikat der Failover-Gruppe im Quellkonto:

   USE ROLE myrole;
   
   -- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
   CREATE FAILOVER GROUP myfg
       AS REPLICA OF myorg.myaccount1.myfg;
   

   Copy

5. Wenden Sie globale IDs auf die Objekte an. Dies ist ein optionaler Schritt für alle Kontoobjekte, die nicht über die Replikation erstellt wurden.

   -- Execute the following SQL statements using the ACCOUNTADMIN role:
   SELECT SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME('myfg');
   

   Copy

   Achtung

   Dieser Schritt muss ausgeführt werden, wenn im Zielkonto Kontoobjekte (wie z. B. Benutzer) vorhanden sind, die Sie während der Replikation nicht löschen möchten. Wird dieser Schritt übersprungen, kann dies zum Verlust von Benutzer-Arbeitsblättern oder der Berechtigungszuweisungen zu Rollen für Objekte (z. B. für Freigaben) führen. Weitere Details dazu finden Sie unter Schritt 5: Globale IDs auf Objekte anwenden, die von Skripten in Zielkonten erstellt wurden – Optional.

Sekundäre Gruppe manuelle aktualisieren¶

Weitere Informationen zum manuellen Aktualisieren einer sekundären Failover-Gruppe im Zielkonto finden Sie unter Manuelles Aktualisieren einer sekundären Failover-Gruppe in einem Zielkonto (unter diesem Thema).

Vorschau für das Aktivieren der Stream- und Aufgabenreplikation – Optional¶

Um Vorschau für die Streamreplikation und die Aufgabenreplikation für ein Konto, eine Datenbank, eine Replikations- oder Failover-Gruppe zu aktivieren, setzen Sie den Parameter ENABLE_STREAM_TASK_REPLICATION für das Quellkonto oder das Primärobjekt auf true.

alter database mydb set ENABLE_STREAM_TASK_REPLICATION = true;

alter replication group myrg set ENABLE_STREAM_TASK_REPLICATION = true;

alter account myorg.myaccount set ENABLE_STREAM_TASK_REPLICATION = true;

Alle für Replikation aktivierten Konten anzeigen¶

Um die Liste der Konten in Ihrer Organisation abzurufen, die für die Replikation aktiviert sind, verwenden Sie SHOW REPLICATION ACCOUNTS.

-- Execute the following SQL statements using the ACCOUNTADMIN role:
SHOW REPLICATION ACCOUNTS;

+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| snowflake_region       | created_on              | account_name | account_locator |  comment        | organization_name |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_WEST_2          | 2020-07-15 21:59:25.455 | myaccount1   | myacctlocator1  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_EAST_1          | 2020-07-23 14:12:23.573 | myaccount2   | myacctlocator2  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+
| AWS_US_EAST_2          | 2020-07-25 19:25:04.412 | myaccount3   | myacctlocator3  |                 | myorg             |
+------------------------+-------------------------+--------------+-----------------+-----------------+-------------------+

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

Mitgliedschaft von Failover- und Replikationsgruppen anzeigen¶

Für Konto-, Datenbank- und Freigabeobjekte gibt es Einschränkungen hinsichtlich der Gruppenmitgliedschaft. Bevor Sie neue Gruppen erstellen oder Objekte zu bestehenden Gruppen hinzufügen, können Sie die Liste der bestehenden Failover-Gruppe und der Objekte in jeder Gruppe überprüfen.

Anzeigen aller Failover-Gruppen, die mit dem aktuellen Konto verknüpft sind, sowie die Objekttypen in jeder Gruppe:

SHOW FAILOVER GROUPS;

Copy

Anzeigen aller Datenbanken in der Failover-Gruppe myfg:

SHOW DATABASES IN FAILOVER GROUP myfg;

Copy

Anzeigen aller Freigaben in der Failover-Gruppe myfg:

SHOW SHARES IN FAILOVER GROUP myfg;

Copy

Replikation von Konto- und Datenbankobjekten von einem Quellkonto zum Zielkonto aktivieren¶

Erstellen Sie eine Failover-Gruppe mit den angegebenen Konto- und Datenbankobjekten im Quellkonto, und aktivieren Sie Replikation und Failover für eine Liste von Zielkonten. Weitere Informationen zur Syntax finden Sie unter CREATE FAILOVER GROUP.

Aktivieren Sie beispielsweise die Replikation von Benutzern, Rollen, Warehouses, Ressourcenmonitoren und der Datenbanken db1 und db2 vom Quellkonto in das Konto myaccount2 derselben Organisation. Konfigurieren den Replikationsplan so, dass myaccount2 alle 10 Minuten automatisch aktualisiert wird.

Auf dem Quellkonto ausführen:

use role myrole;

-- Execute the following SQL statement using a role with the CREATE FAILOVER GROUP privilege:
create failover group myfg
    object_types = users, roles, warehouses, resource monitors, databases, integrations, network policies
    allowed_databases = db1, db2
    allowed_integration_types = API INTEGRATIONS
    allowed_accounts = myorg.myaccount2
    replication_schedule = '10 MINUTE';

Replikations- oder Failover-Gruppen ohne Replikationsplan erstellen¶

Wenn eine sekundäre Replikations- oder Failover-Gruppe als Replikat einer primären Replikations- oder Failover-Gruppe mit einem Replikationsplan erstellt wird, wird beim Erstellen der sekundären Replikations- oder Failover-Gruppe automatisch eine erste Aktualisierung der sekundären Gruppe ausgeführt. Um dies zu verhindern, bevor Sie die folgenden Anweisungen ausführen können, erstellen Sie die primäre Replikations- oder Failover-Gruppe ohne Festlegen des Parameters REPLICATION_SCHEDULE.

Nachdem die sekundäre Gruppe im Zielkonto erstellt wurde, fügen Sie mit der Funktion SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME globale Bezeichner zu Kontoobjekten im Zielkonto hinzu. Kontoobjekte, die nur im Zielkonto vorhanden sind, müssen vor dem Aufrufen dieser Funktion manuell im Quellkonto repliziert werden.

Nachdem Sie den Objekten im Zielkonto globale Bezeichner zugewiesen oder sie im Quellkonto manuell neu erstellt haben, legen Sie mit dem Befehl ALTER REPLICATION GROUP oder ALTER FAILOVER GROUP den Replikationsplan für die primäre Replikations- oder Failover-Gruppe fest.

SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME() zum Anwenden von globalen IDs verwenden¶

Wenden Sie globale Bezeichner auf Kontoobjekte im Zielkonto an, die in der Liste object_types für die Failover-Gruppe myfg enthalten sind:

-- Execute the following SQL statements using the ACCOUNTADMIN role:
SELECT SYSTEM$LINK_ACCOUNT_OBJECTS_BY_NAME('myfg');

Beispiel¶

Anzeigen des Fortschritts der letzten Aktualisierungsoperation für die Failover-Gruppe myfg:

SELECT PHASE_NAME, START_TIME, END_TIME, PROGRESS, DETAILS
  FROM TABLE(information_schema.replication_group_refresh_progress('myfg'));

Beispiele¶

Abfragen der Information Schema-Tabellenfunktion REPLICATION_GROUP_REFRESH_HISTORY, um den Kontoreplikationsverlauf der Failover-Gruppe myfg in den letzten 7 Tagen anzuzeigen:

SELECT PHASE_NAME, START_TIME, END_TIME, TOTAL_BYTES, OBJECT_COUNT
  FROM TABLE(information_schema.replication_group_refresh_history('myfg'))
  WHERE START_TIME >= current_date - interval '7 days';

Abfragen der Account Usage-Ansicht REPLICATION_GROUP_REFRESH_HISTORY, um den Kontoreplikationsverlauf im aktuellen Monat anzuzeigen:

SELECT REPLICATION_GROUP_NAME, PHASE_NAME, START_TIME, END_TIME, TOTAL_BYTES, OBJECT_COUNT
  FROM snowflake.account_usage.replication_group_refresh_history
  WHERE START_TIME >= date_trunc('month', current_date());

Beispiele¶

Abfragen der Tabellenfunktion REPLICATION_GROUP_USAGE_HISTORY, um die in den letzten 7 Tagen für die Kontoreplikation verbrauchten Credits anzuzeigen:

SELECT start_time, end_time, replication_group_name, credits_used, bytes_transferred
  FROM table(information_schema.replication_group_usage_history(date_range_start=>dateadd('day', -7, current_date())));

Abfragen der Account Usage-Ansicht REPLICATION_GROUP_USAGE_HISTORY, um die von der Replikations- oder Failover-Gruppe für die Kontoreplikationsverlauf im aktuellen Monat verbrauchten Credits anzuzeigen:

SELECT start_time, 
  end_time, 
  replication_group_name, 
  credits_used, 
  bytes_transferred
FROM snowflake.account_usage.replication_group_usage_history
WHERE start_time >= DATE_TRUNC('month', CURRENT_DATE());

Beispiele¶

Von Zielkonto ausführen¶

1. Fragen Sie die Tabellenfunktion REPLICATION_GROUP_REFRESH_PROGRESS ab (in Snowflake Information Schema). Beachten Sie den primarySnapshotTimestamp in der Spalte DETAILS für die Phase PRIMARY_UPLOADING_METADATA. Dies ist der Zeitstempel für den neuesten Snapshot der Primärdatenbank.

   SELECT PARSE_JSON(details)['primarySnapshotTimestamp']
     FROM TABLE(information_schema.replication_group_refresh_progress('myfg'))
     WHERE PHASE_NAME = 'PRIMARY_UPLOADING_METADATA';
   

   Copy

2. Fragen Sie die Funktion HASH_AGG für eine angegebene Tabelle der Sekundärdatenbank ab. Die folgende Abfrage gibt einen Hashwert für alle Zeilen der Tabelle mytable zurück:

   SELECT HASH_AGG( * ) FROM mytable;
   

   Copy

Von Quellkonto ausführen¶

3. Fragen Sie die Funktion HASH_AGG für dieselbe Tabelle der Primärdatenbank ab. Geben Sie mithilfe von Time Travel den Zeitstempel an, zu dem der letzte Snapshot der sekundären Datenbank erstellt wurde:

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

   Copy

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