Modelo de entrega para conservar la salida de las aplicaciones en destinos externos - Guía para desarrolladores de aplicaciones de Amazon Kinesis Data Analytics para SQL

Para proyectos nuevos, le recomendamos que utilice el nuevo servicio gestionado para Apache Flink Studio en lugar de aplicaciones de Kinesis Data Analytics para SQL. El servicio gestionado para Apache Flink Studio combina la facilidad de uso con capacidades analíticas avanzadas, lo que le permite crear aplicaciones sofisticadas de procesamiento de flujos en cuestión de minutos.

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.

Modelo de entrega para conservar la salida de las aplicaciones en destinos externos

Amazon Kinesis Data Analytics utiliza un modelo de entrega de tipo "al menos una vez" para enviar la salida de las aplicaciones a los destinos configurados. Cuando una aplicación se está ejecutando, Kinesis Data Analytics tiene puntos de comprobación internos. Estos puntos de comprobación son momentos determinados en los que se han entregado registros de salida en los destinos sin pérdida de datos. El servicio utiliza los puntos de control necesarios para garantizar que la salida de la aplicación se entregue al menos una vez a los destinos configurados.

En una situación normal, la aplicación procesa los datos entrantes de forma continua. Kinesis Data Analytics graba el resultado en los destinos configurados, como un flujo de datos de Kinesis o una secuencia de entrega de Kinesis Data Firehose. Sin embargo, es posible que la aplicación se interrumpa ocasionalmente; por ejemplo:

  • Puede optar por detener la aplicación y reiniciarla más adelante.

  • Puede eliminar el rol de IAM que Kinesis Data Analytics necesita para escribir la salida de la aplicación en el destino configurado. Sin el rol de IAM, Kinesis Data Analytics no tiene permisos para escribir en un destino externo.

  • Una interrupción de la red o errores en otros servicios internos provocan que se detenga la ejecución de la aplicación momentáneamente.

Cuando la aplicación se reinicia, Kinesis Data Analytics se asegura de que continúa el procesamiento y escribe la salida desde un punto anterior o igual al momento en que se produjo el error. Esto ayuda a asegurarse de que no se pierde la entrega de ninguna salida de la aplicación a los destinos configurados.

Supongamos que ha configurado varios destinos desde la misma secuencia en la aplicación. Después de que la aplicación se recupere de un error, Kinesis Data Analytics reanuda la conservación de la salida en los destinos configurados desde el último registro que se entregó en el destino más lento. Esto podría resultar en el mismo registro de salida enviado más de una vez a otros destinos. En este caso, es obligatorio gestionar las posibles duplicidades en el destino de forma externa.