Exemplo: exploração do fluxo de erros no aplicativo - Guia do Desenvolvedor de Amazon Kinesis Data Analytics para aplicativos SQL
Inserção de erro de análiseInserção de erro de divisão por zero

Para novos projetos, recomendamos que você use o novo Managed Service for Apache Flink Studio em vez do Kinesis Data Analytics para aplicativos SQL. O Managed Service for Apache Flink Studio combina facilidade de uso com recursos analíticos avançados, permitindo que você crie aplicativos sofisticados de processamento de stream em minutos.

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

Exemplo: exploração do fluxo de erros no aplicativo

O Amazon Kinesis Data Analytics fornece um fluxo de erros de aplicativo para cada aplicativo que você criou. Todas as linhas que o aplicativo não pode processar são enviadas a esse fluxo de erros. É recomendável manter os dados do fluxo de erros em um destino externo para que você possa investigar.

Execute os seguintes exercícios no console. Nestes exemplos, você insere erros na configuração de entrada editando o esquema inferido pelo processo de descoberta e verifica as linhas enviadas ao fluxo de erros.

Inserção de erro de análise

Neste exercício, você insere um erro de análise.

  1. Crie o aplicativo Kinesis Data Analytics como descrito no exercício Conceitos básicos do Kinesis Data Analytics.

  2. Na página de detalhes do aplicativo, escolha Connect streaming data (Conectar dados de streaming).

  3. Se você fez o exercício em Conceitos básicos, há um fluxo de demonstração (kinesis-analytics-demo-stream) na sua conta. Na página Connect to source (Conectar-se à fonte), escolha este fluxo de demonstração.

  4. O Kinesis Data Analytics faz uma amostra no fluxo de demonstração para inferir um esquema para o fluxo de entrada de aplicativo criado. O console mostra o esquema inferido e os dados de exemplo na guia Formatted stream sample.

  5. Em seguida, edite o esquema e modifique o tipo de coluna para inserir o erro de análise. Escolha Edit schema (Editar esquema).

  6. Altere o tipo de coluna TICKER_SYMBOL de VARCHAR(4) para INTEGER.

    Agora que o tipo de coluna no esquema da aplicação que é criado está inválido, o Kinesis Data Analytics não pode trazer dados para o stream do aplicativo. Em vez disso, ele envia linhas para o fluxo de erros.

  7. Escolha Save schema.

  8. Escolha Refresh schema samples.

    Observe que não há linhas no exemplo Formatted stream. No entanto, a guia Error stream mostra os dados com uma mensagem de erro. A guia Error stream mostra os dados enviados ao fluxo de erros de aplicativo.

    Como você mudou o tipo de dados da coluna, o Kinesis Data Analytics não conseguiu extrair os dados no fluxo de entrada no aplicativo. Ele enviou os dados para o fluxo de erros.

Inserção de erro de divisão por zero

Neste exercício, você atualiza o código do aplicativo para introduzir um erro de tempo de execução (divisão por zero). Observe que o Amazon Kinesis Data Analytics envia as linhas resultantes para o fluxo de erros no aplicativo, e não para o fluxo no aplicativo DESTINATION_SQL_STREAM no qual os resultados devem ser gravados.

  1. Crie o aplicativo Kinesis Data Analytics como descrito no exercício Conceitos básicos do Kinesis Data Analytics.

    Verifique os resultados na guia Real-time analytics da seguinte forma:

    Sour

  2. Atualize a instrução SELECT no código do aplicativo para inserir a divisão por zero. Por exemplo: 

    SELECT STREAM ticker_symbol, sector, change, (price / 0) as ProblemColumn
FROM "SOURCE_SQL_STREAM_001"
WHERE sector SIMILAR TO '%TECH%';

  3. Execute o aplicativo.

    Como ocorre o erro de tempo de execução de divisão por zero, em vez de gravar resultados no DESTINATION_SQL_STREAM, o Kinesis Data Analytics envia as linhas ao fluxo de erros no aplicativo. Na guia Real-time analytics (Análise em tempo real), escolha o fluxo de erros. Em seguida, você poderá ver as linhas no fluxo de erros de aplicativo.