Consultas contínuas - 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á.

Consultas contínuas

Uma consulta por um stream é executada continuamente pelos dados de streaming. Essa execução contínua permite cenários, como a capacidade de aplicativos consultarem continuamente um stream e gerar alertas.

No exercício de Conceitos básicos, há um fluxo no aplicativo chamado SOURCE_SQL_STREAM_001. Ele recebe continuamente os preços de ações a partir de um fluxo de demonstração (um fluxo de dados do Kinesis). O esquema é o seguinte:

(TICKER_SYMBOL VARCHAR(4), 
 SECTOR varchar(16), 
 CHANGE REAL, 
 PRICE REAL)

Suponha que você tenha interesse em alterações nos preços de ações acima de 15%. Você poderá usar a seguinte consulta no código do aplicativo. Essa consulta é executada continuamente e emite registros quando uma alteração acima de 15% é detectada no preço de uma ação.

SELECT STREAM TICKER_SYMBOL, PRICE 
      FROM   "SOURCE_SQL_STREAM_001"
      WHERE  (ABS((CHANGE / (PRICE-CHANGE)) * 100)) > 15

Use o procedimento a seguir para configurar um aplicativo do Amazon Kinesis Data Analytics e testar essa consulta.

Para testar a consulta

  1. Crie um aplicativo seguindo as instruções em Exercício de conceitos básicos.

  2. Substitua a instrução SELECT no código de aplicativo pela consulta SELECT anterior. O código de aplicativo resultante é mostrado a seguir:

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (ticker_symbol VARCHAR(4), 
                                                   price DOUBLE);
-- CREATE OR REPLACE PUMP to insert into output
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
  INSERT INTO "DESTINATION_SQL_STREAM" 
      SELECT STREAM TICKER_SYMBOL, 
                    PRICE 
      FROM   "SOURCE_SQL_STREAM_001"
      WHERE  (ABS((CHANGE / (PRICE-CHANGE)) * 100)) > 15;