如何在节点 JS 中监听来自 SQS 的消息？

Question

我正在尝试使用与设置侦听器的 RabbitMQ 或 Kafka 相同的方式使用 SQS。

但我在他们的文档中没有看到为 SQS 设置侦听器的方法：

我能够收到类似的消息：

 const client = new SQSClient({
    region: 'ap-south-1',
    credentials: {
      accessKeyId: process.env.AWS_ACCESS_KEY!,
      secretAccessKey: process.env.AWS_SECRET_KEY!,
    },
  })

  const command = new ReceiveMessageCommand({ QueueUrl: process.env.SQS_URL! }) 
  const data = await client.send(command)
  console.log(data) // ???? here 

但这是一次，我怎样才能设置一个主动监听器，或者：

• 不断收听（我怀疑 SQS 提供）
• 或在某个区间函数中不断检查新消息

谢谢，希望得到帮助

Answer 1

我正在研究同样的问题并遇到了这个 npm 包 sqs-consumer.

根据文档：“ ... • 使用长轮询连续轮询队列中的消息。 ……”