代码之家  ›  专栏  ›  技术社区  ›  Vipul Sharma

从kinesis流读取数据时,NextSharedIterator从不返回null

amazon-kinesis aws-lambda amazon-web-services
  •  0
  • Vipul Sharma  · 技术社区  · 6 年前


    当我得到第一个迭代器时,我得到数据并使用NextShardIterator(在返回的数据中存在)递归地调用同一个函数。根据文档,当没有更多的数据可读取并且达到$latest时,NextShardIterator将返回null。

    我还尝试使用MillisBehindLatest在值为零时停止读取,但在某些情况下也失败了。

    有没有一个正确的方法来获取基于时间戳的动觉数据?

    0 回复  |  直到 6 年前
        1
  •  1
  •   user1234    6 年前

    NextShardIterator仅在到达已关闭碎片的末尾时返回null(在使用UpdateShardCount、SplitShard或MergeShard更新碎片计数的情况下)

    分片中开始顺序读取数据记录的下一个位置。如果设置为null,则碎片已关闭,请求的迭代器不会返回更多数据。“

    推荐文章
    Suhail Gupta  ·  运动流中的数据丢失。这可能是什么原因?
    8 年前
    ShaiNe Ram  ·  如何从s3 bucket读取数据到Kinesis流
    8 年前
    Hamed Minaee  ·  如何在aws kinesis数据分析的cloudformation中将目标设置为lambda
    8 年前
    Benjamin  ·  Amazon Kinesis流与Java流相比如何?
    8 年前
    JDev  ·  AWS RDS到AWS ES
    9 年前
    Spider  ·  AWS Java SDK通过一个请求获取许多Cloudwatch指标
    9 年前
    GihanDB  ·  不推荐使用AmazonKinesisClient构造函数
    9 年前
    SuSanD  ·  如何在KCL中重新排序异步发送的Kinesis事件
    10 年前
    Ryan Fisch  ·  处理Kinesis流时的AWS Lambda限制
    11 年前
    ecyshor  ·  Aws arn kinsis访问多个流
    11 年前
    关于   移动版
    代码之家 - 一站式码农服务社区
    沪ICP备11025650号