类别:

系统函数 (系统信息)

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

实参

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');
Copy
语言: 中文