DynamoDB Streams 和 Apache Flink

您可以使用 Apache Flink 取用 Amazon DynamoDB Streams 記錄。透過 Amazon Managed Service for Apache Flink，您可以使用 Apache Flink 即時轉換並分析串流資料。Apache Flink 是開放原始碼串流處理架構，用於處理即時資料。Apache Flink 專用的 Amazon DynamoDB Streams 連接器可簡化 Apache Flink 工作負載的建置和管理，方便您將應用程式與其他 AWS 服務 整合。

Amazon Managed Service for Apache Flink 可協助您快速建置端對端串流處理應用程式，以進行日誌分析、點擊流分析、物聯網 (IoT)、廣告技術、遊戲等。四個最常見的使用案例是串流擷取、轉換和載入 (ETL)、事件驅動型應用程式、回應式即時分析，以及資料串流的互動式查詢。如需從 Amazon DynamoDB Streams 寫入 Apache Flink 的詳細資訊，請參閱 Amazon DynamoDB Streams 連接器。

透過 Apache Flink 專用的 DynamoDB Streams 連接器使用 ShardFilter 參數

Amazon DynamoDB Streams 支援 DescribeStream API 中的 ShardFilter 參數，以尋找碎片的子集。透過在請求中指定父碎片，DynamoDB Streams 會傳回其直屬子碎片。您可以使用 ShardFilter 參數，在父碎片關閉後快速探索子碎片，提高串流處理應用程式的回應性並更符合成本效益。

從 DynamoDB Streams 讀取時，Amazon Managed Service for Apache Flink 支援 ShardFilter 參數。若要使用此功能，您必須請求存取包含 ShardFilter 支援的特殊版本 Flink 連接器。若要開始使用，請在支援中心開啟 AWS 支援案例，並請求存取這些二進位檔。如需進一步了解如何搭配 Apache Flink 使用 DynamoDB Streams，請參閱《DynamoDB 開發人員指南》的 讀取及處理串流。