Catégories :: Fonctions système (Informations système)

SYSTEM$CONVERT_PIPES_SQS_TO_SNS¶

Convertissez les canaux à l’aide des notifications Amazon SQS (Simple Queue Service) vers le service Amazon Simple Notification Service (SNS) pour un compartiment S3.

Pour plus d’informations, consultez Automatisation de Snowpipe pour Amazon S3.

Syntaxe¶

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

Copy

Arguments¶

bucket_name: Nom du compartiment S3.
sns_topic_arn: ARN du sujet Amazon SNS.

Exigences en matière de contrôle d’accès¶

Seuls les administrateurs de compte peuvent exécuter cette fonction.

Notes sur l’utilisation¶

Avant d’appeler cette fonction, mettez à jour la politique d’accès pour votre sujet avec les autorisations suivantes :
- Autorisez l’utilisateur de Snowflake IAM à abonner la file d’attente SQS qui se trouve dans votre compte cible à votre rubrique.
- Autorisez Amazon S3 à publier les notifications d’événements de votre compartiment dans la rubrique SNS.
Pour obtenir des instructions, voir Étape 1 : Abonner la file d’attente SQS Snowflake à la rubrique SNS.
Exécutez cette fonction avant de mettre à jour votre compartiment S3 pour envoyer des notifications au sujet SNS.
Pour éviter toute perte de données, Snowpipe continuera à consommer les messages de la file d’attente SQS.
Le compartiment S3 et le sujet SNS doivent se trouver dans la même région AWS.

Exemples¶

Convertissez toutes les notifications du compartiment my_s3_bucket :

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

Copy