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

DynamoDB 串流和 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 可協助您快速建置end-to-end串流處理應用程式，以進行日誌分析、點擊串流分析、物聯網 (IoT)、廣告技術、遊戲等。四個最常見的使用案例是串流extract-transform-load (ETL)、事件驅動應用程式、回應式即時分析，以及資料串流的互動式查詢。如需從 Amazon DynamoDB Streams 寫入 Apache Flink 的詳細資訊，請參閱 Amazon DynamoDB Streams Connector。

搭配適用於 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 開發人員指南讀取及處理串流》中的 。