◯TRIM_HORIZON
一番古いレコードから取得できます。
1kinesis_iterator = connection.get_shard_iterator(stream_name,shards,'TRIM_HORIZON')◯AT_SEQUENCE_NUMBER
指定したシーケンス番号から取得できます。
取得開始するシーケンス番号を指定する必要があります。
1kinesis_iterator = connection.get_shard_iterator(stream_name,shards, 'AT_SEQUENCE_NUMBER', 'シーケンス番号')◯AFTER_SEQUENCE_NUMBER
指定したシーケンス番号の次から取得(前回の最後が取れればこれでOK)
1kinesis_iterator = connection.get_shard_iterator(stream_name,shards,'AFTER_SEQUENCE_NUMBER', 'シーケンス番号')このように必要なデータに合わせて取得する方法を変えることが出来ます。
次回もお楽しみに!!