Configuração da saída do aplicativo - Guia do Desenvolvedor de Amazon Kinesis Data Analytics para aplicativos SQL

Após uma análise cuidadosa, decidimos descontinuar as aplicações do Amazon Kinesis Data Analytics para SQL em duas etapas:

1. A partir de 15 de outubro de 2025, você não poderá mais criar aplicações do Kinesis Data Analytics para SQL.

2. Excluiremos as aplicações a partir de 27 de janeiro de 2026. Você não poderá mais iniciar nem operar as aplicações do Amazon Kinesis Data Analytics para SQL. A partir dessa data, não haverá mais suporte ao Amazon Kinesis Data Analytics para SQL. Para obter mais informações, consulte Descontinuação de aplicações do Amazon Kinesis Data Analytics para SQL.

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á.

Configuração da saída do aplicativo

No código do aplicativo, você grava a saída das instruções SQL em um ou mais fluxos de aplicativo. Opcionalmente, você pode adicionar uma configuração de saída ao seu aplicativo para manter tudo gravado em um stream no aplicativo em um destino externo, como um stream de dados do Amazon Kinesis, um stream de entrega do Firehose ou uma função. AWS Lambda

Há um limite para o número de destinos externos que você pode usar para manter uma saída de aplicativo. Para obter mais informações, consulte Limites.

nota

É recomendável que você use um destino externo no qual manterá os dados do fluxo de erros de aplicativo, para que você possa investigar os erros.

Em cada uma dessas configurações de saída, você fornece o seguinte:

  • Nome do fluxo de aplicativo – O fluxo que você deseja manter em um destino externo.

    O Kinesis Data Analytics busca o fluxo no aplicativo especificado na configuração de saída. (O nome do fluxo faz distinção entre maiúsculas e minúsculas e deve corresponder exatamente.) Verifique se o código do aplicativo está criando esse fluxo de aplicativo.

  • Destino externo: você pode manter os dados em um fluxo de dados do Kinesis, em um fluxo de entrega do Firehose ou em uma função do Lambda. Forneça o nome de recurso da Amazon (ARN) do fluxo ou da função. Forneça também um perfil do IAM que o Kinesis Data Analytics possa assumir para gravar no fluxo ou na função em seu nome. Descreva o formato do registro (JSON, CSV) para que o Kinesis Data Analytics use durante a gravação no destino externo.

Se o serviço do Kinesis Data Analytics não conseguir gravar no destino de streaming ou do Lambda, ele continuará tentando por tempo indeterminado. Isso cria uma pressão contrária, fazendo com que o aplicativo fique para trás. Se isso problema não for resolvido, o aplicativo acabará interrompendo o processamento de novos dados. Você pode monitorar as métricas do Kinesis Data Analytics e definir alarmes para falhas. Para obter mais informações sobre métricas e alarmes, consulte Usando CloudWatch métricas da Amazon e Criação de CloudWatch alarmes da Amazon.

Você pode configurar a saída do aplicativo usando o AWS Management Console. O console faz com que a chamada de API salve a configuração.

Criando uma saída usando o AWS CLI

Esta seção descreve como criar a seção Outputs do corpo de uma solicitação para uma operação CreateApplication ou AddApplicationOutput.

Criação de uma saída do Kinesis Stream

O fragmento JSON a seguir mostra a seção Outputs no corpo da solicitação de CreateApplication para a criação de um destino de fluxo de dados do Amazon Kinesis.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisStreamsOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]

Criar uma saída de fluxo de entrega do Firehose

O fragmento JSON a seguir mostra a seção Outputs no corpo da solicitação CreateApplication para a criação de um destino de fluxo de entrega do Amazon Data Firehose.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisFirehoseOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]

Criação de saída de uma função do Lambda

O fragmento JSON a seguir mostra a Outputs seção no corpo da CreateApplication solicitação para criar um destino de AWS Lambda função.

"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "LambdaOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]