Categorias:

Funções do sistema (Informações do sistema)

SYSTEM$CONVERT_PIPES_SQS_TO_SNS

Converta canais usando notificações do Amazon SQS (Simple Queue Service) para o serviço Amazon Simple Notification Service (SNS) para um bucket S3.

Para obter mais informações, consulte Automação do Snowpipe para Amazon S3.

Sintaxe

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

Argumentos

bucket_name

Nome do bucket S3.

sns_topic_arn

ARN do tópico Amazon SNS.

Requisitos de controle de acesso

Somente administradores de conta podem executar esta função.

Notas de uso

  • Antes de chamar esta função, atualize a política de acesso do seu tópico com as seguintes permissões:

    • Permita que o usuário Snowflake IAM inscreva a fila SQS que está em sua conta de destino para seu tópico.

    • Permita que o Amazon S3 publique notificações de eventos do seu bucket no tópico do SNS.

    Para obter instruções, consulte Etapa 1: Inscreva a fila SQS do Snowflake no tópico do SNS.

  • Chame esta função antes de atualizar seu bucket S3 para enviar notificações para o tópico SNS.

  • Para evitar qualquer perda de dados, o Snowpipe continuará consumindo mensagens da fila SQS.

  • O bucket S3 e o tópico SNS devem estar na mesma região AWS.

Exemplos

Converta todas as notificações do bucket my_s3_bucket:

SELECT SYSTEM$CONVERT_PIPES_SQS_TO_SNS(
   'my_s3_bucket', 'arn:aws:sns:us-east-2:111122223333:sns_topic');
Copy