Amazon Managed Service for Apache Flink - Amazon Timestream
範例應用程式影片教學課程

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

Amazon Managed Service for Apache Flink

您可以使用 Apache Flink，將時間序列資料從 Amazon Managed Service for Apache Flink、Amazon MSK、Apache Kafka 和其他串流技術直接傳輸至 Amazon Timestream for LiveAnalytics。我們已為 Timestream 建立 Apache Flink 範例資料連接器。我們也建立了將資料傳送至 Amazon Kinesis 的範例應用程式，以便資料可以從 Kinesis 流向 Managed Service for Apache Flink，最後流向 Amazon Timestream。您可以在 中取得所有這些成品 GitHub。本影片教學課程說明 設定。

注意

Java 11 是使用 Managed Service for Apache Flink 應用程式的建議版本。如果您有多個 Java 版本，請務必將 Java 11 匯出到 JAVA_HOME 環境變數。

範例應用程式

若要開始使用，請遵循下列程序：

  1. 在 Timestream 中建立資料庫，名稱為 ，kdaflink請依照 中所述的指示進行 建立 資料庫

  2. 在 Timestream 中建立名為 的資料表，kinesisdata1請遵循 中說明的說明 建立資料表

  3. TimestreamTestStream 按照建立串流中所述的指示，使用名稱建立 Amazon Kinesis Data Stream https://docs.aws.amazon.com/streams/latest/dev/amazon-kinesis-streams.html#how-do-i-create-a-stream

  4. 按照 的指示複製適用於 Timestream 的 Apache Flink 資料連接器的 GitHub 儲存庫 GitHub

  5. 若要編譯、執行和使用範例應用程式，請遵循 Apache Flink 範例資料連接器中的指示 README

  6. 遵循編譯應用程式程式碼的指示，編譯 Managed Service for Apache Flink 應用程式

  7. 按照上傳 Apache Flink 串流程式碼的指示，上傳 Managed Service for Apache Flink 應用程式二進位檔

    1. 按一下建立應用程式後，按一下應用程式IAM角色的連結

    2. 連接 AmazonKinesisReadOnlyAccess和 IAM的政策AmazonTimestreamFullAccess。

      注意

      上述IAM政策不限於特定資源，且不適用於生產用途。對於生產系統，請考慮使用限制存取特定資源的政策。

  8. 依照 的指示，複製範例應用程式的 GitHub 儲存庫，將資料寫入 Kinesis https://github.com/awslabs/amazon-timestream-tools/blob/master/tools/kinesis_ingestor GitHub

  9. 請依照 中的指示README執行範例應用程式，以將資料寫入 Kinesis

  10. 在 Timestream 中執行一或多個查詢，以確保資料從 Kinesis 傳送至 Managed Service for Apache Flink to Timestream，並遵循 的指示 建立資料表

影片教學課程

本影片說明如何將 Timestream 與 Managed Service for Apache Flink 搭配使用。