事件集线器发送速度快,但获取速度慢。我使用下一个代码:
subscribe(cb: (event: any) => Promise<void>) {
this.consumerClient.subscribe(
this.config.partitionId,
{
processEvents: async (events: any, context: any) => {
if (events.length === 0) {
return;
}
for (const event of events) {
await cb(event.body);
}
await context.updateCheckpoint(events[events.length - 1]);
},
processError: async (err, context: any) => {
console.error(`Event Hub Subscribe Error`, { err, context });
},
},
{ startPosition: earliestEventPosition },
);
}大约需要1分钟才能完成100项赛事。await cb(event.body);工作得很快。
发布于 2022-05-10 06:35:29
问题必须来自源端,而不是事件中心,因为它正在以预期的速度发送数据。
以下是根据性能和吞吐量结果提出的一些建议:
参考活动中心和Azure功能的性能和规模,了解如何提高性能的更多信息。
https://stackoverflow.com/questions/72130753
复制相似问题