从 aws kinesis 数据流中检索记录时出现问题

Question

我尝试使用以下 aws cli 命令在 aws kinesis 数据流中添加记录，

请求：

aws kinesis put-record --stream-name Live_DataStream  --partition-key 123 --data testdata

回应：

{ "ShardId": "shardId-000000000001", “序列号”：“49583432609061722809096316034912211811585750778783989778” }

但是当我尝试从数据流中获取记录时，记录是空的

请求：

aws kinesis get-records --shard-iterator AAAAAAAAAAGoE8kuRTLaqFMdZQVydTXl5P3B1+KHP4k66Kj1EXirRlqAliCFLRrKC43hcilLXz/D//9Mr27TqLxxRtFqSnOeijhCuTasgcQizgHSTdMlxaw2NF25ToInQ8rXQ37JOfHztOER5TkRsYD4fzZmERsT+vbseCCIJ+XLbKopo8hYpVbFCVwJzhg9W4GH2TjyxQH1yDhCO16/SsXS5GGWKhlO

回应：

{ “记录”： []， “NextShardIterator”： “+ AAAAAAAAAAHi88xL082GH7oCyl + FxrNw8utchS 7mQx / gInRUnNcLu5vUc / Zqs78hOjbdwsszUZlghsT1b4N6Au9LJRnY5xe0CRZFG4bnq100r6NkeHIBxvt1WgvLbVD372ZOCvqa1JKyp0Tl3 / qJKzL57W48H2pzwjFn6kxrWXESj2TN + Xs5J + DK6mUIARfsTUfdvPK15JEGQjJGXapZyEs9l9BJh3Y”， “MillisBehindLatest”：0 }

我尝试了很多次，但记录仍然是空的，并且没有检索到“测试数据”。请为我提供解决此问题的解决方案

Answer 1

如何获得分片迭代器？可能您正在获取在插入的元素之后指向一个元素的迭代器，尝试使用“TRIM_HORIZON”，它应该可以工作。