SQS事件桥每分钟一次

Question

我们正在查看事件桥，以便每分钟向SQS添加一次预定任务。

我们正在寻找事件桥来实现它。到目前为止，它正确地将消息放入队列中，但我们尝试将其安排为每分钟一次，并注意到队列每五分钟只接收一次消息，有时是六分钟。

这些指标似乎表示调用正在发生；但是，队列没有在指定的时间框架内接收它们。

考虑因素

• SQS FIFO队列-重复数据消除

在规定的时间间隔内看不到消息的“duh”是因为AWS文档中的这一点：

用于删除重复发送的消息的令牌。如果成功发送了具有特定消息重复删除ID的消息，则成功接受了使用相同消息重复删除ID发送的任何消息，但在5分钟重复删除间隔内没有发送

对建议持开放态度，并将寻找解决方法。

使现代化

我尝试使用输入变压器来修复，通过添加时间作为队列消息中唯一更改的项目；然而，仍然没有低于5分钟。

可变输入

{"addedOn":"$.time"}

消息

{"AddedOn":<addedOn>}

Answer 1

SQS中内置的队列轮询并没有轮询我更新的超过10条消息的计数。一旦我删除了旧的消息，时间是正确的，它每分钟更新1次。

答案是，如果要使用常量字符串，那么它必须用于大于5分钟的计划作业。

在这里添加信息，尽管链接谷歌搜索的问题冗余：

用于删除重复发送的消息的令牌。如果成功发送了具有特定消息重复删除ID的消息，则成功接受了使用相同消息重复删除ID发送的任何消息，但在5分钟重复删除间隔内没有发送

尽管消息是每分钟一次的唯一事件，但不唯一的常量（JSON文本）仍然将其视为要删除的副本。

为了解决我切换到输入变压器

示例事件以及可以添加为变量的其他字段：

{
 "version": "0",
 "id": "7bf73129-1428-4cd3-a780-95db273d1602",
 "detail-type": "EC2 Instance State-change Notification",
 "source": "aws.ec2",
 "account": "123456789012",
 "time": "2015-11-11T21:29:54Z",
 "region": "us-east-1",
 "resources": [
 "arn:aws:ec2:us-east-1:123456789012:instance/i-abcd1111"
 ],
 "detail": {
 "instance-id": "i-0123456789",
 "state": "RUNNING"
 }
}

我需要一个唯一的变量，所以时间是一个明显的选择。

输入变压器的输入

输入路径：

{"addedOn":"$.time"}

模板：

{"AddedOn":<addedOn>}

文档

此外，发现如果不使用FIFO队列对未来的SQS开发人员来说也是一个简单的选择，那么转向不使用FIFO队列是一个潜在的解决方案。