Я создал SNS topi c, событие в S3 и создание Snowpipe успешно завершено. Но когда я загружаю новый файл в AWS S3, моя снежная труба не срабатывает автоматически. Я полагаю, что мой SNS не передает события. Есть ли зависимость для создания этих предметов, например, snowpipe, sns topi c и события в S3?
Ниже приведен код для Snowpipe:
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" } ] }