时间戳

首页 > 解决方案 > 在 S3 中上传新文件时，Snowpipe 未触发

amazon-s3 - 在 S3 中上传新文件时，Snowpipe 未触发

问题描述

我已经创建了 SNS 主题、S3 中的事件和 Snowpipe 创建已成功完成。但是当我在 AWS S3 中上传任何新文件时，我的雪管不会自动触发。我猜我的 SNS 没有处理事件触发。在 S3 中创建这些项目，即雪管、sns 主题和事件是否有任何依赖关系？

下面是雪管的代码：

Create or Replace pipe ALTIMUS_BILL_pipe auto_ingest=true aws_sns_topic='arn:aws:sns:ap-south-1:123456654321:snowpipe_sns_test' as copy into src.tbl_ALTIMUS_BILL from @my_stage_tbl_ALTIMUS_BILL;

以下是我在 SNS 中使用的策略

{.., "Statement": [{"Sid": "__default_statement_ID","Effect": "Allow", "Principal": {"AWS": ""}, "Action": [ "SNS:Publish", ... ], "Resource": "arn:aws:sns:XXX:snowpipe_sns_test", "Condition": {"StringEquals": {"AWS:SourceOwner": "XXX"}} }, { "Sid": "__console_pub_0", "Effect": "Allow", "Principal": { "AWS": "" }, "Action": "SNS:Publish", "Resource": "arn:aws:sns:XXX:snowpipe_sns_test" }, { "Sid": "__console_sub_0", "Effect": "Allow", "Principal": { "AWS": "*" }, "Action": [ "SNS:Subscribe", "SNS:Receive" ], "Resource": "arn:aws:sns:XXX:snowpipe_sns_test" } ] }

标签： amazon-s3amazon-snssnowflake-task

解决方案

我得到了答案。为了正常工作，在创建所有这些设置时需要遵循一个顺序。首先需要创建 SNS 主题（发布者），然后是 Snowpipe（订阅者），最后需要注册 S3 存储桶事件创建。现在一切就绪，一切对我来说都很好。谢谢...

推荐阅读