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á.
# Criando um EventBridge cachimbo Amazon
EventBridge O Pipes permite que você crie point-to-point integrações entre fontes e destinos, incluindo enriquecimento e transformações avançadas de eventos.
Para criar uma EventBridge tubulação, você executa as seguintes etapas:
1. [Como especificar uma origem](#pipes-configure-source)
1. [Como configurar a filtragem de eventos (opcional)](#pipes-configure-filtering)
1. [Como definir o enriquecimento do evento (opcional)](#pipes-define-enrichment)
1. [Como configurar um destino](#pipes-configure-target)
1. [Como configurar as definições de pipe](#pipes-configure-pipe-settings)
Para configurar rapidamente um pipe de amostra, consulte [Primeiros passos: Crie um EventBridge canal Amazon](pipes-get-started.md). Este tópico é usado CloudFormation para implantar uma tubulação e seus recursos associados e mostra uma visão geral das capacidades de uma tubulação.
*Para obter informações sobre como criar um pipe usando a AWS CLI, consulte [create-pipe](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/pipes/create-pipe.html) na Referência de Comandos da AWS CLI.*
## Como especificar uma origem
Para começar, especifique a origem da qual deseja que o pipe receba eventos.
**Para especificar uma origem de pipe usando o console**
1. Abra o EventBridge console da Amazon em [https://console.aws.amazon.com/events/](https://console.aws.amazon.com/events/).
1. No painel de navegação, escolha **Pipes**.
1. Escolha **Criar pipe**.
1. Insira um nome para o pipe.
1. (Opcional) Adicione uma descrição para o pipe.
1. Na guia **Criar pipe**, em **Origem**, escolha o tipo de origem que você deseja especificar para esse pipe e configure a origem.
As propriedades de configuração diferem com base no tipo de origem escolhida:
------
#### [ Confluent ]
**Como configurar um fluxo do Confluent Cloud como origem usando o console**
1. Em **Origem**, selecione **Confluent Cloud**.
1. Para **Servidores bootstrap**, insira os endereços de pares `host:port` de seus agentes.
1. Em **Nome do tópico**: insira o nome do tópico do qual o pipe lerá.
1. (Opcional) Em **VPC**, escolha a VPC que deseja. Em seguida, para **sub-redes VPC**, escolha as sub-redes desejadas. Em **Grupos de segurança**, escolha os grupos de segurança.
1. Em **Autenticação: opcional**, ative **Usar autenticação** e faça o seguinte:
1. Em **Método de autenticação**, escolha o tipo de autenticação.
1. Em **Chave secreta**, escolha a chave secreta.
Para obter mais informações, consulte [Authenticate to Confluent Cloud resources](https://docs.confluent.io/cloud/current/access-management/authenticate/overview.html) na documentação da Confluent.
1. (Opcional) Em **Configurações adicionais**, faça o seguinte:
1. Para **Posição inicial**, escolha uma das seguintes opções:
+ **Mais recente**: comece a ler o fluxo com o registro mais recente no fragmento.
+ **Horizonte de corte**: comece a ler o fluxo com o registro mais recente não cortado no fragmento. Este é o registro mais antigo do fragmento.
1. **Em Tamanho do lote: opcional**, insira um número máximo de registros para cada lote. O valor padrão é 100.
1. Em **Janela de lotes: opcional**, insira um número máximo de segundos para coletar registros antes de continuar.
------
#### [ DynamoDB ]
1. Em **Origem**, escolha **DynamoDB**.
1. Para o **fluxo do DynamoDB**, escolha o fluxo que você deseja usar como origem.
1. Para **Posição inicial**, escolha uma das seguintes opções:
+ **Mais recente**: comece a ler o fluxo com o registro mais recente no fragmento.
+ **Horizonte de corte**: comece a ler o fluxo com o registro mais recente não cortado no fragmento. Este é o registro mais antigo do fragmento.
1. (Opcional) Em **Configurações adicionais**, faça o seguinte:
1. **Em Tamanho do lote: opcional**, insira um número máximo de registros para cada lote. O valor padrão é 10.
1. Em **Janela de lotes: opcional**, insira um número máximo de segundos para coletar registros antes de continuar.
1. Em **Lotes simultâneos por fragmento: opcional**, insira o número de lotes do mesmo fragmento que podem ser lidos ao mesmo tempo.
1. Para **Em caso de falha parcial do item do lote**, escolha o seguinte:
+ **AUTOMATIC\_BISECT**: divida cada lote na metade e faça novas tentativas com cada metade até que todos os registros sejam processados ou que reste apenas uma mensagem com falha no lote.
**nota**
Se não escolher **AUTOMATIC\_BISECT**, poderá retornar registros específicos com falha e somente aqueles serão repetidos.
------
#### [ Kinesis ]
**Para configurar uma origem do Kinesis usando o console**
1. Em **Origem**, escolha **Kinesis**.
1. Para o **fluxo do Kinesis**, escolha o fluxo que você deseja usar como origem.
1. Para **Posição inicial**, escolha uma das seguintes opções:
+ **Mais recente**: comece a ler o fluxo com o registro mais recente no fragmento.
+ **Horizonte de corte**: comece a ler o fluxo com o registro mais recente não cortado no fragmento. Este é o registro mais antigo do fragmento.
+ **No timestamp**: comece a ler o fluxo a partir de um horário especificado. Em **Timestamp**, insira os dados e a hora usando o formato YYYY/MM/DD hh:mm:ss.
1. (Opcional) Em **Configurações adicionais**, faça o seguinte:
1. **Em Tamanho do lote: opcional**, insira um número máximo de registros para cada lote. O valor padrão é 10.
1. (Opcional) Para **Janela batch: opcional**, insira um número máximo de segundos para coletar registros antes de continuar.
1. Em **Lotes simultâneos por fragmento: opcional**, insira o número de lotes do mesmo fragmento que podem ser lidos ao mesmo tempo.
1. Para **Em caso de falha parcial do item do lote**, escolha o seguinte:
+ **AUTOMATIC\_BISECT**: divida cada lote na metade e faça novas tentativas com cada metade até que todos os registros sejam processados ou que reste apenas uma mensagem com falha no lote.
**nota**
Se não escolher **AUTOMATIC\_BISECT**, poderá retornar registros específicos com falha e somente aqueles serão repetidos.
------
#### [ Amazon MQ ]
**Para configurar uma origem do Amazon MQ usando o console**
1. Em **Origem**, selecione **Amazon MQ**.
1. Para o **agente do Amazon MQ**, escolha o fluxo que deseja usar como origem.
1. Em **Nome da fila**, insira o nome da fila da qual o pipe lerá.
1. Em **Método de autenticação**, escolha **BASIC\_AUTH**.
1. Em **Chave secreta**, escolha a chave secreta.
1. (Opcional) Em **Configurações adicionais**, faça o seguinte:
1. **Em Tamanho do lote: opcional**, insira um número máximo de mensagens para cada lote. O valor padrão é 100.
1. Em **Janela de lotes: opcional**, insira um número máximo de segundos para coletar registros antes de continuar.
------
#### [ Amazon MSK ]
**Para configurar uma origem do Amazon MSK usando o console**
1. Em **Origem**, selecione **Amazon MSK**.
1. Em **cluster do Amazon MSK**, escolha o cluster que deseja usar.
1. Em **Nome do tópico**: insira o nome do tópico do qual o pipe lerá.
1. (Opcional) Em **ID do grupo de consumidores: opcional**, insira o ID de um grupo de consumidores no qual deseja que o pipe entre.
1. (Opcional) Para **Autenticação: opcional**, ative **Usar Autenticação** e faça o seguinte:
1. Em **Método de autenticação**, escolha o tipo que deseja.
1. Em **Chave secreta**, escolha a chave secreta.
1. (Opcional) Em **Configurações adicionais**, faça o seguinte:
1. **Em Tamanho do lote: opcional**, insira um número máximo de registros para cada lote. O valor padrão é 100.
1. Em **Janela de lotes: opcional**, insira um número máximo de segundos para coletar registros antes de continuar.
1. Para **Posição inicial**, escolha uma das seguintes opções:
+ **Mais recente**: comece a ler o tópico com o registro mais recente no fragmento.
+ **Horizonte de corte**: comece a ler o tópico com o registro mais recente não cortado no fragmento. Este é o registro mais antigo do fragmento.
**nota**
**Horizonte de corte** é o mesmo que **Mais antigo** para Apache Kafka.
------
#### [ Self managed Apache Kafka ]
**Para configurar uma origem autogerenciada do Apache Kafka usando o console**
1. Em **Origem**, escolha **Apache Kafka autogerenciado**.
1. Para **Servidores bootstrap**, insira os endereços de pares `host:port` de seus agentes.
1. Em **Nome do tópico**: insira o nome do tópico do qual o pipe lerá.
1. (Opcional) Em **VPC**, escolha a VPC que deseja. Em seguida, para **sub-redes VPC**, escolha as sub-redes desejadas. Em **Grupos de segurança**, escolha os grupos de segurança.
1. (Opcional) Para **Autenticação: opcional**, ative **Usar Autenticação** e faça o seguinte:
1. Em **Método de autenticação**, escolha o tipo de autenticação.
1. Em **Chave secreta**, escolha a chave secreta.
1. (Opcional) Em **Configurações adicionais**, faça o seguinte:
1. Para **Posição inicial**, escolha uma das seguintes opções:
+ **Mais recente**: comece a ler o fluxo com o registro mais recente no fragmento.
+ **Horizonte de corte**: comece a ler o fluxo com o registro mais recente não cortado no fragmento. Este é o registro mais antigo do fragmento.
1. **Em Tamanho do lote: opcional**, insira um número máximo de registros para cada lote. O valor padrão é 100.
1. Em **Janela de lotes: opcional**, insira um número máximo de segundos para coletar registros antes de continuar.
------
#### [ Amazon SQS ]
**Para configurar uma origem do Amazon SQS usando o console**
1. Em **Origem**, escolha **SQS**.
1. Na **fila SQS**, escolha a fila que você deseja usar.
1. (Opcional) Em **Configurações adicionais**, faça o seguinte:
1. **Em Tamanho do lote: opcional**, insira um número máximo de registros para cada lote. O valor padrão é 100.
1. Em **Janela de lotes: opcional**, insira um número máximo de segundos para coletar registros antes de continuar.
------
## Como configurar a filtragem de eventos (opcional)
É possível adicionar filtragem ao seu pipe para enviar apenas um subconjunto de eventos da sua origem para o destino.
**Para configurar a filtragem usando o console**
1. Escolha **Filtragem**.
1. Em **Exemplo de evento: opcional**, você verá um evento de amostra que pode ser usado para criar seu padrão de evento ou pode inserir seu próprio evento escolhendo **Inserir seu próprio** evento.
1. Em **Padrão do evento**, insira o padrão do evento que deseja usar para filtrar os eventos. Para obter mais informações sobre construção de filtros, consulte [Filtragem de eventos no Amazon Pipes EventBridge](eb-pipes-event-filtering.md).
A seguir, um exemplo de padrão de evento que envia somente eventos com o valor **Seattle** no campo **Cidade**.
```
{
"data": {
"City": ["Seattle"]
}
}
```
Agora que os eventos estão sendo filtrados, é possível adicionar enriquecimento opcional e um destino para o pipe.
## Como definir o enriquecimento do evento (opcional)
Você pode enviar os dados do evento para enriquecimento em uma função Lambda, máquina de estado AWS Step Functions , Amazon API Gateway ou destino de API.
**Para selecionar o enriquecimento**
1. Escolha **Enriquecimento**.
1. Em **Detalhes**, em **Serviço**, selecione o serviço e as configurações relacionadas que deseja usar para enriquecimento.
Também é possível transformar os dados antes de enviá-los para serem aprimorados.
**(Opcional) Para definir o transformador de entrada**
1. Escolha o **Transformador de entrada de enriquecimento: opcional**.
1. Em **Sample events/Event Payload**, escolha o tipo de evento de amostra.
1. Para **Transformer**, insira a sintaxe do transformador, como `"Event happened at <$.detail.field>."` onde `<$.detail.field>` é uma referência a um campo do evento de amostra. Também é possível clicar duas vezes em um campo do evento de amostra para adicioná-lo ao transformador.
1. Em **Saída**, verifique se a saída tem a aparência desejada.
Agora que os dados foram filtrados e aprimorados, é preciso definir um destino para o qual enviar os dados do evento.
## Como configurar um destino
**Para configurar um destino**
1. Selecione **Target**.
1. Em **Detalhes**, para o **Serviço de destino**, escolha o destino. Os campos que são exibidos variam de acordo com o serviço escolhido. Insira as informações específicas desse tipo de destino conforme necessário.
Também é possível transformar os dados antes de enviá-los ao destino.
**(Opcional) Para definir o transformador de entrada**
1. Escolha **Transformador de entrada de destino: opcional**.
1. Em **Sample events/Event Payload**, escolha o tipo de evento de amostra.
1. Para **Transformer**, insira a sintaxe do transformador, como `"Event happened at <$.detail.field>."` onde `<$.detail.field>` é uma referência a um campo do evento de amostra. Também é possível clicar duas vezes em um campo do evento de amostra para adicioná-lo ao transformador.
1. Em **Saída**, verifique se a saída tem a aparência desejada.
Agora que o pipe está configurado, verifique se suas configurações estão definidas corretamente.
## Como configurar as definições de pipe
Um pipe está ativo por padrão, mas você pode desativá-lo. Também é possível especificar as permissões do pipe, configurar o registro em log de pipes e adicionar tags.
**Configurar as definições de pipe**
1. Escolha a guia **Configurações de pipe**.
1. Por padrão, os pipes recém-criados ficam ativos assim que são criados. Se quiser criar um pipe inativo, em **Ativação**, para **Ativar pipe**, desative **Ativo**.
1. Em **Permissões**, para **Perfil de execução**, faça o seguinte:
1. Para EventBridge criar uma nova função de execução para esse canal, escolha **Criar uma nova função para esse recurso específico.** Em **Nome do perfil**, você pode, opcionalmente, editar o nome do perfil.
1. Para um perfil de execução existente, escolha **Usar perfil existente**. Em **Nome do perfil**, escolha o perfil.
1. (Opcional) Se você tiver especificado um DynamoDB stream Kinesis or como fonte de canal, poderá configurar uma política de repetição e uma fila de mensagens mortas (DLQ).
Para **Política de repetição e fila de mensagens não entregues: opcional**, faça o seguinte:
Em **Revisar política**, faça o seguinte:
1. Se quiser habilitar políticas de novas tentativas, ative **Novas tentativas**. Por padrão, os pipes recém-criados não têm uma política de repetição ativada.
1. Em **Tempo Máximo do Evento**, insira um valor entre um minuto (00:01) e 24 horas (24:00).
1. Em **Tentativas de Repetição**, insira um número entre 0 e 185.
1. Se quiser usar uma fila de mensagens não entregues (DLQ), ative a **Fila de mensagens não entregues**, escolha o método de sua preferência e escolha a fila ou o tópico que gostaria de usar. Por padrão, os pipes recém-criados não usam uma DLQ.
1. Escolha o KMS key para usar EventBridge ao criptografar dados de tubulação.
Para obter mais informações sobre como EventBridge usar KMS keys, consulte[Criptografia em repouso](eb-data-protection.md#eb-encryption-at-rest).
+ Escolha **Usar Chave pertencente à AWS** EventBridge para criptografar os dados usando um Chave pertencente à AWS.
Chave pertencente à AWS É um KMS key que EventBridge possui e gerencia para uso em várias AWS contas. Em geral, a menos que seja necessário auditar ou controlar a chave de criptografia que protege os recursos, uma Chave pertencente à AWS é uma boa escolha.
Esse é o padrão.
+ Escolha **Usar chave gerenciada pelo cliente** EventBridge para criptografar os dados usando o chave gerenciada pelo cliente que você especifica ou cria.
Chaves gerenciadas pelo cliente estão KMS keys na sua AWS conta que você cria, possui e gerencia. Você tem controle total sobre essas KMS keys.
1. Especifique um existente chave gerenciada pelo cliente ou escolha **Criar um novo KMS key**.
EventBridge exibe o status da chave e quaisquer aliases de chave que tenham sido associados ao especificado chave gerenciada pelo cliente.
1. (Opcional) Em **Logs: opcional**, você pode configurar como o EventBridge Pipes envia informações de registro em log para os serviços compatíveis, incluindo como configurar esses logs.
Para obter mais informações sobre o registro em log de pipes, consulte [Registrando o desempenho do Amazon EventBridge Pipes](eb-pipes-logs.md).
CloudWatch logs é selecionado como destino de log por padrão, assim como o nível de `ERROR` log. Então, por padrão, o EventBridge Pipes cria um novo CloudWatch grupo de registros para o qual envia registros de log contendo o `ERROR` nível de detalhe.
Para que o EventBridge Pipes envie registros de log para qualquer um dos destinos de log suportados, faça o seguinte:
1. Em **Registros: opcional**, escolha os destinos para os quais deseja que os registros de log sejam entregues.
1. Em **Nível de registro**, escolha o nível de informações a EventBridge serem incluídas nos registros de registro. O nível de log `ERROR` é selecionado por padrão.
Para obter mais informações, consulte [Especificando o nível EventBridge de registro de tubos](eb-pipes-logs.md#eb-pipes-logs-level).
1. Selecione **Incluir dados de execução** se EventBridge quiser incluir informações de carga útil do evento e informações de solicitação e resposta de serviço nos registros de log.
Para obter mais informações, consulte [Incluindo dados de execução nos registros do EventBridge Pipes](eb-pipes-logs.md#eb-pipes-logs-execution-data).
1. Configure cada destino de log selecionado por você:
Para CloudWatch Logs registros, em **CloudWatch registros**, faça o seguinte:
+ Para **grupo de CloudWatch registros**, escolha se deseja EventBridge criar um novo grupo de registros, ou você pode selecionar um grupo de registros existente ou especificar o ARN de um grupo de registros existente.
+ Para novos grupos de logs, edite o nome do grupo de logs conforme desejado.
CloudWatch os registros são selecionados por padrão.
Para registros de Firehose transmissão, em **Registro de Firehose transmissão**, selecione a Firehose transmissão.
Para Amazon S3 registros, em **registros do S3**, faça o seguinte:
+ Insira o nome do bucket a ser usado como destino do log.
+ Insira o ID da AWS conta do proprietário do bucket.
+ Insira qualquer texto de prefixo que você queira usar quando o EventBridge criar objetos do S3.
Para obter informações, consulte [Como organizar objetos usando prefixos](https://docs.aws.amazon.com/AmazonS3/latest/userguide/using-prefixes.html) no *Guia do usuário do Amazon Simple Storage Service *.
+ Escolha como você deseja EventBridge formatar os registros de log do S3:
+ `json`: JSON
+ `plain`: texto sem formatação
+ `w3c`: [Formato de arquivo de registro em log estendido do W3C](https://www.w3.org/TR/WD-logfile)
1. (Opcional) Em **Tags: opcional**, escolha **Adicionar nova tag** e insira uma ou mais tags para a regra. Para obter mais informações, consulte [Recursos de marcação na Amazon EventBridge](eb-tagging.md).
1. Escolha **Criar pipe**.
## Como validar os parâmetros de configuração
Depois que um pipe é criado, EventBridge valida os seguintes parâmetros de configuração:
+ **Função do IAM** — Como a origem de um canal não pode ser alterada após a criação do canal, EventBridge verifica se a função do IAM fornecida pode acessar a fonte.
**nota**
EventBridge não executa a mesma validação para enriquecimentos ou alvos porque eles podem ser atualizados após a criação do canal.
+ **Lotes** — EventBridge valida se o tamanho do lote da origem não excede o tamanho máximo do lote de destino. Se isso acontecer, será EventBridge necessário um tamanho de lote menor. Além disso, se um destino não oferecer suporte ao agrupamento em lotes, você não poderá configurar o agrupamento em lotes EventBridge para a origem.
+ **Enriquecimentos** — EventBridge valida que o tamanho do lote para enriquecimentos do API Gateway e do destino da API é 1, pois somente tamanhos de lote de 1 são suportados.