aws kinesis get-records返回空数组 [英] aws kinesis get-records returns empty array

问题描述

我在玩Kinesis，我尝试了一个非常简单的示例

I am playing around with Kinesis, and I tried a very simple example

我首先放了一个样本记录

I first put a sample record

aws kinesis put-records --records "Data=Test data - hemant,PartitionKey=20150421" --stream-name mystream 

我回来了

{
"FailedRecordCount": 0,
"Records": [
    {
        "SequenceNumber": "49549975503580743304507290523786194552567002802960728066",
        "ShardId": "shardId-000000000000"
    }
]}

所以看跌期权似乎奏效了.现在，我试图检索此记录，首先，通过获取shard-iterator，然后使用返回的shard-iterator调用gert-record. get-shard-iterator返回

So put appears to have worked. Now I am trying to retrive back this record, first, by getting the shard-iterator, and then calling the gert-record using the returned shard-iterator. The get-shard-iterator returns

aws kinesis get-shard-iterator --stream-name cakestream --shard-id 0 --shard-iterator-type LATEST
{
"ShardIterator": "AAAAAAAAAAEna1yL0ccbircK95wu6WRfN7LamlaXL5bZ1GzaFrUcSU8S74o4Pus59Z0XmdaMamdvz4tv3qKuPxpomz/Eeg671gVUKNHUDruAKyA4pjWRP37VI1K5w/kLqpBo49YsCKHMxcduaN6GdeCXL4QMSgvH9Aqi7leRuIr2T1w4MeqjhlcM1iz8icaWGlHfUVCbgtY="}

现在我尝试使用该分片迭代器获取记录

And now I try to get the records using that shard-iterator

aws kinesis get-records --shard-iterator "AAAAAAAAAAEna1yL0ccbircK95wu6WRfN7LamlaXL5bZ1GzaFrUcSU8S74o4Pus59Z0XmdaMamdvz4tv3qKuPxpomz/Eeg671gVUKNHUDruAKyA4pjWRP37VI1K5w/kLqpBo49YsCKHMxcduaN6GdeCXL4QMSgvH9Aqi7leRuIr2T1w4MeqjhlcM1iz8icaWGlHfUVCbgtY="{
"NextShardIterator": "AAAAAAAAAAE4lTq/jqanuj+xsULhl6QQeykzToObYDoaukearHkQfed/keYjgxzwfxkDXlBJBAOVLsk3pI9d0EwQWn5NmJ9poCL9M1wGDe2M42fgmp1EdK0WJGI1zG7TMi8m1bGQ6qDL05zf7gCtK5/xod6Vw/Gr98bsdQ8Ewp3U57FuHxZ29LUUbYp3AoN7CbUTD5rtqzU=",
"Records": []}

所以，我的问题是为什么我不找回数据?

So, my question is why am I not getting back my data?

推荐答案

最新的分片迭代器将在创建后 返回流中的所有记录.

The LATEST shard iterator will return all records put into the stream after it was created.

因此，如果您想查看记录，则必须在创建迭代器后将其放入，然后请求获取记录.

So, if you'd like to see your records, you'll have to put them after you create the iterator, and then request for get-records.

这篇关于aws kinesis get-records返回空数组的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！