AWS Kinesis過去から読まれました

Question

AWS Kinesisストリームから時間を読み取るにはどうすればよいですか？
AWS Kinesisストリームを使用すると、イベントのストリームを送信でき、コンシューマアプリケーションがイベントを読み取ることができます。 Kinesis Streamワーカーはレコードをフェッチし、最後のチェックポイントからIRecordProcessor＃processRecordsに渡します。
しかし、2時間前からのレコードの処理を開始するなど、時間の経過しているレコードを読み込む必要がある場合、そのレコードをフェッチするようにキネシスワーカーを設定するにはどうすればよいですか？

Answer 1

Shineイテレータに関するさまざまな設定を使用して、キネシス消費者をもう一度（または別のもの）起動することができます。 参照ここGetShardIterator 通常の設定では、LATESTまたはTRIM_HORIZON（最も古い）です：

{ 
    "ShardId": "ShardId", 
    "ShardIteratorType": "LATEST", 
    "StreamName": "StreamName", 
} 

しかし、あなたは

{ 
    "ShardId": "ShardId", 
    "ShardIteratorType": "AT_TIMESTAMP", 
    "StreamName": "StreamName", 
    "Timestamp": 2016-06-29T19:58:46.480-00:00 
} 

（過去24時間から）特定の時間にそれを変更することができますことに注意してください通常キネシス消費者はチェックポイントをdynamodbテーブルに保存します。そのため、同じキネシスアプリケーションを使用している場合は、まずチェックポイントを削除する必要があります。