Amazon Managed Service para Apache Flink - Amazon Timestream
Aplicación de muestraTutoriales en video

Para obtener capacidades similares a las de Amazon Timestream, considere Amazon Timestream LiveAnalytics para InfluxDB. Ofrece una ingesta de datos simplificada y tiempos de respuesta a las consultas en milisegundos de un solo dígito para realizar análisis en tiempo real. Obtenga más información aquí.

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 utilizar Apache Flink para transferir los datos de serie temporal desde Amazon Managed Service para Apache Flink, Amazon MSK, Apache Kafka y otras tecnologías de transmisión directamente a Amazon Timestream para 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 manera que los datos puedan pasar de Kinesis a Managed Service para Apache Flink y, por último, a Amazon Timestream. Todos estos artefactos están disponibles en GitHub. En este tutorial en video se describe la configuración.

nota

Java 11 es la versión recomendada para utilizar la aplicación de Managed Service para Apache Flink. Si tiene varias versiones de Java, asegúrese de exportar Java 11 a la variable de entorno JAVA_HOME.

Aplicación de muestra

Para comenzar, siga el procedimiento que se indica a continuación:

  1. Cree una base de datos en Timestream con el nombre kdaflink según las instrucciones que se describen en Creación de una base de datos de .

  2. Cree una tabla en Timestream con el nombre kinesisdata1 según las instrucciones que se describen en Creación de una tabla.

  3. Cree una Amazon Kinesis Data Stream con el nombre TimestreamTestStream según las instrucciones que se describen en Creación de una transmisión.

  4. Clone el repositorio de GitHub para el conector de datos de Apache Flink para Timestream según las instrucciones de GitHub.

  5. Para compilar, ejecutar y utilizar la aplicación de muestra, siga las instrucciones que se encuentran en el README del conector de datos de muestra de Apache Flink.

  6. Compile la aplicación de Managed Service para Apache Flink según las instrucciones para compilar el código de la aplicación.

  7. Cargue el archivo binario de la aplicación de Managed Service para Apache Flink según las instrucciones para cargar el código de transmisión de Apache Flink.

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

    2. Asocie las políticas de IAM para AmazonKinesisReadOnlyAccess y AmazonTimestreamFullAccess.

      nota

      Las políticas de IAM 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 limiten el acceso a recursos específicos.

  8. Clone el repositorio de GitHub para la aplicación de muestra mediante la escritura de datos en Kinesis según las instrucciones que se encuentran en GitHub.

  9. Siga las instrucciones de README para ejecutar la aplicación de muestra 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 o Apache Flink a Timestream según las instrucciones para Creación de una tabla.

Tutoriales en video

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