Etapa 3.3: Adicionar análise em tempo real (adicionar código de aplicativo)

Na página do hub do aplicativo, escolha Ir para o SQL editor.

Na seção Você gostaria de começar a executar "ExampleApp“? caixa de diálogo, escolha Sim, iniciar aplicativo.

O console envia uma solicitação para iniciar o aplicativo (consulteStartApplication) e, em seguida, a página do SQL editor é exibida.

O console abre a página do SQL editor. Revise a página, incluindo os botões (Adicionar SQL a partir de modelos, Salvar e executar SQL) e várias guias.

No SQL editor, escolha Adicionar a SQL partir de modelos.

Na lista de modelos disponíveis, escolha Continuous filter. O código de exemplo lê dados de um stream no aplicativo (a cláusula WHERE filtra as linhas) e os insere em outro stream no aplicativo, da seguinte forma:

Escolha Adicionar isso SQL ao editor.

Teste o código do aplicativo da seguinte forma:

Lembre-se de que você já iniciou o aplicativo (o status éRUNNING). Portanto, o Amazon Kinesis Data Analytics já está lendo continuamente a origem de streaming e adicionando linhas ao stream no aplicativo SOURCE_SQL_STREAM_001.

1. No SQL Editor, escolha Salvar e executar SQL. Primeiro, o console envia a solicitação de atualização para salvar o código do aplicativo. Em seguida, o código é executado continuamente.

2. Você pode ver os resultados na guia Real-time analytics.

   

   O SQL editor tem as seguintes guias:

   • A guia Source data mostra um fluxo de entrada de aplicativo que é mapeado para a origem de streaming. Escolha o fluxo de aplicativo e você poderá ver a entrada dos dados em ação. Observe as colunas adicionais do stream de entrada no aplicativo que não foram especificadas na configuração de entrada. Elas incluem as seguintes colunas de timestamp:

      

     • ROWTIME— Cada linha em um stream no aplicativo tem uma coluna especial chamadaROWTIME. Essa coluna é o timestamp quando o Amazon Kinesis Data Analytics inseriu a linha no primeiro stream no aplicativo (o stream de entrada no aplicativo mapeado para a origem de streaming).

        

     • Approximate_Arrival_Time: cada registro do Kinesis Data Analytics inclui um valor chamado Approximate_Arrival_Time. Esse valor é o timestamp de chegada aproximado definido quando a origem de streaming recebe e armazena o registro com êxito. Quando o Kinesis Data Analytics lê registros em uma origem de streaming, ele obtém essa coluna no fluxo de entrada de aplicativo.

     Esses valores de timestamp são úteis nas consultas em janelas baseadas em tempo. Para obter mais informações, consulte Consultas em janelas.

      

   • A guia Real-time analytics mostra todos os outros fluxos de aplicativo criados pelo código de aplicativo. Ela também inclui o stream de erros. O Kinesis Data Analytics envia quaisquer linhas que não consegue processar no fluxo de erros. Para obter mais informações, consulte Como tratar erros.

      

     Selecione DESTINATION_SQL_STREAM para visualizar as linhas inseridas pelo código do aplicativo. Observe as colunas adicionais que o código do aplicativo não criou. Essas colunas incluem a coluna de timestamp ROWTIME. O Kinesis Data Analytics simplesmente copia esses valores da origem (SOURCE_SQL_STREAM_001).

      

   • A guia Destination mostra o destino externo em que o Kinesis Data Analytics grava os resultados da consulta. Você ainda não configurou um destino externo para a saída do aplicativo.