Boto3 읽기 운동성 스트림이

Question

boto3의 문서 요청에

, 당신은 시간의 임의의 점에서 레코드를 읽을 수있는 샤드 반복자 타입 AT_TIMESTAMP를 지정할 수 있음을 언급, TRIM_HORIZON는 ShardIterator 가리하게하는 시스템의 샤드에서 마지막으로 트리밍되지 않은 레코드 (샤드의 가장 오래된 데이터 레코드) 또는 가장 최근의 샤드의 데이터를 항상 읽도록합니다.

이다 ShardIteratorType = 'TRIM_HORIZON'을 설정

my_shard_id = 'shardId-000000000000' 

shard_iterator = kinesis_client.get_shard_iterator(StreamName=my_stream_name, 
                 ShardId=my_shard_id, 
                 ShardIteratorType='TRIM_HORIZON') 

에 나에게 새로운 소비자를 회전 할 수있는 즉, 유스 케이스 내 전체의 기초가 가장 오래된 항목부터 발전기를 제공해야 마지막 24 시간의 모든 사건을 처리하게하십시오. 순간 내가 여기에 나타 새 이벤트를 만들 그러나

그러나이 나를 위해 일하고, 나는 빈 기록을

{u'Records': [], 'ResponseMetadata': {'RetryAttempts': 0, 'HTTPStatusCode': 200, 'RequestId': 'e705d8f2-dd62-f0d5-b551-4dd5ace4499e', 'HTTPHeaders': {'x-amzn-requestid': 'e705d8f2-dd62-f0d5-b551-4dd5ace4499e', 'content-length': '284', 'x-amz-id-2': '5bI4T8k4DIpvCsBRUtMw1WFgWqa4tT5X8bUj9mg1NGUFMBZe36iqibCRjDHathIe4j6GbmI6v8A+9d1TiBtbGg7/Sn4GduQPDQ0HVpcP/sM=', 'server': 'Apache-Coyote/1.1', 'date': 'Sun, 08 Oct 2017 21:04:39 GMT', 'content-type': 'application/x-amz-json-1.1'}}, u'NextShardIterator': u'AAAAAAAAAAH1FwRBEtaHytINAF8WzGDaKRaY5OEKCjFS+mKK5AQFqEf1SPJ8crMIMuBSNFOtfFn3KBT63r5f/bu40OLwhDztEbJgeYjciHVJERpFBDENiWOAZ760flMiZ0mXwCGfFW8cq/8hVC/qiwg1yF96+ujIIAz4vzvK7N944LBB2vH35+8noU/FBK9LCHLOxXxNAQXoOarcEPEU6jt112kOwEyT', u'MillisBehindLatest': 0} 
{u'Records': [], 'ResponseMetadata': {'RetryAttempts': 0, 'HTTPStatusCode': 200, 'RequestId': 'c51c2d88-e979-8b07-9748-b8a598ff324c', 'HTTPHeaders': {'x-amzn-requestid': 'c51c2d88-e979-8b07-9748-b8a598ff324c', 'content-length': '284', 'x-amz-id-2': 'BE5rXnfii4ifLDlFuIHQxTBpUvhJ2MJKW92QjzDVFNUD4xRgIgcWhn89dA5EbdPo8HGb5MJDzZ+QfGqB9R4JykZmkvTgb3Fd9y9zaionRBk=', 'server': 'Apache-Coyote/1.1', 'date': 'Sun, 08 Oct 2017 21:04:44 GMT', 'content-type': 'application/x-amz-json-1.1'}}, u'NextShardIterator': u'AAAAAAAAAAEE0Qf0P4bXC7fg7yWj5SejVw9AIyN0iEnHWfj+nN8rIFSPwtDASvHIs+ZPcE2E7EU/gcvLqceWZ+GCptAnc6C3AzwsBK4HamaGCbV7K8l0fTnVMvErzboVGGqtAH4iHrimleGzUgJJ0TYgSDmPvdGDXCP+PRtwTFVGGZxK05jxTHf1qqOm74EfOMe65Bg+10MaNO4IO3NePm5lAy6AbQ/q', u'MillisBehindLatest': 0} 

를 얻을 수 없습니다.

스트림이 지난 24 시간 동안 보낸 모든 이벤트를 표시하려면이 항목이 필요합니다.

Answer 1

TRIM_HORIZON은 가장 오래된 항목부터 읽기 시작하지만 이전에 검사 점을 사용하여 중지 한 위치부터 시작합니다. DynamoDB에서 검사 점 테이블을 볼 수 있습니다.