Amazon KinesisからデータGet方法まとめ

◯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', 'シーケンス番号')

このように必要なデータに合わせて取得する方法を変えることが出来ます。

次回もお楽しみに!!

関連ソリューション

Amazon Kinesisを使ったデータ分析のご相談はこちら

この記事を書いた人

aws-recipe-user