NodeJS SQS:传输中的消息太多

vmdwslir  于 2023-03-07  发布在  Node.js
关注(0)|答案(1)|浏览(122)

我有一个SQS消费者(https://github.com/bbc/sqs-consumer)在EC2计算机上运行(t2.medium)。这个过程只有一个示例在运行。但是,当我打开SQS Jmeter 板时,我看到有30多条消息在运行。这是一个FIFO队列,具有基于MessageGroupId的重复数据删除。我没有使用库提供的任何批处理,正如库教程所示,只是简单的消费者一次一条消息。我在这里错过了什么?
担心的原因是我在处理消息时收到了很多超时错误(我正在使用Puppeteer打开网站并检查网站上的链接)--我正在尝试缩小原因范围--而t2机器网络带宽过载可能是其中之一(我认为)。

lc8prwob

lc8prwob1#

我意识到我忘记为消息处理程序添加Promise.resolve(),并且消息没有正确地从队列中移除。

相关问题