最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

订阅分片后无法从kinesis

网站源码admin29浏览0评论

订阅分片后无法从kinesis

订阅分片后无法从kinesis

我有一个运动数据流,其中 1 个分片只有一些数据,我目前正在通过订阅我的 nodejs 应用程序中的分片从中读取数据,但我无法这样做,因为它给了我这个错误: -

Error: TypeError: Cannot read properties of undefined (reading 'Symbol(Symbol.asyncIterator)')

这是我在下面编写的代码:-

const {
  KinesisClient,
  SubscribeToShardCommand,
  RegisterStreamConsumerCommand,
} = require("@aws-sdk/client-kinesis");

const kinesis = new KinesisClient({ region: "ap-south-1" });

const streamName = "<my-stream-name>"
const shardId = "<my-shardid>";

const readFromShard = async () => {
  const command = new SubscribeToShardCommand({
    StreamName: streamName,
    ConsumerARN: `<my-consumer-arn>`,
    ShardId: shardId,
    StartingPosition: {
      Type: "LATEST",
    },
  });

  try {
    const response = await kinesis.send(command);

    const subscriptionArn = response.EventStream;
    console.log("Subscribed to shard:", shardId);

    // Handle the received records
    for await (const record of response.Records) {
      console.log(record);
      // const payload = Buffer.from(record.Data).toString("utf-8");
      console.log("Received data:", payload);
    }

    // Subscription is closed, handle it as needed
    console.log("Subscription closed:", subscriptionArn);
  } catch (error) {
    console.error("Error:", error);
  }
};
readFromShard();

解决此错误的任何帮助将不胜感激。谢谢。

回答如下:

与本文相关的文章

发布评论

评论列表(0)

  1. 暂无评论