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.
En el primer paso del Tutorial: Procesar operaciones bursátiles en tiempo real con KPL y KCL 1.x, creará la secuencia que utilizará en los pasos siguientes.
Para crear un flujo
Inicie sesión en la AWS Management Console y abra la consola de Kinesis en https://console.aws.amazon.com/kinesis
. -
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
1
como número de particiones, pero deje Calcular el número de particiones que va a necesitar contraído. -
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 particiones
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 los datos y el número aproximado de registros por segundo producidos por 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
Crear un usuario y una política de IAM