Etapa 3: Criar o aplicativo de análise inicial Amazon Kinesis Data Analytics

Criar um aplicativo: você só precisa fornecer um nome. O console cria o aplicativo e o serviço define o estado do aplicativo para READY.

Configurar a entrada: primeiro você adiciona uma origem de streaming, o fluxo de demonstração. Você deve criar um fluxo de demonstração no console para que possa usá-lo. Em seguida, o console usa uma amostra aleatória dos registros no fluxo de demonstração e infere um esquema para o fluxo de entrada de aplicativo criado. O console nomeia o stream no aplicativo SOURCE_SQL_STREAM_001.

O console usa a API de descoberta para inferir o esquema. Se necessário, você pode editar o esquema inferido. Para obter mais informações, consulte DiscoverInputSchema. O Kinesis Data Analytics usa esse esquema para criar um fluxo de aplicativo.

Quando você inicia o aplicativo, o Kinesis Data Analytics lê o fluxo de demonstração continuamente em seu nome e insere linhas no fluxo de entrada de aplicativo SOURCE_SQL_STREAM_001.

Especificar o código do aplicativo: você usa um modelo (chamado Continuous filter) que fornece o código a seguir:

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
  (symbol VARCHAR(4), sector VARCHAR(12), CHANGE DOUBLE, price DOUBLE);
 
-- Create pump to insert into output. 
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
   INSERT INTO "DESTINATION_SQL_STREAM"  
      SELECT STREAM ticker_symbol, sector, CHANGE, price
      FROM "SOURCE_SQL_STREAM_001"
      WHERE sector SIMILAR TO '%TECH%';

O código de aplicativo consulta o stream no aplicativo SOURCE_SQL_STREAM_001. Em seguida, o código insere as linhas resultantes em outro stream no aplicativo DESTINATION_SQL_STREAM, usando bombas. Para obter mais informações sobre esse padrão de codificação, consulte Código do aplicativo.

Para obter mais informações sobre os elementos de idioma SQL compatíveis com o Kinesis Data Analytics, consulte Amazon Kinesis Data Analytics SQL Reference.

Configuração de saída: neste exercício, você não configura nenhuma saída. Ou seja, você não persiste dados no stream no aplicativo criado pelo aplicativo em nenhum destino externo. Em vez disso, você verifica os resultados da consulta no console. Exemplos adicionais neste guia mostram como configurar a saída. Para obter um exemplo, consulte Exemplo: criar alertas simples.