

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í](https://docs.aws.amazon.com//timestream/latest/developerguide/timestream-for-influxdb.html).

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
<a name="ApacheFlink"></a>

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](https://youtu.be/64DSlBvN5lg) 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\$1HOME. 

**Topics**
+ [Aplicación de muestra](#ApacheFlink.sample-app)
+ [Tutoriales en video](#ApacheFlink.video-tutorial)

## Aplicación de muestra
<a name="ApacheFlink.sample-app"></a>

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](console_timestream.md#console_timestream.db.using-console).

1. Cree una tabla en Timestream con el nombre `kinesisdata1` según las instrucciones que se describen en [Creación de una tabla](console_timestream.md#console_timestream.table.using-console).

1. Cree una Amazon Kinesis Data Stream con el nombre `TimestreamTestStream` según las instrucciones que se describen en [Creación de una transmisión](https://docs.aws.amazon.com/streams/latest/dev/amazon-kinesis-streams.html#how-do-i-create-a-stream).

1. Clone el repositorio de GitHub para el [conector de datos de Apache Flink para Timestream](https://github.com/awslabs/amazon-timestream-tools/blob/master/integrations/flink_connector) según las instrucciones de [GitHub](https://docs.github.com/en/free-pro-team@latest/github/creating-cloning-and-archiving-repositories/cloning-a-repository).

1.  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](https://github.com/awslabs/amazon-timestream-tools/blob/master/integrations/flink_connector/README.md). 

1. Compile la aplicación de Managed Service para Apache Flink según las instrucciones para [compilar el código de la aplicación](https://docs.aws.amazon.com/managed-flink/latest/java/get-started-exercise.html#get-started-exercise-5.5).

1. 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](https://docs.aws.amazon.com/managed-flink/latest/java/get-started-exercise.html#get-started-exercise-6).

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

   1. 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.

1. Clone el repositorio de GitHub para la [aplicación de muestra mediante la escritura de datos en Kinesis](https://github.com/awslabs/amazon-timestream-tools/tree/mainline/tools/python/kinesis_ingestor) según las instrucciones que se encuentran en [GitHub](https://docs.github.com/en/free-pro-team@latest/github/creating-cloning-and-archiving-repositories/cloning-a-repository).

1. Siga las instrucciones de [README](https://github.com/awslabs/amazon-timestream-tools/blob/mainline/tools/python/kinesis_ingestor/README.md) para ejecutar la aplicación de muestra para escribir datos en Kinesis.

1. 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](console_timestream.md#console_timestream.table.using-console).

## Tutoriales en video
<a name="ApacheFlink.video-tutorial"></a>

En este [video](https://youtu.be/64DSlBvN5lg) se explica cómo utilizar Timestream con Managed Service para Apache Flink.