Habilitação de notificações de erro do Snowpipe para o Amazon SNS¶

Etapa 1: Criar um tópico do Amazon SNS¶

Crie um tópico SNS em sua conta AWS para lidar com todas as mensagens de erro. Registre o Amazon Resource Name (ARN) para o tópico SNS.

Para reduzir a latência e evitar cobranças de saída de dados pelo envio de notificações entre regiões, recomendamos criar o tópico SNS na mesma região que sua conta Snowflake.

Para instruções, consulte o tópico Criar um tópico do Amazon SNS na documentação do SNS.

Etapa 2: Criar a política IAM¶

Crie uma política do AWS Identity and Access Management (IAM) que concede permissões para publicar no tópico SNS. A política define as seguintes ações:

• sns:publish

  Publicar no tópico SNS.

1. Faça login no Console de gerenciamento AWS.

2. No painel inicial, escolha Identity & Access Management (IAM):

3. Escolha Account settings no painel de navegação à esquerda.

4. Expanda a lista Security Token Service Regions, encontre a região AWS correspondente à região onde sua conta está localizada e escolha Activate se o status for Inactive.

5. Escolha Policies no painel de navegação à esquerda.

6. Clique em Create Policy.

7. Clique na guia JSON.

8. Adicione um documento de política que defina as ações que podem ser tomadas sobre seu tópico SNS.

   Copie e cole o texto a seguir no editor de políticas:

   {
       "Version": "2012-10-17",
       "Statement": [
         {
            "Effect": "Allow",
            "Action": [
                "sns:Publish"
            ],
            "Resource": "<sns_topic_arn>"
         }
       ]
    }
   

   Copy

   Substitua sns_topic_arn pelo ARN do tópico SNS que você criou em Etapa 1: Criar um tópico do Amazon SNS (neste tópico).

9. Clique em Review policy.

10. Digite o nome da política (por exemplo, snowflake_sns_topic) e uma descrição opcional. Clique em Create policy.

Etapa 3: Criar a função AWS IAM¶

Crie uma função AWS IAM na qual atribuir privilégios sobre o tópico SNS.

1. Faça login no Console de gerenciamento AWS.

2. No painel inicial, escolha Identity & Access Management (IAM):

3. Escolha Roles no painel de navegação à esquerda.

4. Clique no botão Create role.

5. Selecione Another AWS account como o tipo de entidade confiável.

6. No campo Account ID, digite temporariamente sua própria ID de conta AWS.

7. Selecione a opção Require external ID. Esta opção permite que você conceda permissões sobre os recursos de sua conta Amazon (ou seja, SNS) a um terceiro (ou seja, Snowflake).

   Por enquanto, insira uma ID fictícia, como 0000. Mais tarde, você modificará a relação de confiança e substituirá a ID fictícia pela ID externa para o IAM do Snowflake gerado pelo usuário para sua conta. Uma condição na política de confiança para sua função IAM permite que seus usuários do Snowflake assumam a função usando o objeto de integração de notificação que você criará mais tarde.

8. Clique no botão Next.

9. Localize a política que você criou em Etapa 2: Criar a política IAM (neste tópico) e selecione essa política.

10. Clique no botão Next.

11. Digite um nome e descrição para a função e clique no botão Create role.

12. Registre o valor Role ARN localizado na página de resumo de funções. Você especificará esse valor em uma ou mais etapas posteriores.

Etapa 4: Criar a integração de notificação¶

Crie uma integração de notificação usando CREATE NOTIFICATION INTEGRATION. Uma integração é um objeto Snowflake que faz referência ao tópico SNS que você criou.

Uma única integração de notificação pode oferecer suporte a múltiplas tarefas e canais.

CREATE NOTIFICATION INTEGRATION <integration_name>
  ENABLED = true
  TYPE = QUEUE
  NOTIFICATION_PROVIDER = AWS_SNS
  DIRECTION = OUTBOUND
  AWS_SNS_TOPIC_ARN = '<topic_arn>'
  AWS_SNS_ROLE_ARN = '<iam_role_arn>'

onde:

<nome_integração>

Nome da nova integração.

DIRECTION = OUTBOUND

Direção das mensagem em nuvem em relação ao Snowflake. Necessário somente ao configurar notificações de erro.

<arn_tópico>

ARN do tópico SNS que você registrou em Etapa 1: Criar um tópico do Amazon SNS (neste tópico).

<arn_função_iam>

A função IAM ARN que você registrou em Etapa 3: Criar a função AWS IAM (neste tópico).

Por exemplo:

CREATE NOTIFICATION INTEGRATION my_notification_int
  ENABLED = true
  TYPE = QUEUE
  NOTIFICATION_PROVIDER = AWS_SNS
  DIRECTION = OUTBOUND
  AWS_SNS_TOPIC_ARN = 'arn:aws:sns:us-east-2:111122223333:sns_topic'
  AWS_SNS_ROLE_ARN = 'arn:aws:iam::111122223333:role/error_sns_role';

Etapa 5: Conceder acesso do Snowflake ao tópico SNS¶

Etapa 6: Habilitar notificações de erro em canais¶

Uma única integração de notificação pode ser compartilhada por vários canais. O corpo das mensagens de erro identifica o canal, o caminho e o estágio externo, o arquivo onde o erro se originou, entre outros detalhes.

Para permitir notificações de erro de um canal, especifique um valor de parâmetro ERROR_INTEGRATION.

Observe que operar em qualquer objeto de um esquema também requer o privilégio USAGE no banco de dados e esquema principais.

Para instruções sobre como criar uma função personalizada com um conjunto específico de privilégios, consulte Criação de funções personalizadas.

Para informações gerais sobre concessões de funções e privilégios para executar ações de SQL em objetos protegíveis, consulte Visão geral do controle de acesso.

CREATE PIPE <name>
  [ AUTO_INGEST = TRUE | FALSE  ]
  ERROR_INTEGRATION = <integration_name>
  AS <copy_statement>

CREATE PIPE mypipe
  AUTO_INGEST = TRUE
  ERROR_INTEGRATION = my_notification_int
  AS
  COPY INTO mydb.public.mytable
  FROM @mydb.public.mystage;

ALTER PIPE <name> SET ERROR_INTEGRATION = <integration_name>;

ALTER PIPE mypipe SET ERROR_INTEGRATION = my_notification_int;