Nodejs Kinesis 客户端失败,线索不多
Nodejs Kinesis Client fails with not much clue
我正在编写一个简单的 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 ”,对发生的事情没有太多线索。
任何指点都会很有帮助。
谢谢
AWS Kinesis 期待以下形式的数据
{
...
{
Data: Buffer.from( JSON.stringify({...}) )
}
}
查看AWS文档docs
我正在编写一个简单的 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 ”,对发生的事情没有太多线索。
任何指点都会很有帮助。
谢谢
AWS Kinesis 期待以下形式的数据
{
...
{
Data: Buffer.from( JSON.stringify({...}) )
}
}
查看AWS文档docs