Aktivieren von Fehlerbenachrichtigungen für Aufgaben mit Google Pub/Sub

Unter diesem Thema wird eine Anleitung zur Konfiguration von Fehlerbenachrichtigungen für Aufgaben unter Verwendung von Google Pub/Sub bereitgestellt.

Aktivieren von Fehlerbenachrichtigungen mit Google Pub/Sub

Um Aufgabenbenachrichtigungen zu aktivieren, führen Sie die in den nächsten Abschnitten beschriebenen Schritte aus.

Schritt 1: Erstellen des Pub/Sub-Themas

Erstellen Sie ein Pub/Sub-Thema, das Fehlerbenachrichtigungsmeldungen von Snowflake empfangen kann, oder verwenden Sie ein vorhandenes Thema. Sie können das Thema mit Cloud Shell oder Cloud SDK erstellen. Weitere Informationen dazu finden Sie in der Pub/Sub-Dokumentation unter Themen erstellen und verwenden.

Führen Sie zum Beispiel den folgenden Befehl aus, um ein leeres Thema zu erstellen:

$ gsutil notification create -t <topic>
Copy

Wenn das Thema bereits vorhanden ist, wird es vom Befehl verwendet. Andernfalls wird ein neues Thema erstellt.

Schritt 2: Erstellen des Pub/Sub-Abonnements

Erstellen Sie optional ein Abonnement für das Pub/Sub-Thema, um Fehlerbenachrichtigungen abzurufen. Sie können ein Abonnement mit Pull-Bereitstellung für das Pub/Sub-Thema über die Cloud Console, das Befehlszeilentool gcloud oder die Cloud Pub/Sub-API erstellen. Anweisungen finden Sie unter Verwalten von Themen und Abonnements in der Pub/Sub-Dokumentation.

Schritt 3: Erstellen einer Benachrichtigungsintegration in Snowflake

Erstellen Sie eine Benachrichtigungsintegration mit dem Befehl CREATE NOTIFICATION INTEGRATION. Die Benachrichtigungsintegration verweist auf Ihr Pub/Sub-Thema. Snowflake verknüpft die Benachrichtigungsintegration mit einem Google Cloud Platform (GCP)-Dienstkonto, das für Ihr Konto erstellt wurde. Snowflake erstellt ein einziges Dienstkonto, auf das von allen GCP-Speicherintegrationen in Ihrem Snowflake-Konto verwiesen wird.

Bemerkung

  • Dieser SQL-Befehl kann nur von Kontoadministratoren (Benutzer mit der Rolle ACCOUNTADMIN) oder von Rollen mit der globalen Berechtigung CREATE INTEGRATION ausgeführt werden.

  • Das GCP-Dienstkonto für Benachrichtigungsintegrationen unterscheidet sich von dem Dienstkonto, das für Speicherintegrationen erstellt wird.

CREATE NOTIFICATION INTEGRATION <integration_name>
  ENABLED = TRUE
  TYPE = QUEUE
  DIRECTION = OUTBOUND
  NOTIFICATION_PROVIDER = GCP_PUBSUB
  GCP_PUBSUB_TOPIC_NAME = '<topic_id>'
Copy

Wobei:

  • integration_name ist der Name der neuen Integration.

  • topic_id ist das Pub/Sub-Thema, an das Snowflake Fehlerbenachrichtigungen sendet. Weitere Informationen dazu finden Sie unter Schritt 1: Erstellen des Pub/Sub-Themas (unter diesem Thema).

Beispiel:

CREATE NOTIFICATION INTEGRATION my_notification_int
  TYPE = QUEUE
  DIRECTION = OUTBOUND
  NOTIFICATION_PROVIDER = GCP_PUBSUB
  ENABLED = true
  GCP_PUBSUB_TOPIC_NAME = 'projects/sdm-prod/topics/mytopic';
Copy

Schritt 4: Gewähren von Snowflake-Zugriff auf das Pub/Sub-Abonnement

  1. Führen Sie den Befehl DESCRIBE INTEGRATION aus, um die Snowflake-Dienstkonto-ID abzurufen:

    DESC NOTIFICATION INTEGRATION <integration_name>;
    
    Copy

    Wobei:

    • integration_name ist der Name der Integration, die Sie in „Schritt 1: Benachrichtigungsintegration in Snowflake erstellen“ erstellt haben.

    Beispiel:

    DESC NOTIFICATION INTEGRATION my_notification_int;
    
    Copy
  2. Notieren Sie den Namen des Dienstkontos in der Spalte GCP_PUBSUB_SERVICE_ACCOUNT, die das folgende Format hat:

    <service_account>@<project_id>.iam.gserviceaccount.com
    
    Copy
  3. Melden Sie sich bei der Google Cloud Platform Console als Projekteditor an.

  4. Wählen Sie im Startseiten-Dashboard die Option Big Data » Pub/Sub » Subscriptions aus.

  5. Wählen Sie das Abonnement aus, das für den Zugriff konfiguriert werden soll.

  6. Klicken Sie oben rechts auf SHOW INFO PANEL. Der Informationsbereich für das Abonnement wird erweitert.

  7. Suchen Sie im Feld Add members nach dem Dienstkontonamen, den Sie sich in Schritt 2 notiert haben.

  8. Wählen Sie in der Dropdown-Liste Select a role die Option Pub/Sub Publisher aus.

  9. Klicken Sie auf die Schaltfläche Add. Der Name des Dienstkontos wird der Dropdown-Liste Pub/Sub Publisher im Informationsbereich hinzugefügt.

Schritt 5: Aktivieren von Fehlerbenachrichtigungen in Aufgaben

Anschließend aktivieren Sie die Fehlerbenachrichtigung entweder in einer eigenständigen Aufgabe oder in einer Stammaufgabe, indem Sie ERROR_INTEGRATION den Namen der Benachrichtigungsintegration zuweisen. Sie können den Parameterwert beim Erstellen einer Aufgabe (mit CREATE TASK) oder später (mit ALTER TASK) festlegen.

Weitere Informationen dazu finden Sie unter Konfigurieren einer Aufgabe zum Senden von Fehlerbenachrichtigungen.