Tutorial: Processar dados de ações em tempo real usando a KCL e a KCL 2. - Amazon Kinesis Data Streams

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

Tutorial: Processar dados de ações em tempo real usando a KCL e a KCL 2.

O cenário deste tutorial envolve consumir negociações de ações em um stream de dados e escrever um aplicativo do Amazon Kinesis Data Streams simples que realiza cálculos no streaming. Você aprenderá a enviar um streaming de registros para o Kinesis Data Streams e implementar um aplicativo que consome e processa os registros quase em tempo real.

Importante

Depois de criar um streaming, sua conta incorre em cobranças nominais pelo uso do Kinesis Data Streams, pois o Kinesis Data Streams não está qualificado para oAWSNível gratuito. Depois que for iniciado, o aplicativo consumidor também incorrerá em cobranças nominais pelo uso do Amazon DynamoDB. O aplicativo consumidor usa o DynamoDB para rastrear o estado do processamento. Quando você terminar de usar este aplicativo, exclua suaAWSrecursos para parar de incorrer em cobranças. Para obter mais informações, consulte Etapa 7: Concluir.

O código não acessa os dados reais da bolsa de valores, ele simula o stream de negociações de ações. Isso é feito com o uso de um gerador de negociações de ações aleatórias cujo ponto de partida são dados do mercado real referente às 25 principais ações por capitalização de mercado em fevereiro de 2015. Se tiver acesso a um streaming de negociações de ações em tempo real, você poderá se interessar em derivar estatísticas úteis e em tempo hábil desse streaming. Por exemplo, talvez convenha executar uma análise de janela deslizante na qual você determina a ação mais popular que foi adquirida nos últimos 5 minutos. Ou talvez convenha uma notificação sempre que uma ordem de venda for muito grande (ou seja, tenha muitas quotas). Você pode estender o código nesta série para oferecer essa funcionalidade.

É possível executar as etapas deste tutorial no desktop ou laptop e executar o código de produtor e de consumidor na mesma máquina ou em qualquer plataforma que ofereça suporte aos requisitos definidos.

Os exemplos mostrados usam a região Oeste dos EUA (Oregon), mas funcionam em qualquer um dosAWSregiõesque oferecem suporte ao Kinesis Data Streams.