Tutorial: Procesamiento de datos de operaciones bursátiles en tiempo real con KPL y KCL 2.x - Amazon Kinesis Data Streams

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Tutorial: Procesamiento de datos de operaciones bursátiles en tiempo real con KPL y KCL 2.x

El escenario que planteamos en este tutorial comprende la adquisición de operaciones bursátiles en un flujo de datos y la escritura de una aplicación de Amazon Kinesis Data Streams sencilla que realiza cálculos con dicho flujo. Aprenderá a enviar un flujo de registros a Kinesis Data Streams e implementar una aplicación que consume y procesa dichos registros casi en tiempo real.

importante

Una vez creado un flujo, su cuenta generará gastos nominales por el uso de Kinesis Data Streams, ya que Kinesis Data Streams no está disponible en el nivel gratuito de AWS. Una vez que se inicia la aplicación consumidora, se aplicarán cargos nominales por el uso de Amazon DynamoDB. La aplicación consumidora utiliza DynamoDB para realizar un seguimiento del estado de procesamiento. Cuando termine con esta aplicación, elimine sus recursos de AWS para dejar de incurrir en gastos. Para obtener más información, consulte Paso 7: Conclusión.

El código no obtiene acceso a datos bursátiles reales, sino que, en su lugar, simula la secuencia de operaciones bursátiles. Lo hace a través de un generador de operaciones bursátiles aleatorias que parte de datos reales del mercado para los 25 principales valores por capitalización en febrero de 2015. Si tiene acceso a una secuencia de operaciones bursátiles en tiempo real, puede que le interese derivar estadísticas útiles y puntuales a partir de dicha secuencia. Por ejemplo, es posible que desee realizar un análisis de ventana deslizante en el que se determina el valor más popular adquirido durante los últimos 5 minutos. O también cabe la posibilidad de que quiera recibir una notificación cada vez que haya una orden de venta que sea demasiado grande (es decir, con demasiadas acciones). Puede ampliar el código de esta serie para proporcionar esta funcionalidad.

Puede seguir los pasos de este tutorial en su ordenador de escritorio o portátil y ejecutar tanto el código de productor como el de consumidor en la misma máquina o en cualquier plataforma que sea compatibles con los requisitos definidos.

Los ejemplos mostrados utilizan la región Oeste de EE. UU. (Oregón), pero funcionan en cualquiera de las regiones de AWS compatibles con Kinesis Data Streams.