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

Amazon Kinesis Data Streams 生產者疑難排解

我的生產者應用程式寫入的速度比預期慢

超過服務限制

若要查明是否超出服務限制，請檢查您的生產者是否由服務擲回了傳輸量例外狀況，並查驗有哪些 API 操作受到調節。請切記，視呼叫而定將有不同的限制，具體如 配額和限制所述。例如，除了讀寫操作眾所周知的碎片層級限制外，另有以下的串流層級限制：

CreateStream、DeleteStream、ListStreams、GetShardIterator 和 MergeShards 操作的限制為每秒 5 次呼叫。DescribeStream 操作的限制為每秒 10 次呼叫。DescribeStreamSummary 操作的限制為每秒 20 次呼叫。

如果上述呼叫不存在問題，請確定您選取了能夠對所有碎片均勻地分佈 put 操作的分割區索引鍵，而且並無任何特定分割區索引鍵不慎達到了服務限制但其餘則未達到限制。對此，您將需要測量尖峰傳輸量並考量到串流中的碎片數目。如需如何管理串流的詳細資訊，請參閱建立和管理 Kinesis 資料串流。

我想要最佳化我的生產者

開始最佳化生產者之前，請先完成下列關鍵任務。首先，根據記錄大小和每秒記錄筆數，確認所需的尖峰傳輸量。接著，排除串流容量為限制因素 (超過服務限制) 的可能性。如果您排除了串流容量，則針對以下兩種常見類型的生產者使用相應的故障診斷技巧及最佳化準則。

大型生產者

大型生產者通常是從內部部署伺服器或 Amazon EC2 執行個體執行。需要由大型生產者提供較高傳輸量的消費者通常會在意每一記錄延遲。處理延遲的策略包括：如果客戶可以微批次/緩衝記錄，請在使用單一記錄操作 PutRecord 之前，使用 Amazon Kinesis Producer Library （具有進階彙總邏輯）、多記錄操作 PutRecords PutRecord或將記錄彙總到較大的檔案中。 PutRecords 如果您無法批次處理/緩衝，請使用多個執行緒同時寫入 Kinesis Data Streams 服務。 適用於 Java 的 AWS SDK 和其他 SDKs 包含能以極少程式碼執行此操作的非同步用戶端。

小型生產者

小型生產者通常是行動應用程式、IoT 裝置或 web 用戶端。如果是行動應用程式，建議您在 AWS Mobile SDKs 中使用 PutRecords操作或 Kinesis Recorder。如需詳細資訊，請參閱 適用於 Android 的 AWS Mobile SDK 入門指南和 AWS Mobile SDK for iOS 入門指南。行動應用程式必須處理自身固有的斷續連線問題，而且需要某一類的批次 put 操作如 PutRecords。若您由於某些因素無法批次處理，請參閱上述「大型生產者」一節的資訊。如果您的生產者是瀏覽器，產生的資料量通常很少。不過，這樣是將 put 操作放在了應用程式的重要路徑上，而此做法並不建議。

操作濫用 flushSync()

flushSync() 不正確地使用 可能會大幅影響寫入效能。flushSync() 操作專為關機案例而設計，以確保在 KPL 應用程式終止之前傳送所有緩衝記錄。如果您在每次寫入操作之後實作此操作，可能會增加大量額外延遲，每次寫入大約 500 毫秒。請確定您已flushSync()針對應用程式關閉實作 ，以避免寫入效能不必要的額外延遲。

我收到未經授權的 KMS 主金鑰許可錯誤

若生產者應用程式寫入已加密的串流但未具備 KMS 主金鑰的許可，便會發生此錯誤。若要為應用程式指派許可使其能夠存取 KMS 金鑰，請參閱在 AWS KMS 中使用金鑰政策及搭配 AWS KMS 使用 IAM 政策。

對生產者的其他常見問題進行故障診斷