# Tutorial: usar o AWS Lambda com o Amazon Simple Notification Service Neste tutorial, você usa uma função do Lambda em uma Conta da AWS para assinar um tópico do Amazon Simple Notification Service (Amazon SNS) em uma Conta da AWS separada. Quando você publica mensagens em seu tópico do Amazon SNS, sua função do Lambda lê o conteúdo da mensagem e a envia para o Amazon CloudWatch Logs. Para concluir este tutorial, use o AWS Command Line Interface (AWS CLI). ![\[\]](http://docs.aws.amazon.com/pt_br/lambda/latest/dg/images/services-sns-tutorial/sns_tut_resources.png) Para concluir este tutorial, execute as seguintes etapas: + Na **conta A**, crie um tópico do Amazon SNS. + Na **conta B**, crie uma função do Lambda que leia as mensagens do tópico. + Na **conta B**, crie uma assinatura para o tópico. + Publique mensagens para o tópico do Amazon SNS na **conta A** e confirme se a função do Lambda na **conta B** os envia para o CloudWatch Logs. Ao concluir essas etapas, você aprenderá a configurar um tópico do Amazon SNS para invocar uma função do Lambda. Você também aprenderá como criar uma política do AWS Identity and Access Management (IAM) que dá permissão para um recurso em outra Conta da AWS para invocar o Lambda. No tutorial, você usa duas Contas da AWS separadas. Os comandos da AWS CLI ilustram isso usando dois perfis nomeados `accountA` e `accountB`, cada um configurado para uso com uma Conta da AWS.diferente. Para saber como configurar a AWS CLI para usar perfis diferentes, consulte [Configurações de arquivos de configuração e credenciais](https://docs.aws.amazon.com/cli/latest/userguide/cli-configure-files.html) no *Guia do usuário da AWS Command Line Interface para a versão 2*. Certifique-se de configurar o mesmo padrão de Região da AWS para ambos os perfis. Se os perfis da AWS CLI criados para as duas Contas da AWS usarem nomes diferentes, ou se você usa o perfil padrão e um perfil nomeado, modifique os comandos da AWS CLI nas seguintes etapas, conforme necessário. ## Pré-requisitos ### Instalar o AWS Command Line Interface Se você ainda não instalou a AWS Command Line Interface, siga as etapas em [Instalar ou atualizar a versão mais recente da AWS CLI](https://docs.aws.amazon.com/cli/latest/userguide/getting-started-install.html) para instalá-la. O tutorial requer um terminal de linha de comando ou um shell para executar os comandos. No Linux e no macOS, use o gerenciador de pacotes e de shell de sua preferência. **nota** No Windows, alguns comandos da CLI do Bash que você costuma usar com o Lambda (como `zip`) não são compatíveis com os terminais integrados do sistema operacional. Para obter uma versão do Ubuntu com o Bash integrada no Windows, [instale o Subsistema do Windows para Linux](https://docs.microsoft.com/en-us/windows/wsl/install-win10). ## Criar um tópico do Amazon SNS (conta A) ![\[\]](http://docs.aws.amazon.com/pt_br/lambda/latest/dg/images/services-sns-tutorial/sns_tut_steps_1.png) **Para criar um tópico do** + Na **conta A**, crie um tópico padrão do Amazon SNS usando o comando da AWS CLI a seguir. ``` aws sns create-topic --name sns-topic-for-lambda --profile accountA ``` Você deve ver saída semelhante ao seguinte: ``` { "TopicArn": "arn:aws:sns:us-west-2:123456789012:sns-topic-for-lambda" } ``` Anote o nome do recurso da Amazon (ARN) do seu tópico. Você precisará dele posteriormente no tutorial ao adicionar permissões à sua função do Lambda para assinar o tópico. ## Criar uma função de execução da função (conta B) ![\[\]](http://docs.aws.amazon.com/pt_br/lambda/latest/dg/images/services-sns-tutorial/sns_tut_steps_2.png) Um perfil de execução é um perfil do IAM que concede a uma função do Lambda permissão para acessar os recursos e Serviços da AWS. Antes de criar sua função na **conta B**, você cria um perfil que dá à função permissões básicas para gravar logs no CloudWatch Logs. Adicionaremos as permissões para ler seu tópico do Amazon SNS em uma etapa posterior. **Para criar uma função de execução** 1. Na **conta B**, abra a [página de perfis](https://console.aws.amazon.com/iam/home#/roles) no console do IAM. 1. Selecione **Criar perfil**. 1. Em **Tipo de entidade confiável**, escolha **Serviços da AWS**. 1. Em **Caso de uso**, escolha **Lambda**. 1. Escolha **Próximo**. 1. Adicione uma política de permissões básica para o perfil ao fazer o seguinte: 1. Na caixa de pesquisa **Políticas de permissões**, insira **AWSLambdaBasicExecutionRole**. 1. Escolha **Próximo**. 1. Finalize a criação do perfil fazendo o seguinte: 1. Em **Detalhes do perfil**, insira **lambda-sns-role** para **Nome do perfil**. 1. Selecione **Criar perfil**. ## Criar uma função Lambda (conta B) ![\[\]](http://docs.aws.amazon.com/pt_br/lambda/latest/dg/images/services-sns-tutorial/sns_tut_steps_3.png) Criar uma função do Lambda que processe suas mensagens do Amazon SNS. O código da função registra o conteúdo da mensagem de cada registro no Amazon CloudWatch Logs. Este tutorial usa o runtime do Node.js 24, mas também fornecemos exemplos de códigos em outras linguagens de runtime. Você pode selecionar a guia na caixa a seguir para ver o código do runtime do seu interesse. O código JavaScript que você usará nesta etapa é o primeiro exemplo mostrado na guia **JavaScript**. ------ #### [ .NET ] **SDK para .NET** Há mais no GitHub. Encontre o exemplo completo e saiba como configurar e executar no repositório dos [Exemplos sem servidor](https://github.com/aws-samples/serverless-snippets/tree/main/integration-sns-to-lambda). Consumir um evento do SNS com o Lambda usando .NET. ``` // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. // SPDX-License-Identifier: Apache-2.0 using Amazon.Lambda.Core; using Amazon.Lambda.SNSEvents; // Assembly attribute to enable the Lambda function's JSON input to be converted into a .NET class. [assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))] namespace SnsIntegration; public class Function { public async Task FunctionHandler(SNSEvent evnt, ILambdaContext context) { foreach (var record in evnt.Records) { await ProcessRecordAsync(record, context); } context.Logger.LogInformation("done"); } private async Task ProcessRecordAsync(SNSEvent.SNSRecord record, ILambdaContext context) { try { context.Logger.LogInformation($"Processed record {record.Sns.Message}"); // TODO: Do interesting work based on the new message await Task.CompletedTask; } catch (Exception e) { //You can use Dead Letter Queue to handle failures. By configuring a Lambda DLQ. context.Logger.LogError($"An error occurred"); throw; } } } ``` ------ #### [ Go ] **SDK para Go V2** Há mais no GitHub. Encontre o exemplo completo e saiba como configurar e executar no repositório dos [Exemplos sem servidor](https://github.com/aws-samples/serverless-snippets/tree/main/integration-sns-to-lambda). Consumir um evento do SNS com o Lambda usando Go. ``` // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. // SPDX-License-Identifier: Apache-2.0 package main import ( "context" "fmt" "github.com/aws/aws-lambda-go/events" "github.com/aws/aws-lambda-go/lambda" ) func handler(ctx context.Context, snsEvent events.SNSEvent) { for _, record := range snsEvent.Records { processMessage(record) } fmt.Println("done") } func processMessage(record events.SNSEventRecord) { message := record.SNS.Message fmt.Printf("Processed message: %s\n", message) // TODO: Process your record here } func main() { lambda.Start(handler) } ``` ------ #### [ Java ] **SDK para Java 2.x** Há mais no GitHub. Encontre o exemplo completo e saiba como configurar e executar no repositório dos [Exemplos sem servidor](https://github.com/aws-samples/serverless-snippets/tree/main/integration-sns-to-lambda). Consumir um evento do SNS com o Lambda usando Java. ``` // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. // SPDX-License-Identifier: Apache-2.0 package example; import com.amazonaws.services.lambda.runtime.Context; import com.amazonaws.services.lambda.runtime.LambdaLogger; import com.amazonaws.services.lambda.runtime.RequestHandler; import com.amazonaws.services.lambda.runtime.events.SNSEvent; import com.amazonaws.services.lambda.runtime.events.SNSEvent.SNSRecord; import java.util.Iterator; import java.util.List; public class SNSEventHandler implements RequestHandler { LambdaLogger logger; @Override public Boolean handleRequest(SNSEvent event, Context context) { logger = context.getLogger(); List records = event.getRecords(); if (!records.isEmpty()) { Iterator recordsIter = records.iterator(); while (recordsIter.hasNext()) { processRecord(recordsIter.next()); } } return Boolean.TRUE; } public void processRecord(SNSRecord record) { try { String message = record.getSNS().getMessage(); logger.log("message: " + message); } catch (Exception e) { throw new RuntimeException(e); } } } ``` ------ #### [ JavaScript ] **SDK para JavaScript (v3)** Há mais no GitHub. Encontre o exemplo completo e saiba como configurar e executar no repositório de [Exemplos sem servidor](https://github.com/aws-samples/serverless-snippets/blob/main/integration-sns-to-lambda). Consumir um evento do SNS com o Lambda usando JavaScript. ``` // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. // SPDX-License-Identifier: Apache-2.0 exports.handler = async (event, context) => { for (const record of event.Records) { await processMessageAsync(record); } console.info("done"); }; async function processMessageAsync(record) { try { const message = JSON.stringify(record.Sns.Message); console.log(`Processed message ${message}`); await Promise.resolve(1); //Placeholder for actual async work } catch (err) { console.error("An error occurred"); throw err; } } ``` Consumir um evento do SNS com o Lambda usando TypeScript. ``` // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. // SPDX-License-Identifier: Apache-2.0 import { SNSEvent, Context, SNSHandler, SNSEventRecord } from "aws-lambda"; export const functionHandler: SNSHandler = async ( event: SNSEvent, context: Context ): Promise => { for (const record of event.Records) { await processMessageAsync(record); } console.info("done"); }; async function processMessageAsync(record: SNSEventRecord): Promise { try { const message: string = JSON.stringify(record.Sns.Message); console.log(`Processed message ${message}`); await Promise.resolve(1); //Placeholder for actual async work } catch (err) { console.error("An error occurred"); throw err; } } ``` ------ #### [ PHP ] **SDK para PHP** Há mais no GitHub. Encontre o exemplo completo e saiba como configurar e executar no repositório dos [Exemplos sem servidor](https://github.com/aws-samples/serverless-snippets/tree/main/integration-sns-to-lambda). Consumir um evento do SNS com o Lambda usando PHP. ``` // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. // SPDX-License-Identifier: Apache-2.0 getRecords() as $record) { $message = $record->getMessage(); // TODO: Implement your custom processing logic here // Any exception thrown will be logged and the invocation will be marked as failed echo "Processed Message: $message" . PHP_EOL; } } } return new Handler(); ``` ------ #### [ Python ] **SDK para Python (Boto3).** Há mais no GitHub. Encontre o exemplo completo e saiba como configurar e executar no repositório dos [Exemplos sem servidor](https://github.com/aws-samples/serverless-snippets/tree/main/integration-sns-to-lambda). Consumir um evento do SNS com o Lambda usando Python. ``` # Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. # SPDX-License-Identifier: Apache-2.0 def lambda_handler(event, context): for record in event['Records']: process_message(record) print("done") def process_message(record): try: message = record['Sns']['Message'] print(f"Processed message {message}") # TODO; Process your record here except Exception as e: print("An error occurred") raise e ``` ------ #### [ Ruby ] **SDK para Ruby** Há mais no GitHub. Encontre o exemplo completo e saiba como configurar e executar no repositório dos [Exemplos sem servidor](https://github.com/aws-samples/serverless-snippets/tree/main/integration-sns-to-lambda). Consumir um evento do SNS com o Lambda usando Ruby. ``` # Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. # SPDX-License-Identifier: Apache-2.0 def lambda_handler(event:, context:) event['Records'].map { |record| process_message(record) } end def process_message(record) message = record['Sns']['Message'] puts("Processing message: #{message}") rescue StandardError => e puts("Error processing message: #{e}") raise end ``` ------ #### [ Rust ] **SDK para Rust** Há mais no GitHub. Encontre o exemplo completo e saiba como configurar e executar no repositório dos [Exemplos sem servidor](https://github.com/aws-samples/serverless-snippets/tree/main/integration-sns-to-lambda). Consuma um evento do SNS com o Lambda usando Rust. ``` // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. // SPDX-License-Identifier: Apache-2.0 use aws_lambda_events::event::sns::SnsEvent; use aws_lambda_events::sns::SnsRecord; use lambda_runtime::{run, service_fn, Error, LambdaEvent}; use tracing::info; // Built with the following dependencies: // aws_lambda_events = { version = "0.10.0", default-features = false, features = ["sns"] } // lambda_runtime = "0.8.1" // tokio = { version = "1", features = ["macros"] } // tracing = { version = "0.1", features = ["log"] } // tracing-subscriber = { version = "0.3", default-features = false, features = ["fmt"] } async fn function_handler(event: LambdaEvent) -> Result<(), Error> { for event in event.payload.records { process_record(&event)?; } Ok(()) } fn process_record(record: &SnsRecord) -> Result<(), Error> { info!("Processing SNS Message: {}", record.sns.message); // Implement your record handling code here. Ok(()) } #[tokio::main] async fn main() -> Result<(), Error> { tracing_subscriber::fmt() .with_max_level(tracing::Level::INFO) .with_target(false) .without_time() .init(); run(service_fn(function_handler)).await } ``` ------ **Para criar a função** 1. Crie um diretório para o projeto e depois mude para esse diretório. ``` mkdir sns-tutorial cd sns-tutorial ``` 1. Copie o código JavaScript de amostra em um novo arquivo denominado `index.js`. 1. Crie um pacote de implantação usando o comando `zip` a seguir. ``` zip function.zip index.js ``` 1. Execute o comando da AWS CLI a seguir para criar sua função do Lambda na **conta B**. ``` aws lambda create-function --function-name Function-With-SNS \ --zip-file fileb://function.zip --handler index.handler --runtime nodejs24.x \ --role arn:aws:iam:::role/lambda-sns-role \ --timeout 60 --profile accountB ``` Você deve ver saída semelhante ao seguinte: ``` { "FunctionName": "Function-With-SNS", "FunctionArn": "arn:aws:lambda:us-west-2:123456789012:function:Function-With-SNS", "Runtime": "nodejs24.x", "Role": "arn:aws:iam::123456789012:role/lambda_basic_role", "Handler": "index.handler", ... "RuntimeVersionConfig": { "RuntimeVersionArn": "arn:aws:lambda:us-west-2::runtime:7d5f06b69c951da8a48b926ce280a9daf2e8bb1a74fc4a2672580c787d608206" } } ``` 1. O nome do recurso da Amazon (ARN) da sua função. Você precisará dele posteriormente no tutorial ao adicionar permissões para permitir que o Amazon SNS invoque sua função. ## Adicionar permissões à função (conta B) ![\[\]](http://docs.aws.amazon.com/pt_br/lambda/latest/dg/images/services-sns-tutorial/sns_tut_steps_4.png) Para que o Amazon SNS invoque a sua função, você precisa conceder permissão em uma declaração de uma [política baseada em recursos](access-control-resource-based.md). Você adiciona essa declaração usando o comando `add-permission` da AWS CLI. **Para conceder permissão ao Amazon SNS para invocar sua função** + Na **conta B**, execute o seguinte comando da AWS CLI usando o ARN para o tópico do Amazon SNS que você gravou anteriormente. ``` aws lambda add-permission --function-name Function-With-SNS \ --source-arn arn:aws:sns:us-east-1::sns-topic-for-lambda \ --statement-id function-with-sns --action "lambda:InvokeFunction" \ --principal sns.amazonaws.com --profile accountB ``` Você deve ver saída semelhante ao seguinte: ``` { "Statement": "{\"Condition\":{\"ArnLike\":{\"AWS:SourceArn\": \"arn:aws:sns:us-east-1::sns-topic-for-lambda\"}}, \"Action\":[\"lambda:InvokeFunction\"], \"Resource\":\"arn:aws:lambda:us-east-1::function:Function-With-SNS\", \"Effect\":\"Allow\",\"Principal\":{\"Service\":\"sns.amazonaws.com\"}, \"Sid\":\"function-with-sns\"}" } ``` **nota** Se a conta com o tópico do Amazon SNS estiver hospedada em uma [Região da AWS de aceitação](https://docs.aws.amazon.com/accounts/latest/reference/manage-acct-regions.html), será necessário especificar a região na entidade principal. Por exemplo, se você estiver trabalhando com um tópico do Amazon SNS na região Ásia-Pacífico (Hong Kong), será necessário especificar `sns.ap-east-1.amazonaws.com` em vez de `sns.amazonaws.com` para a entidade principal. ## Conceder permissão entre contas para assinatura do Amazon SNS (conta A) ![\[\]](http://docs.aws.amazon.com/pt_br/lambda/latest/dg/images/services-sns-tutorial/sns_tut_steps_5.png) Para que a sua função do Lambda na **conta B** assine o tópico do Amazon SNS criado na **conta A**, você precisa conceder permissão para que a **conta B** assine seu tópico. Você concede essa permissão usando o comando `add-permission` da AWS CLI. **Para conceder permissão para a conta B assinar o tópico** + Na **conta A**, execute o comando da AWS CLI a seguir. Use o ARN para o tópico do Amazon SNS que você gravou anteriormente. ``` aws sns add-permission --label lambda-access --aws-account-id \ --topic-arn arn:aws:sns:us-east-1::sns-topic-for-lambda \ --action-name Subscribe ListSubscriptionsByTopic --profile accountA ``` ## Criar uma assinatura (conta B) ![\[\]](http://docs.aws.amazon.com/pt_br/lambda/latest/dg/images/services-sns-tutorial/sns_tut_steps_6.png) Na **conta B**, agora você assina a sua função do Lambda no tópico do Amazon SNS criado no início do tutorial na **conta A**. Quando uma mensagem é enviada para esse tópico (`sns-topic-for-lambda`), o Amazon SNS invoca sua função do Lambda `Function-With-SNS` na **conta B**. **Criar uma assinatura** + Na **conta B**, execute o comando da AWS CLI a seguir. Use sua região padrão na qual você criou seu tópico e os ARNs para seu tópico e função do Lambda. ``` aws sns subscribe --protocol lambda \ --region us-east-1 \ --topic-arn arn:aws:sns:us-east-1::sns-topic-for-lambda \ --notification-endpoint arn:aws:lambda:us-east-1::function:Function-With-SNS \ --profile accountB ``` Você deve ver saída semelhante ao seguinte: ``` { "SubscriptionArn": "arn:aws:sns:us-east-1::sns-topic-for-lambda:5d906xxxx-7c8x-45dx-a9dx-0484e31c98xx" } ``` ## Publicar mensagens no tópico (conta A e conta B) ![\[\]](http://docs.aws.amazon.com/pt_br/lambda/latest/dg/images/services-sns-tutorial/sns_tut_steps_7.png) Agora que a sua função do Lambda na **conta B** está assinada em seu tópico do Amazon SNS na **conta A**, é hora de testar sua configuração publicando mensagens em seu tópico. Para confirmar se o Amazon SNS invocou sua função do Lambda, use o CloudWatch Logs para visualizar a saída da função. **Para publicar uma mensagem em seu tópico e ver a saída da sua função** 1. Insira `Hello World` em um arquivo de texto e salve-o como `message.txt`. 1. No mesmo diretório em que você salvou seu arquivo de texto, execute o comando da AWS CLI a seguir na **conta A**. Use o ARN para seu próprio tópico. ``` aws sns publish --message file://message.txt --subject Test \ --topic-arn arn:aws:sns:us-east-1::sns-topic-for-lambda \ --profile accountA ``` Isso retornará um ID de mensagem com um identificador exclusivo, indicando que a mensagem foi aceita pelo Amazon SNS. Depois, o Amazon SNS tenta enviar a mensagem aos assinantes do tópico. Para confirmar se o Amazon SNS invocou sua função do Lambda, use o CloudWatch Logs para visualizar a saída da função: 1. Na **conta B**, abra a página [Grupos de logs](https://console.aws.amazon.com/cloudwatch/home#logsV2:log-groups) do console do Amazon CloudWatch. 1. Escolha o nome do grupo de logs para sua função (`/aws/lambda/Function-With-SNS`). 1. Escolha o stream de logs mais recente. 1. Se sua função foi invocada corretamente, você verá uma saída semelhante à seguinte, mostrando o conteúdo da mensagem que você publicou no seu tópico. ``` 2023-07-31T21:42:51.250Z c1cba6b8-ade9-4380-aa32-d1a225da0e48 INFO Processed message Hello World 2023-07-31T21:42:51.250Z c1cba6b8-ade9-4380-aa32-d1a225da0e48 INFO done ``` ## Limpe os recursos Agora você pode excluir os recursos criados para este tutorial, a menos que queira mantê-los. Excluindo os recursos da AWS que você não está mais usando, você evita cobranças desnecessárias em sua Conta da AWS. Em **Account A** (Conta A), limpe o tópico do Amazon SNS. **Para excluir o tópico do Amazon SNS** 1. Abra a [página Topics](https://console.aws.amazon.com//sns/home#topics:) (Tópicos) no console do Amazon SNS. 1. Selecione o tópico que você criou. 1. Escolha **Excluir**. 1. Digite **delete me** no campo de entrada de texto. 1. Escolha **Excluir**. Em **Account B** (Conta B), limpe sua função de execução, a função Lambda e a assinatura do Amazon SNS. **Para excluir a função de execução** 1. Abra a página [Roles](https://console.aws.amazon.com/iam/home#/roles) (Funções) no console do IAM. 1. Selecione a função de execução que você criou. 1. Escolha **Excluir**. 1. Insira o nome do perfil no campo de entrada de texto e escolha **Delete** (Excluir). **Como excluir a função do Lambda** 1. Abra a página [Functions](https://console.aws.amazon.com/lambda/home#/functions) (Funções) no console do Lambda. 1. Selecione a função que você criou. 1. Selecione **Ações**, **Excluir**. 1. Digite **confirm** no campo de entrada de texto e escolha **Delete** (Excluir). **Para excluir a inscrição do Amazon SNS** 1. Abrir o[Página Assinaturas](https://console.aws.amazon.com//sns/home#subscriptions:)No console do Amazon SNS. 1. Selecione a assinatura que você criou. 1. Escolha **Delete** (Excluir), **Yes, Delete** (Sim, excluir).