Após uma análise cuidadosa, decidimos descontinuar o Amazon Kinesis Data Analytics SQL para aplicativos em duas etapas:
1. A partir de 15 de outubro de 2025, você não poderá criar um novo Kinesis Data Analytics SQL para aplicativos.
2. Excluiremos seus aplicativos a partir de 27 de janeiro de 2026. Você não poderá iniciar ou operar seu Amazon Kinesis Data Analytics SQL para aplicativos. O suporte não estará mais disponível para o Amazon Kinesis Data Analytics SQL a partir desse momento. Para obter mais informações, consulte Descontinuação do Amazon Kinesis Data Analytics SQL para aplicativos.
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 SQL instruções em um ou mais fluxos no 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 persistir os dados em um stream de dados do Kinesis, em um stream de entrega do Firehose ou em uma função Lambda. Você fornece o Amazon Resource Name (ARN) do stream ou da função. Você também fornece uma IAM função que o Kinesis Data Analytics pode assumir para gravar no stream ou na função em seu nome. Você descreve o formato de registro (JSON,CSV) para o Kinesis Data Analytics usar ao gravar 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 a API chamada para salvar 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 JSON fragmento a seguir mostra a Outputs
seção no corpo da CreateApplication
solicitação para criar um destino de stream de dados do Amazon Kinesis.
"Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisStreamsOutput": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string" } ]
Criando uma saída de fluxo de entrega do Firehose
O JSON fragmento a seguir mostra a Outputs
seção no corpo da CreateApplication
solicitação para criar um destino de stream 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 JSON fragmento 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" } ]