Exemplo: criar alertas simples - Guia do desenvolvedor do Amazon Kinesis Data Analytics SQL para aplicativos

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

Exemplo: criar alertas simples

Nesse aplicativo Kinesis Data Analytics, a consulta é executada continuamente no fluxo no aplicativo criado pelo fluxo de demonstração. Para obter mais informações, consulte Consultas contínuas.

Se alguma linha mostrar uma alteração maior do que 1% no preço da ação, as linhas serão inseridas em outro fluxo de aplicativo. No exercício, você pode configurar a saída de aplicativos para que os resultados de um destino externo permaneçam. Em seguida, investigue mais os resultados. Por exemplo, use uma função AWS Lambda para processar registros e enviar alertas.

Para criar um aplicativo de alertas simples

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

  2. No editor SQL no Kinesis Data Analytics, substitua o código de aplicativo pelo seguinte: 

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" 
           (ticker_symbol VARCHAR(4), 
            sector        VARCHAR(12), 
            change        DOUBLE, 
            price         DOUBLE);

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  (ABS(Change / (Price - Change)) * 100) > 1;

    A instrução SELECT no código do aplicativo filtra linhas em SOURCE_SQL_STREAM_001 para mudanças nos preços das ações superiores a 1%. Em seguida, ela insere essas linhas em outro fluxo no aplicativo DESTINATION_SQL_STREAM usando uma bomba. Para obter mais informações sobre o padrão de codificação que explica o uso de bombas para inserir linhas em fluxos no aplicativo, consulte Código do aplicativo.

  3. Escolha Save and run SQL.

  4. Adicione um destino. Para fazer isso, escolha a guia Destination (Destino) no editor SQL ou Add a destination (Adicionar um destino) na página de detalhes do aplicativo.

    1. No editor SQL, selecione a guia Destination (Destino) e, em seguida, escolha Connect to a destination (Conectar-se a um destino).

      Na página Connect to destination (Conectar-se ao destino) escolha Create New (Criar novo).

    2. Escolha Go to Kinesis Streams.

    3. No console do Amazon Kinesis Data Streams, crie um novo fluxo do Kinesis (por exemplo, gs-destination) com um fragmento. Aguarde até que o status do stream seja ACTIVE.

    4. Volte para o console do Kinesis Data Analytics. Na página Connect to destination (Conectar-se ao destino), escolha o fluxo que você criou.

      Se o fluxo não for exibido, atualize a página.

    5. Escolha Save and continue.

    Agora, você tem um destino externo, um fluxo de dados do Kinesis, em que o Kinesis Data Analytics mantém a saída de aplicativo no stream no aplicativo DESTINATION_SQL_STREAM.

  5. Configure o AWS Lambda para monitorar o stream do Kinesis criado e invoque uma função do Lambda.

    Para obter instruções, consulte Pré-processar dados usando uma função do Lambda.