Amazon Managed Service para Apache Flink - Amazon Timestream
Aplicación de muestraTutorial en vídeo

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.

Amazon Managed Service para Apache Flink

Puede usar Apache Flink para transferir sus datos de series temporales desde Amazon Managed Service para Apache FlinkMSK, Amazon, Apache Kafka y otras tecnologías de streaming directamente a Amazon Timestream for. LiveAnalytics Hemos creado un ejemplo de conector de datos de Apache Flink para Timestream. También hemos creado una aplicación de muestra para enviar datos a Amazon Kinesis, de forma que los datos puedan pasar de Kinesis a Managed Service for Apache Flink y, finalmente, a Amazon Timestream. Todos estos artefactos están disponibles en. GitHub Este tutorial en vídeo describe la configuración.

nota

Java 11 es la versión recomendada para usar la aplicación Managed Service for Apache Flink. Si tiene varias versiones de Java, asegúrese de exportar Java 11 a su variable de HOME entorno JAVA _.

Aplicación de muestra

Para empezar, siga el siguiente procedimiento:

  1. Cree una base de datos en Timestream con el nombre kdaflink siguiendo las instrucciones descritas en Creación de una base de datos de

  2. Cree una tabla en Timestream con el nombre kinesisdata1 siguiendo las instrucciones descritas en Creación de una tabla

  3. Cree una transmisión de datos de Amazon Kinesis con el nombre TimestreamTestStream siguiendo las instrucciones que se describen en Creación de una transmisión

  4. Clone el GitHub repositorio del conector de datos Apache Flink para Timestream siguiendo las instrucciones de GitHub

  5. Para compilar, ejecutar y usar la aplicación de ejemplo, siga las instrucciones del conector de datos de ejemplo de Apache Flink README

  6. Compila el servicio gestionado para la aplicación Apache Flink siguiendo las instrucciones para compilar el código de la aplicación

  7. Cargue el archivo binario de la aplicación Managed Service for Apache Flink siguiendo las instrucciones para cargar el código de streaming de Apache Flink

    1. Después de hacer clic en Crear aplicación, haga clic en el enlace del IAM rol de la aplicación

    2. Adjunte las IAM políticas de AmazonKinesisReadOnlyAccessy AmazonTimestreamFullAccess.

      nota

      Las IAM políticas anteriores no se limitan a recursos específicos y no son adecuadas para su uso en producción. En el caso de un sistema de producción, considere la posibilidad de utilizar políticas que restrinjan el acceso a recursos específicos.

  8. Clone el GitHub repositorio de la aplicación de ejemplo escribiendo datos en Kinesis siguiendo las instrucciones de GitHub

  9. Siga las instrucciones de READMEpara ejecutar la aplicación de ejemplo para escribir datos en Kinesis.

  10. Ejecute una o más consultas en Timestream para asegurarse de que los datos se envían desde Kinesis a Managed Service para Apache Flink to Timestream siguiendo las instrucciones para Creación de una tabla

Tutorial en vídeo

En este vídeo se explica cómo utilizar Timestream con Managed Service para Apache Flink.