- 类别:
系统函数 (系统信息)
SYSTEM$CONVERT_PIPES_SQS_TO_SNS¶
将使用 Amazon SQS (Simple Queue Service) 通知的管道转换为适用于 S3 桶的 Amazon Simple Notification Service (SNS) 服务。
有关更多信息,请参阅 针对 Amazon S3 自动执行 Snowpipe。
语法¶
SYSTEM$CONVERT_PIPES_SQS_TO_SNS( '<bucket_name>, '<sns_topic_arn>' )
实参¶
bucket_name
S3 桶的名称。
sns_topic_arn
Amazon SNS 主题的 ARN。
访问控制要求¶
只有账户管理员才能执行此函数。
使用说明¶
在调用此函数之前,请使用以下权限更新主题的访问策略:
允许 Snowflake IAM 用户订阅您主题的 目标 账户中的 SQS 队列。
允许 Amazon S3 将事件通知从桶发布到 SNS 主题。
有关说明,请参阅 第 1 步:将 Snowflake SQS 队列订阅至 SNS 主题。
在更新 S3 桶 之前 调用此函数,以向 SNS 主题发送通知。
为了防止任何数据丢失,Snowpipe 将继续使用 SQS 队列中的消息。
S3 桶和 SNS 主题必须位于同一 AWS 区域。
示例¶
转换桶 my_s3_bucket
中的所有通知:
SELECT SYSTEM$CONVERT_PIPES_SQS_TO_SNS(
'my_s3_bucket', 'arn:aws:sns:us-east-2:111122223333:sns_topic');