用戶可以使用這些信息估算自己的系統(tǒng)性能。例如可以檢測(cè)上游應(yīng)用程序發(fā)布數(shù)據(jù)的速度是否過快,超過了下游應(yīng)用程序(Consuming application)的處理能力進(jìn)而產(chǎn)生吞吐率瓶頸。
基于時(shí)間的迭代器
當(dāng)應(yīng)用程序從流中讀取數(shù)據(jù)時(shí),為了以正確的順序拉取正確的數(shù)據(jù),需要追蹤數(shù)據(jù)在流中的位置。在Kinesis Streams中可以使用迭代器實(shí)現(xiàn)該功能。在本次更新之前可以使用順序號(hào)、最老記錄或最新記錄作為迭代器。
在AWS的此次更新中,用戶已經(jīng)可以指定時(shí)間戳決定要從哪里開始處理自己的流。這種功能的一個(gè)用例是:當(dāng)下游應(yīng)用程序經(jīng)歷計(jì)劃內(nèi)停機(jī)時(shí),發(fā)布方可能依然在向流中發(fā)布新數(shù)據(jù)。默認(rèn)情況下,Kinesis Stream最多可存儲(chǔ)24小時(shí)的數(shù)據(jù),這樣消費(fèi)應(yīng)用程序就可以通過提供時(shí)間戳,從上次中斷的地方繼續(xù)處理流中發(fā)布的數(shù)據(jù)。