

Para recursos semelhantes aos do Amazon Timestream para, considere o Amazon Timestream LiveAnalytics para InfluxDB. Ele oferece ingestão de dados simplificada e tempos de resposta de consulta de um dígito em milissegundos para análises em tempo real. Saiba mais [aqui](https://docs.aws.amazon.com//timestream/latest/developerguide/timestream-for-influxdb.html).

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

# Amazon Managed Service for Apache Flink
<a name="ApacheFlink"></a>

Você pode usar o Apache Flink para transferir seus dados de séries temporais do Amazon Managed Service for Apache Flink, Amazon MSK, Apache Kafka e outras tecnologias de streaming diretamente para o Amazon Timestream para LiveAnalytics. Criamos um conector de dados de amostra do Apache Flink para o Timestream. Também criamos um aplicativo de amostra para enviar dados para o Amazon Kinesis para que os dados possam fluir do Kinesis para o Managed Service para Apache Flink e, finalmente, para o Amazon Timestream. Todos esses artefatos estão disponíveis para você no GitHub. Este [tutorial em vídeo](https://youtu.be/64DSlBvN5lg) descreve a configuração.

**nota**  
 O Java 11 é a versão recomendada para usar a aplicação do Managed Service for Apache Flink. Se você tiver várias versões do Java, certifique-se de exportar o Java 11 para sua variável de ambiente JAVA\$1HOME. 

**Topics**
+ [Aplicação de exemplo](#ApacheFlink.sample-app)
+ [Vídeo de tutorial](#ApacheFlink.video-tutorial)

## Aplicação de exemplo
<a name="ApacheFlink.sample-app"></a>

Para começar a usar, siga o procedimento a seguir.

1. Crie um banco de dados no Timestream com o nome `kdaflink` seguindo as instruções descritas em [Criar um banco de dados](console_timestream.md#console_timestream.db.using-console).

1. Crie uma tabela no Timestream com o nome `kinesisdata1` seguindo as instruções descritas em [Criar uma tabela](console_timestream.md#console_timestream.table.using-console).

1. Crie um Amazon Kinesis Data Stream com o nome `TimestreamTestStream` seguindo as instruções descritas em [Criação de um stream](https://docs.aws.amazon.com/streams/latest/dev/amazon-kinesis-streams.html#how-do-i-create-a-stream).

1. Clone o repositório do GitHub para [o conector de dados Apache Flink](https://github.com/awslabs/amazon-timestream-tools/blob/master/integrations/flink_connector) para Timestream seguindo as instruções do [GitHub](https://docs.github.com/en/free-pro-team@latest/github/creating-cloning-and-archiving-repositories/cloning-a-repository).

1.  Para compilar, executar e usar o aplicativo de amostra, siga as instruções no README do conector de [dados de amostra do Apache Flink](https://github.com/awslabs/amazon-timestream-tools/blob/master/integrations/flink_connector/README.md). 

1. Compile a aplicação do Managed Service para o Apache Flink seguindo as instruções para [compilar](https://docs.aws.amazon.com/managed-flink/latest/java/get-started-exercise.html#get-started-exercise-5.5) a aplicação do Managed Service para o Apache Flink.

1. Faça o upload do serviço gerenciado para o binário do aplicativo Apache Flink seguindo as instruções para [carregar o código de streaming do Apache Flink](https://docs.aws.amazon.com/managed-flink/latest/java/get-started-exercise.html#get-started-exercise-6).

   1. Depois de clicar em Criar aplicativo, clique no link do perfil do IAM para o aplicativo.

   1. Anexe as políticas do IAM para **AmazonKinesisReadOnlyAccess** e **AmazonTimeStreamFullAccess.**
**nota**  
As políticas do IAM acima não se restringem a recursos específicos e não são adequadas para uso em produção. Para um sistema de produção, considere usar políticas que restrinjam o acesso a recursos específicos.

1. Clone o repositório do GitHub para [ o aplicativo de amostra gravando dados no Kinesis ](https://github.com/awslabs/amazon-timestream-tools/tree/mainline/tools/python/kinesis_ingestor)seguindo as instruções do [GitHub](https://docs.github.com/en/free-pro-team@latest/github/creating-cloning-and-archiving-repositories/cloning-a-repository).

1. Siga as instruções no [README](https://github.com/awslabs/amazon-timestream-tools/blob/mainline/tools/python/kinesis_ingestor/README.md) para executar o aplicativo de amostra para gravar dados no Kinesis.

1. Execute uma ou mais consultas no Timestream para garantir que os dados estejam sendo enviados do Kinesis para o Managed Service para o Apache Flink para o Timestream seguindo as instruções para [Criar uma tabela](console_timestream.md#console_timestream.table.using-console).

## Vídeo de tutorial
<a name="ApacheFlink.video-tutorial"></a>

Este [vídeo](https://youtu.be/64DSlBvN5lg) explica como usar o Timestream com Managed Service para Apache Flink.