Categories:

System functions (System Information)

SYSTEM$CONVERT_PIPES_SQS_TO_SNS

将使用 Amazon SQS (Simple Queue Service) 通知的管道转换为适用于 S3 桶的 Amazon Simple Notification Service (SNS) 服务。

For more information, see Automating Snowpipe for Amazon S3.

语法

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

实参

bucket_name

S3 桶的名称。

sns_topic_arn

Amazon SNS 主题的 ARN。

访问控制要求

只有账户管理员才能执行此函数。

使用说明

  • 在调用此函数之前，请使用以下权限更新主题的访问策略：

    • Allow the Snowflake IAM user to subscribe the SQS queue that is in your target account to your topic.
    • 允许 Amazon S3 将事件通知从桶发布到 SNS 主题。

    For instructions, see Step 1: Subscribe the Snowflake SQS Queue to the SNS Topic.

  • 在更新 S3 桶 之前 调用此函数，以向 SNS 主题发送通知。

  • 为了防止任何数据丢失，Snowpipe 将继续使用 SQS 队列中的消息。

  • S3 桶和 SNS 主题必须位于同一 AWS 区域。

示例

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');