Servizio gestito da Amazon per Apache Flink - Amazon Timestream
Applicazione di esempioTutorial video

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Servizio gestito da Amazon per Apache Flink

Puoi utilizzare Apache Flink per trasferire i dati delle serie temporali da Amazon Managed Service per Apache Flink, MSK Amazon, Apache Kafka e altre tecnologie di streaming direttamente in Amazon Timestream for. LiveAnalytics Abbiamo creato un connettore dati di esempio Apache Flink per Timestream. Abbiamo anche creato un'applicazione di esempio per l'invio di dati ad Amazon Kinesis in modo che i dati possano fluire da Kinesis a Managed Service for Apache Flink e infine ad Amazon Timestream. Tutti questi artefatti sono disponibili in. GitHub Questo video tutorial descrive la configurazione.

Nota

Java 11 è la versione consigliata per l'utilizzo dell'applicazione Managed Service for Apache Flink. Se disponete di più versioni di Java, assicuratevi di esportare Java 11 nella variabile di HOME ambiente JAVA _.

Applicazione di esempio

Per iniziare, seguite la procedura seguente:

  1. Crea un database in Timestream con il nome kdaflink seguendo le istruzioni descritte in Creazione di un database

  2. Crea una tabella in Timestream con il nome kinesisdata1 seguendo le istruzioni descritte in Creare una tabella

  3. Crea un Amazon Kinesis Data Stream con il nome TimestreamTestStream seguendo le istruzioni descritte in Creazione di un flusso

  4. Clona il GitHub repository per il connettore dati Apache Flink per Timestream seguendo le istruzioni di GitHub

  5. Per compilare, eseguire e utilizzare l'applicazione di esempio, segui le istruzioni nel connettore di dati di esempio Apache Flink README

  6. Compilate l'applicazione Managed Service for Apache Flink seguendo le istruzioni per la compilazione del codice dell'applicazione

  7. Carica il file binario dell'applicazione Managed Service for Apache Flink seguendo le istruzioni per caricare il codice di streaming Apache Flink

    1. Dopo aver fatto clic su Crea applicazione, fai clic sul collegamento del ruolo dell'IAMapplicazione

    2. Allega le IAM politiche per AmazonKinesisReadOnlyAccesse AmazonTimestreamFullAccess.

      Nota

      Le IAM politiche di cui sopra non sono limitate a risorse specifiche e non sono adatte all'uso in produzione. Per un sistema di produzione, prendi in considerazione l'utilizzo di politiche che limitano l'accesso a risorse specifiche.

  8. Clona il GitHub repository per l'applicazione di esempio che scrive i dati su Kinesis seguendo le istruzioni di GitHub

  9. Segui le istruzioni riportate nella sezione READMEper eseguire l'applicazione di esempio per la scrittura di dati su Kinesis

  10. Esegui una o più query in Timestream per assicurarti che i dati vengano inviati da Kinesis a Managed Service for Apache Flink to Timestream seguendo le istruzioni per Creare una tabella

Tutorial video

Questo video spiega come utilizzare Timestream con Managed Service per Apache Flink.