Nodejs Kinesis 客户端失败，线索不多

Question

我正在编写一个简单的 nodejs kinesis 生产者客户端，它失败了，没有任何有用的信息。这是代码：

const { Kinesis, PutRecordsCommand } = require("@aws-sdk/client-kinesis");

const kinesis_client = new Kinesis({
    region: 'us-east-1'
});

/**
 * 
 * @param {*} streamName 
 */
async function kinesis_pushdata() {

    const params = {
        StreamName: "course-progress",
        Records: [
        {
            Data: JSON.stringify({
            'record' : 'sample record'
            }),
            ParitionKey: 1
        }
        ]
    };

    try {
        const data = await kinesis_client.send(new PutRecordsCommand(params));
        console.log(data);
      } catch (error) {
        console.log(error);
      }
      
}

kinesis_pushdata();

凭据配置为从配置文件中获取。当我运行这个时，我得到一个 TypeError “ TypeError: Cannot read 属性 'byteLength' of undefined ”，对发生的事情没有太多线索。

任何指点都会很有帮助。

谢谢

Answer 1

AWS Kinesis 期待以下形式的数据

{
...
 {
  Data: Buffer.from( JSON.stringify({...}) )
 }
}

查看AWS文档docs

Nodejs Kinesis 客户端失败，线索不多

Nodejs Kinesis Client fails with not much clue

node.js

amazon-web-services

amazon-kinesis

producer