gpt4 book ai didi

amazon-kinesis - 分片 [shardId-000000000000] 未关闭。如果我们在重新分片操作正在进行时构建了分片列表,就会发生这种情况

转载 作者:行者123 更新时间:2023-12-04 23:00:19 24 4
gpt4 key购买 nike

从 Amazon kinesis Stream 获取数据时出现此错误。
我正在做以下步骤

  • 创建亚马逊 kinesis Steam
  • 使用 putRecord 放置数据AmazonKinesisClient的api .
  • 然后使用 Worker Of KCL 库从流中获取数据。
  • 最佳答案

    有几种可能性。

  • 在您下令创建流后,您是否等待完成的时间足够长?有时,创建分片可能需要 10 分钟。由于您设法使用了 putRecord方法,流和分片应该是事件的。
  • 您是否正确配置了 DynamoDB?我假设您将它用于 Kinesis 应用程序同步。查看 DynamoDB 表的内部记录。所有列(即leaseKey、checkpoint、leaseOwner、parentShardId 等)是否正确填写?也许数据库中的数据很旧,所以您可能正在访问一个封闭的分片?

  • 你提到的异常(exception)在这里: https://github.com/awslabs/amazon-kinesis-client/blob/master/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncer.java#L193

    尝试删除 DynamoDB 表并让 Kinesis 应用程序 (KCL) 创建一个全新的表。
    链接: https://console.aws.amazon.com/dynamodb/

    关于amazon-kinesis - 分片 [shardId-000000000000] 未关闭。如果我们在重新分片操作正在进行时构建了分片列表,就会发生这种情况,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27470660/

    24 4 0
    Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
    广告合作:1813099741@qq.com 6ren.com