Categories:

System Functions (System Information)

SYSTEM$CONVERT_PIPES_SQS_TO_SNS

Convert pipes using Amazon SQS (Simple Queue Service) notifications to the Amazon Simple Notification Service (SNS) service for an S3 bucket.

For more information, see Automating Snowpipe for Amazon S3.

Syntax

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

Arguments

bucket_name

Name of the S3 bucket.

sns_topic_arn

ARN of Amazon SNS topic.

Access Control Requirements

Only account administrators can execute this function.

Usage Notes

  • Execute this function before you update your S3 bucket to send notifications to the SNS topic.

  • To prevent any data loss, Snowpipe will continue to consume messages from the SQS queue.

  • The S3 bucket and SNS topic must be in the same AWS region.

Examples

Convert all notifications from bucket my_s3_bucket:

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