Kategorien:

Systemfunktionen (Systeminformationen)

SYSTEM$CONVERT_PIPES_SQS_TO_SNS

Konvertiert für einen S3-Bucket Pipes, die Amazon SQS (Simple Queue Service)-Benachrichtigungen verwenden, für die Verwendung des Amazon Simple Notification Service (SNS)-Dienstes.

Weitere Informationen dazu finden Sie unter Automatisieren von Snowpipe für Amazon S3.

Syntax

SYSTEM$CONVERT_PIPES_SQS_TO_SNS( '<bucket_name>, '<sns_topic_arn>' )
Copy

Argumente

bucket_name

Name des S3-Buckets.

sns_topic_arn

ARN des Amazon SNS-Themas.

Anforderungen an die Zugriffssteuerung

Nur Kontoadministratoren können diese Funktion ausführen.

Nutzungshinweise

  • Bevor Sie diese Funktion aufrufen, aktualisieren Sie die Zugriffsrichtlinie für Ihr Thema mit den folgenden Berechtigungen:

    • Erlauben Sie dem Snowflake-IAM-Benutzer, die SQS-Warteschlange, die sich in Ihrem Zielkonto befindet, für Ihr Thema zu abonnieren.

    • Erlauben Sie Amazon S3, Ereignisbenachrichtigungen aus Ihrem Bucket im SNS-Thema zu veröffentlichen.

    Eine Anleitung dazu finden Sie untern Schritt 1: Snowflake-SQS-Warteschlange zum SNS-Thema abonnieren.

  • Rufen Sie diese Funktion auf, bevor Sie Ihren S3-Bucket aktualisieren, um Benachrichtigungen an das SNS-Thema zu senden.

  • Um Datenverluste zu vermeiden, wird Snowpipe weiterhin Meldungen aus der SQS-Warteschlange verarbeiten.

  • Der S3-Bucket und das SNS-Thema müssen sich in der gleichen AWS-Region befinden.

Beispiele

Konvertieren aller Benachrichtigungen aus dem Bucket my_s3_bucket:

SELECT SYSTEM$CONVERT_PIPES_SQS_TO_SNS(
   'my_s3_bucket', 'arn:aws:sns:us-east-2:111122223333:sns_topic');
Copy