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.
Cree un flujo de datos
En el primer paso del Tutorial: Procese datos bursátiles en tiempo real con KPL and KCL 1.x, creará la secuencia que utilizará en los pasos siguientes.
Para crear un flujo
-
Elija Flujos de datos en el panel de navegación.
-
En la barra de navegación, expanda el selector de regiones y seleccione una región.
-
Elija Create Kinesis stream (Crear secuencia de Kinesis).
-
Escriba un nombre para la secuencia (por ejemplo
StockTradeStream). -
Introduzca
1el número de fragmentos, pero mantenga el cálculo aproximado del número de fragmentos que necesitará plegados. -
Elija Create Kinesis stream (Crear secuencia de Kinesis).
En la página de lista Flujos de Kinesis, el estado del flujo es CREATING mientras se está creando. Cuando la secuencia está lista para usarse, el estado cambia a ACTIVE. Elija el nombre del flujo. En la página que aparece, la pestaña Detalles muestra un resumen de la configuración del flujo. La sección Monitoreo muestra información de supervisión del flujo.
Información adicional sobre los fragmentos
Cuando comience a utilizar Kinesis Data Streams fuera de este tutorial, es posible que tenga que planificar el proceso de creación de flujos más detenidamente. Debe planificarlo en función de la demanda máxima esperada cuando aprovisione los fragmentos. Con este escenario como ejemplo, el tráfico del mercado bursátil de los Estados Unidos alcanza su máximo durante el día (hora del este), por lo que las estimaciones de la demanda deben realizarse a para ese momento del día. A continuación, podrá elegir el aprovisionamiento adecuado para la demanda máxima prevista o escalar su secuencia en respuesta a las fluctuaciones de la demanda.
Un fragmento es una unidad de capacidad de rendimiento. En la página Crear flujo de Kinesis, expanda Estimar el número de particiones que necesitará. Introduzca el tamaño medio de los registros, el número máximo de registros escritos por segundo, y el número de aplicaciones consumidoras utilizando las directrices siguientes:
- Tamaño medio de registro
-
Estimación del tamaño medio calculado de los registros. Si no conoce este valor, utilice la estimación del tamaño máximo del registro para este valor.
- Número máximo de registros escritos
-
Tenga en cuenta el número de entidades que proporcionan datos y el número aproximado de registros por segundo que produce cada una de ellas. Por ejemplo, si está obteniendo operaciones bursátiles de 20 servidores y cada uno genera 250 operaciones por segundo, el número total de operaciones (registros) por segundo es de 5000.
- Número de aplicaciones consumidoras
-
Número de aplicaciones que leen independientemente desde la secuencia para procesarla de una forma diferente y producir resultados distintos. Cada aplicación puede tener varias instancias en ejecución en diferentes máquinas (es decir, que se ejecutan en un clúster) para poder procesar una secuencia de gran volumen.
Si el número estimado de fragmentos que se muestra supera su límite de fragmentos actual, puede que tenga que enviar una solicitud para aumentar ese límite antes de crear una secuencia con ese número de fragmentos. Para solicitar un aumento del límite de particiones, utilice el formulario Límites de Kinesis Data Streams
Siguientes pasos
Cree una IAM política y un usuario
