As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.
# Inscrevendo AWS Event Fork Pipelines em um tópico do Amazon SNS
Para acelerar o desenvolvimento de seus aplicativos orientados a eventos, você pode inscrever pipelines de tratamento de eventos — desenvolvidos pelo AWS Event Fork Pipelines — em tópicos do Amazon SNS. AWS O Event Fork Pipelines é um conjunto de [aplicativos aninhados](https://docs.aws.amazon.com/serverless-application-model/latest/developerguide/serverless-sam-template-nested-applications.html) de código aberto, baseado no [AWS Serverless Application Model](https://aws.amazon.com/serverless/sam/) (AWS SAM), que você pode implantar diretamente do [pacote AWS Event Fork Pipelines](https://serverlessrepo.aws.amazon.com/applications?query=aws-event-fork-pipelines) (escolha **Mostrar aplicativos que criam funções personalizadas do IAM** ou políticas de recursos) em sua conta. AWS Para obter mais informações, consulte [Como funciona o AWS Event Fork Pipelines](sns-fork-pipeline-as-subscriber.md#how-sns-fork-works).
Esta seção mostra como você pode usar o Console de gerenciamento da AWS para implantar um pipeline e depois inscrever o AWS Event Fork Pipelines em um tópico do Amazon SNS. Antes de começar, [crie um tópico do Amazon SNS](sns-create-topic.md).
Para excluir os recursos que compõem um pipeline, localize o pipeline na página **Aplicativos** do AWS Lambda console, expanda a **seção de modelos do SAM**, escolha **CloudFormationpilha** e, em seguida, escolha **Outras ações**, **Excluir** pilha.
# Implantar e inscrever o pipeline de armazenamento e backup de eventos para o Amazon SNS
| |
| --- |
| Para arquivamento e análise de eventos, o Amazon SNS agora recomenda o uso de sua integração nativa com o Amazon Data Firehose. Você pode inscrever streams de entrega do Firehose em tópicos do SNS, o que permite enviar notificações para endpoints de arquivamento e análise, como buckets do Amazon Simple Storage Service (Amazon S3), tabelas do Amazon Redshift, Amazon Service (Service) e muito mais. OpenSearch OpenSearch Usar o Amazon SNS com os streams de entrega do Firehose é uma solução totalmente gerenciada e sem código que não exige o uso de funções. AWS Lambda Para obter mais informações, consulte [Fanout de fluxos de entrega do Firehose](sns-firehose-as-subscriber.md). |
Este tutorial mostra como implantar o [pipeline de armazenamento e backup de eventos](sns-fork-pipeline-as-subscriber.md#sns-fork-event-storage-and-backup-pipeline) e inscrevê-lo em um tópico do Amazon SNS. Esse processo transforma automaticamente o AWS SAM modelo associado ao pipeline em uma CloudFormation pilha e, em seguida, implanta a pilha na sua. Conta da AWS Esse processo também cria e configura o conjunto de recursos que compõe o pipeline de armazenamento e backup de eventos, incluindo o seguinte:
+ Fila do Amazon SQS
+ Função do Lambda
+ Fluxo de entrega do Firehose
+ Bucket de backup do Amazon S3
Para obter mais informações sobre como configurar um fluxo com um bucket do Amazon S3 como destino, consulte `[S3DestinationConfiguration](https://docs.aws.amazon.com/firehose/latest/APIReference/API_S3DestinationConfiguration.html)` na *Referência de API do Amazon Data Firehose*.
Para obter mais informações sobre como transformar eventos e configurar o armazenamento em buffer, a compactação e a criptografia de eventos, consulte [Criar um fluxo de entrega](https://docs.aws.amazon.com/firehose/latest/dev/basic-create.html) no *Guia do desenvolvedor do Amazon Data Firehose*.
Para obter mais informações sobre como filtrar eventos, consulte [Políticas de filtro de assinatura do Amazon SNS](sns-subscription-filter-policies.md) neste guia.
1. Faça login no [console do AWS Lambda](https://console.aws.amazon.com/lambda/).
1. No painel de navegação, escolha **Functions (Funções)** e selecione **Create function (Criar função)**.
1. Na página **Create function (Criar função)**, faça o seguinte:
1. Escolha **Browse serverless app repository** (Procurar no repositório de aplicações sem servidor), **Public applications** (Aplicações públicas), **Show apps that create custom IAM roles or resource policies** (Mostrar aplicações que criam funções do IAM ou políticas de recursos).
1. Procure `fork-event-storage-backup-pipeline` e escolha o aplicativo.
1. Na página **fork-event-storage-backup-pipeline**, faça o seguinte:
1. Na seção **Application settings (Configurações do aplicativo)**, insira um **Application name (Nome de aplicativo)** (por exemplo, `my-app-backup`).
**nota**
Para cada implantação, o nome do aplicativo deve ser exclusivo. Se você reutilizar o nome de um aplicativo, a implantação atualizará somente a CloudFormation pilha implantada anteriormente (em vez de criar uma nova).
1. (Opcional) Para **BucketArn**, insira o ARN do bucket do Amazon S3 no qual os eventos recebidos são carregados. Se você não inserir um valor, um novo bucket do Amazon S3 será criado em sua AWS conta.
1. (Opcional) Para **DataTransformationFunctionArn**, insira o ARN da função Lambda por meio da qual os eventos recebidos são transformados. Se você não inserir um valor, a transformação de dados será desativada.
1. (Opcional) Insira uma das seguintes **LogLevel**configurações para a execução da função Lambda do seu aplicativo:
+ `DEBUG`
+ `ERROR`
+ `INFO` (padrão)
+ `WARNING`
1. Para **TopicArn**, insira o ARN do tópico do Amazon SNS no qual essa instância do fork pipeline deve ser assinada.
1. (Opcional) **StreamBufferingSizeInMBs**Em **StreamBufferingIntervalInSeconds**e, insira os valores para configurar o armazenamento em buffer de eventos recebidos. Se nenhum valor for inserido, são usados 300 segundos e 5 MB.
1. (Opcional) Insira uma das seguintes **StreamCompressionFormat**configurações para compactar eventos recebidos:
+ `GZIP`
+ `SNAPPY`
+ `UNCOMPRESSED` (padrão)
+ `ZIP`
1. (Opcional) Para **StreamPrefix**, insira o prefixo da string para nomear os arquivos armazenados no bucket de backup do Amazon S3. Se você não inserir um valor, nenhum prefixo será usado.
1. (Opcional) Para **SubscriptionFilterPolicy**, insira a política de filtro de assinatura do Amazon SNS, no formato JSON, a ser usada para filtrar eventos recebidos. A política de filtro decide quais eventos são indexados no índice OpenSearch de serviços. Se nenhum valor for inserido, nenhuma filtragem será usada (todos os eventos serão indexados).
1. (Opcional) Para **SubscriptionFilterPolicyScope**, insira a string `MessageBody` ou habilite `MessageAttributes` a filtragem de mensagens baseada em carga ou atributo.
1. Escolha **I acknowledge that this app creates custom IAM roles, resource policies and deploys nested applications. (Eu reconheço que este aplicativo cria funções personalizadas do IAM, políticas de recursos e implanta aplicativos aninhados.)** e selecione **Deploy (Implantar)**.
Na *my-app* página **Status de implantação para**, o Lambda exibe o status **Seu aplicativo está sendo implantado**.
Na seção **Recursos**, CloudFormation começa a criar a pilha e exibe o status **CREATE\$1IN\$1PROGRESS** de cada recurso. Quando o processo estiver concluído, CloudFormation exibirá o status **CREATE\$1COMPLETE**.
Quando a implantação for concluída, o Lambda exibirá o status **Your application has been deployed** (Sua aplicação foi implantada).
As mensagens publicadas em seu tópico do Amazon SNS são armazenadas no bucket de backup do Amazon S3 provisionado pelo pipeline de armazenamento e backup de eventos automaticamente.
# Implantar e inscrever o pipeline de pesquisa e análise de eventos para o Amazon SNS
| |
| --- |
| Para arquivamento e análise de eventos, o Amazon SNS agora recomenda o uso de sua integração nativa com o Amazon Data Firehose. Você pode inscrever streams de entrega do Firehose em tópicos do SNS, o que permite enviar notificações para endpoints de arquivamento e análise, como buckets do Amazon Simple Storage Service (Amazon S3), tabelas do Amazon Redshift, Amazon Service (Service) e muito mais. OpenSearch OpenSearch Usar o Amazon SNS com os streams de entrega do Firehose é uma solução totalmente gerenciada e sem código que não exige o uso de funções. AWS Lambda Para obter mais informações, consulte [Fanout de fluxos de entrega do Firehose](sns-firehose-as-subscriber.md). |
Esta página mostra como implantar o [pipeline de pesquisa e análise de eventos](sns-fork-pipeline-as-subscriber.md#sns-fork-event-search-and-analytics-pipeline) e inscrevê-lo em um tópico do Amazon SNS. Esse processo transforma automaticamente o AWS SAM modelo associado ao pipeline em uma CloudFormation pilha e, em seguida, implanta a pilha na sua. Conta da AWS Esse processo também cria e configura o conjunto de recursos que compõe o pipeline de pesquisa e análise de eventos, incluindo o seguinte:
+ Fila do Amazon SQS
+ Função do Lambda
+ Fluxo de entrega do Firehose
+ Domínio do Amazon OpenSearch Service
+ Bucket de mensagens mortas do Amazon S3
Para obter mais informações sobre como configurar um fluxo com um índice como um destino, consulte `[ElasticsearchDestinationConfiguration](https://docs.aws.amazon.com/firehose/latest/APIReference/API_ElasticsearchDestinationConfiguration.html)` na *Referência de API do Amazon Data Firehose*.
Para obter mais informações sobre como transformar eventos e configurar o armazenamento em buffer, a compactação e a criptografia de eventos, consulte [Criar um fluxo de entrega](https://docs.aws.amazon.com/firehose/latest/dev/basic-create.html) no *Guia do desenvolvedor do Amazon Data Firehose*.
Para obter mais informações sobre como filtrar eventos, consulte [Políticas de filtro de assinatura do Amazon SNS](sns-subscription-filter-policies.md) neste guia.
1. Faça login no [console do AWS Lambda](https://console.aws.amazon.com/lambda/).
1. No painel de navegação, escolha **Functions (Funções)** e selecione **Create function (Criar função)**.
1. Na página **Create function (Criar função)**, faça o seguinte:
1. Escolha **Browse serverless app repository** (Procurar no repositório de aplicações sem servidor), **Public applications** (Aplicações públicas), **Show apps that create custom IAM roles or resource policies** (Mostrar aplicações que criam funções do IAM ou políticas de recursos).
1. Procure `fork-event-search-analytics-pipeline` e escolha o aplicativo.
1. Na página **fork-event-search-analytics-pipeline**, faça o seguinte:
1. Na seção **Application settings (Configurações do aplicativo)**, insira um **Application name (Nome de aplicativo)** (por exemplo, `my-app-search`).
**nota**
Para cada implantação, o nome do aplicativo deve ser exclusivo. Se você reutilizar o nome de um aplicativo, a implantação atualizará somente a CloudFormation pilha implantada anteriormente (em vez de criar uma nova).
1. (Opcional) Para **DataTransformationFunctionArn**, insira o ARN da função Lambda usada para transformar eventos recebidos. Se você não inserir um valor, a transformação de dados será desativada.
1. (Opcional) Insira uma das seguintes **LogLevel**configurações para a execução da função Lambda do seu aplicativo:
+ `DEBUG`
+ `ERROR`
+ `INFO` (padrão)
+ `WARNING`
1. (Opcional) Em **SearchDomainArn**, insira o ARN do domínio de OpenSearch serviço, um cluster que configura a funcionalidade necessária de computação e armazenamento. Se você não inserir um valor, um novo domínio será criado com a configuração padrão.
1. Para **TopicArn**, insira o ARN do tópico do Amazon SNS no qual essa instância do fork pipeline deve ser assinada.
1. Para **SearchIndexName**, insira o nome do índice de OpenSearch serviços para pesquisa e análise de eventos.
**nota**
As seguintes cotas se aplicam a nomes de índice:
Não é possível incluir letras maiúsculas
Não é possível incluir os seguintes caracteres: `\ / * ? " < > | ` , #`
Não é possível começar com os seguintes caracteres: `- + _`
Não podem ser o seguinte: `. ..`
Não podem ter mais que 80 caracteres
Não podem ter mais que 255 bytes
Não é possível conter dois pontos (do OpenSearch Serviço 7.0)
1. (Opcional) Insira uma das seguintes **SearchIndexRotationPeriod**configurações para o período de rotação do índice de OpenSearch serviços:
+ `NoRotation` (padrão)
+ `OneDay`
+ `OneHour`
+ `OneMonth`
+ `OneWeek`
A rotação de índice anexa um timestamp ao nome do índice, facilitando a expiração de dados antigos.
1. Para **SearchTypeName**, insira o nome do tipo de OpenSearch serviço para organizar os eventos em um índice.
**nota**
OpenSearch Os nomes dos tipos de serviço podem conter qualquer caractere (exceto bytes nulos), mas não podem começar com `_` eles.
Para o OpenSearch Service 6.x, só pode haver um tipo por índice. Se você especificar um novo tipo para um índice existente que já tem outro tipo, o Firehose retornará um erro runtime.
1. (Opcional) **StreamBufferingSizeInMBs**Em **StreamBufferingIntervalInSeconds**e, insira os valores para configurar o armazenamento em buffer de eventos recebidos. Se nenhum valor for inserido, são usados 300 segundos e 5 MB.
1. (Opcional) Insira uma das seguintes **StreamCompressionFormat**configurações para compactar eventos recebidos:
+ `GZIP`
+ `SNAPPY`
+ `UNCOMPRESSED` (padrão)
+ `ZIP`
1. (Opcional) Para **StreamPrefix**, insira o prefixo da string para nomear os arquivos armazenados no bucket de cartas mortas do Amazon S3. Se você não inserir um valor, nenhum prefixo será usado.
1. (Opcional) Para **StreamRetryDurationInSecons**, insira a duração da nova tentativa para casos em que o Firehose não consegue indexar eventos OpenSearch no índice de serviços. Se você não inserir um valor, será usado 300 segundos.
1. (Opcional) Para **SubscriptionFilterPolicy**, insira a política de filtro de assinatura do Amazon SNS, no formato JSON, a ser usada para filtrar eventos recebidos. A política de filtro decide quais eventos são indexados no índice OpenSearch de serviços. Se nenhum valor for inserido, nenhuma filtragem será usada (todos os eventos serão indexados).
1. Escolha **I acknowledge that this app creates custom IAM roles, resource policies and deploys nested applications. (Eu reconheço que este aplicativo cria funções personalizadas do IAM, políticas de recursos e implanta aplicativos aninhados.)** e selecione **Deploy (Implantar)**.
Na *my-app-search* página **Status de implantação para**, o Lambda exibe o status **Seu aplicativo está sendo implantado**.
Na seção **Recursos**, CloudFormation começa a criar a pilha e exibe o status **CREATE\$1IN\$1PROGRESS** de cada recurso. Quando o processo estiver concluído, CloudFormation exibirá o status **CREATE\$1COMPLETE**.
Quando a implantação for concluída, o Lambda exibirá o status **Your application has been deployed** (Sua aplicação foi implantada).
As mensagens publicadas em seu tópico do Amazon SNS são indexadas automaticamente no índice de OpenSearch serviços provisionado pelo pipeline de pesquisa e análise de eventos. Se o pipeline não puder indexar um evento, ele armazenará em um bucket de mensagens não entregues do Amazon S3.
# Implantação do Event Replay Pipeline com a integração do Amazon SNS
Esta página mostra como implantar o [pipeline de repetição de eventos](sns-fork-pipeline-as-subscriber.md#sns-fork-event-replay-pipeline) e inscrevê-lo em um tópico do Amazon SNS. Esse processo transforma automaticamente o AWS SAM modelo associado ao pipeline em uma CloudFormation pilha e, em seguida, implanta a pilha na sua. Conta da AWS Esse processo também cria e configura o conjunto de recursos que compõe o pipeline de repetição de eventos, incluindo uma fila do Amazon SQS e uma função do Lambda.
Para obter mais informações sobre como filtrar eventos, consulte [Políticas de filtro de assinatura do Amazon SNS](sns-subscription-filter-policies.md) neste guia.
1. Faça login no [console do AWS Lambda](https://console.aws.amazon.com/lambda/).
1. No painel de navegação, escolha **Functions (Funções)** e selecione **Create function (Criar função)**.
1. Na página **Create function (Criar função)**, faça o seguinte:
1. Escolha **Browse serverless app repository** (Procurar no repositório de aplicações sem servidor), **Public applications** (Aplicações públicas), **Show apps that create custom IAM roles or resource policies** (Mostrar aplicações que criam funções do IAM ou políticas de recursos).
1. Procure `fork-event-replay-pipeline` e escolha o aplicativo.
1. Na página **fork-event-replay-pipeline**, faça o seguinte:
1. Na seção **Application settings (Configurações do aplicativo)**, insira um **Application name (Nome de aplicativo)** (por exemplo, `my-app-replay`).
**nota**
Para cada implantação, o nome do aplicativo deve ser exclusivo. Se você reutilizar o nome de um aplicativo, a implantação atualizará somente a CloudFormation pilha implantada anteriormente (em vez de criar uma nova).
1. (Opcional) Insira uma das seguintes **LogLevel**configurações para a execução da função Lambda do seu aplicativo:
+ `DEBUG`
+ `ERROR`
+ `INFO` (padrão)
+ `WARNING`
1. (Opcional) Para **ReplayQueueRetentionPeriodInSeconds**, insira o tempo, em segundos, durante o qual a fila de repetição do Amazon SQS mantém a mensagem. Se você não inserir um valor, será usado 1.209.600 segundos (14 dias).
1. Para **TopicArn**, insira o ARN do tópico do Amazon SNS no qual essa instância do fork pipeline deve ser assinada.
1. Para **DestinationQueueName**, insira o nome da fila do Amazon SQS para a qual a função de reprodução do Lambda encaminha as mensagens.
1. (Opcional) Para **SubscriptionFilterPolicy**, insira a política de filtro de assinatura do Amazon SNS, no formato JSON, a ser usada para filtrar eventos recebidos. A política de filtro decide quais eventos serão armazenados em buffer para repetição. Se nenhum valor for inserido, nenhuma filtragem será usada (todos os eventos serão armazenados em buffer).
1. Escolha **I acknowledge that this app creates custom IAM roles, resource policies and deploys nested applications. (Eu reconheço que este aplicativo cria funções personalizadas do IAM, políticas de recursos e implanta aplicativos aninhados.)** e selecione **Deploy (Implantar)**.
Na *my-app-replay* página **Status de implantação para**, o Lambda exibe o status **Seu aplicativo está sendo implantado**.
Na seção **Recursos**, CloudFormation começa a criar a pilha e exibe o status **CREATE\$1IN\$1PROGRESS** de cada recurso. Quando o processo estiver concluído, CloudFormation exibirá o status **CREATE\$1COMPLETE**.
Quando a implantação for concluída, o Lambda exibirá o status **Your application has been deployed** (Sua aplicação foi implantada).
As mensagens publicadas em seu tópico do Amazon SNS são armazenadas em buffer para repetição na fila do Amazon SQS provisionada pelo pipeline de repetição de eventos automaticamente.
**nota**
Por padrão, a repetição está desabilitada. Para habilitar a repetição, navegue até a página da função no console do Lambda, expanda a seção **Designer**, escolha o bloco **SQS** e, na seção **SQS**, escolha **Enabled** (Habilitado).