我正在尝试订阅Kinesis Shard的活动。但是SubscribeToShardCommand
的执行挂起了5分钟(订阅超时),然后抛出一个错误:
(node:2667) UnhandledPromiseRejectionWarning: SyntaxError: Unexpected token in JSON at position 0
at JSON.parse (<anonymous>)
at /home/mjpolak/Documents/company/project/node_modules/@aws-sdk/client-kinesis/protocols/Aws_json1_1.ts:4020:19
at processTicksAndRejections (internal/process/task_queues.js:88:5)
at Object.deserializeAws_json1_1SubscribeToShardCommand (/home/mjpolak/Documents/company/project/node_modules/@aws-sdk/client-kinesis/protocols/Aws_json1_1.ts:2583:21)
at /home/mjpolak/Documents/company/project/node_modules/@aws-sdk/middleware-serde/src/deserializerMiddleware.ts:20:18
at /home/mjpolak/Documents/company/project/node_modules/@aws-sdk/middleware-signing/src/middleware.ts:26:22
at StandardRetryStrategy.retry (/home/mjpolak/Documents/company/project/node_modules/@aws-sdk/middleware-retry/src/defaultStrategy.ts:125:38)
at /home/mjpolak/Documents/company/project/node_modules/@aws-sdk/middleware-logger/src/loggerMiddleware.ts:21:20
at /home/mjpolak/Documents/company/project/kinesis-subscribe.ts:85:29
我正在寻找帮助,让我订阅成功。
完整代码:
const { StreamDescription } = await client.send(
new DescribeStreamCommand({
StreamName: 'streamName',
}),
);
const { StreamARN } = StreamDescription;
const { Consumers } = await client.send(
new ListStreamConsumersCommand({
StreamARN,
}),
);
let Consumer = Consumers.find((x) => x.ConsumerName == 'tester');
if (Consumer == null) {
const consumerData = await client.send(
new RegisterStreamConsumerCommand({
ConsumerName: 'tester',
StreamARN,
}),
);
Consumer = consumerData.Consumer;
}
console.log(`StreaARM: ${StreamARN}`);
console.log(`Consumer: ${Consumer.ConsumerARN}`);
const { EventStream } = await client.send(
new SubscribeToShardCommand({
ConsumerARN: Consumer.ConsumerARN,
ShardId: 'shardId-000000000000',
StartingPosition: {
Type: 'LATEST'
},
}),
);
console.log("Consuming");
通过调查Wireshark的通信,我可以确认HTTP连接已建立,并且AWS将一些数据推送到我的客户端。因此,我猜测客户端库中存在某种错误,它保留块而不是返回结果。
我还在SDK存储库上创建了错误:https://github.com/aws/aws-sdk-js-v3/issues/2418
发布于 2021-05-26 16:35:14
日志显示JSON解析抛出了错误,当您收到HTML或XML格式的响应,但预期的是JSON响应时,就会发生这种情况。尝试在控制台上记录响应,并查看其格式是否正确。
https://stackoverflow.com/questions/67637061
复制