Kinesis - 處理寫入ProvisionedThroughputExceededException

Question

我們將AWS Kinesis用作持久隊列。 Kinesis擁有最多1000次寫入/秒，每個分片總數限制爲1M /秒。我們使用案例的80％低於限制。但是，有一些超過1M/s的峯值。爲這些峯值預留更多寫入容量是不划算的。

有什麼建議嗎？

1. 讓SDK處理ProvisionedThroughputExceededException重試？
2. 將事件寫入臨時位置並刷新一次達到1M？
3. ...？

Answer 1

您可以使用kinesis autoscaling的awslabs項目。

這會自動增加高峯時段的碎片數量，並在活動較少時降低碎片數量。您可以通過Autoscaling策略配置閾值來完成此操作。