Etapa 2: criar o aplicativo Kinesis Data Analytics - 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á.

Etapa 2: criar o aplicativo Kinesis Data Analytics

Nesta seção do Exemplo de hotspots, você cria um aplicativo Kinesis Data Analytics da seguinte forma:

  • Configure a entrada do aplicativo para usar o fluxo de dados do Kinesis criado por você como a origem do streaming na Etapa 1.

  • Use o código do aplicativo fornecido no AWS Management Console.

Para criar um aplicativo.

  1. Crie um aplicativo Kinesis Data Analytics seguindo as etapas 1, 2 e 3 no exercício Conceitos básicos (consulte Etapa 3.1: criar um aplicativo).

    Na configuração de origem, faça o seguinte:

    • Especifique a origem do streaming criado por você em Etapa 1: criar os streamings de entrada e saída.

    • Depois que o console inferir o esquema, edite-o. Verifique se os tipos de coluna x e yDOUBLE estão definidos como e se o tipo de coluna IS_HOT está definido como VARCHAR.

  2. Use o seguinte código de aplicativo (você pode colar esse código no editor SQL):

    CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
    "x" DOUBLE, 
    "y" DOUBLE, 
    "is_hot" VARCHAR(4),
    HOTSPOTS_RESULT VARCHAR(10000)
); 
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
    INSERT INTO "DESTINATION_SQL_STREAM" 
    SELECT "x", "y", "is_hot", "HOTSPOTS_RESULT" 
    FROM TABLE (
        HOTSPOTS(   
            CURSOR(SELECT STREAM "x", "y", "is_hot" FROM "SOURCE_SQL_STREAM_001"), 
            1000, 
            0.2, 
            17)
    );

  3. Execute o código SQL e analise os resultados.

    Resultados do código SQL mostrando rowtime, hotspot e hotspot_heat.

Próxima etapa

Etapa 3: configurar a saída do aplicativo