问题标签 [aws-event-bridge]

We are looking at Event Bridge to give us a scheduled task added to our SQS once per minute.

We are looking at Event Bridge to make it happen. So far it properly puts messages into the queue, but we are trying to schedule it for once per minute and noticing that the queue only gets messages once per five minutes sometimes six minutes.

The metrics seem to state invocation is happening; however, the queue isn't receiving them in the time frame specified.

Considerations

• SQS FIFO Queue - Deduplication
• Constant JSON String

The "duh" of not seeing messages at prescribed interval is because of this in the AWS documentation:

The token used for deduplication of sent messages. If a message with a particular message deduplication ID is sent successfully, any messages sent with the same message deduplication ID are accepted successfully but aren’t delivered during the 5-minute deduplication interval

Open to suggestions and will be looking for a workaround.

Update

I tried using Input Transformer to fix by adding the time as uniquely changing item in the queue message; however, still not getting below 5 minutes.

Variable Input

Message

我正在尝试将 AWS EventBridge 与 SNS 目标一起使用，并且我已经获得了发送基本消息 SNS 和输入转换器的基本集成。但是，我希望能够设置 SNS 消息属性（用于订阅过滤）并理想地以 JSON 格式提供消息，因此每个 SNS 订阅（SMS、电子邮件）等的消息都不同。

这甚至可能吗？我一直无法找到明确的文档页面来说明 EventBridge 和 SNS Target 支持的范围。它只是一个基本信息吗？

我可以通过使用 Event Bridge => Lambda => SNS 来实现这一点，但我试图避免额外的跳跃。有没有人有任何关于 SNS 目标正式支持 Event Bridge 的确切信息？

我在 AWS Lambda 中开发了一个推送通知引擎，使用 One Signal over https，它工作得很好。我可以根据传入的 IoT 规则触发通知，并将它们近乎实时地发送出去。

导致此代码运行的条件每天可以触发多次。问题是，在某些情况下，我每天最多只需要发送一次通知，有时只有在之前的通知已发送给该用户的情况下。我想我的问题是存储状态的最佳位置在哪里？

1. 有没有一种方法可以以幂等的方式安排通知，以便后续调用不会发送多个，而是会相互覆盖，并只导致一个调用？可以以某种方式使用 SNS 吗？

2. 另一个想法是使用设备阴影。这是一种可能的解决方案，其中状态可以存储在那里并用于确保在需要时一次且仅一次发送第一个通知，并在需要时升级以发送更严重的通知？

我正在尝试构建一个架构，其中单个 Lambda 按计划触发，具有多个参数集。因此，例如，如果我有三组参数并将计划设置为十分钟，我希望每十分钟执行三次。

有没有办法使用自定义属性触发 EventBridge 计划事件，以便我可以将参数传递给 Lambda？我注意到事件模式中的details属性，但找不到任何关于它在预定事件中的使用的参考。

当我将 code.zip 上传到 s3-bucket 或使用 aws cli (aws s3 cp) 复制 code.zip 时，我的 CodePipeline 没有被触发。

Cloudformation 事件规则片段：

触发角色策略：

事件模式：

这里缺少什么？或者任何人对如何进一步调试有任何指示？

我正在尝试构建一个无服务器异步轮询服务来触发异步数据请求，等待它完成（通过定期尝试），然后在准备好后轮询响应。

理想情况下，我会使用 Lambda 触发数据请求并推送 EventBridge 的事件，以便稍后由另一个 Lambda 处理，该 Lambda 查询 API 以查看响应是否准备好，如果没有 - 将新事件推送到 EventBridge 稍后再试。为此，我需要一种方法让 EventBridge 在向前转发事件之前等待。我正在尝试提出一个不需要 Lambda 空闲时间的解决方案。

有没有办法让 EventBridge 在事件被推送之前等待它？或者设置一个一次性的预定事件？

我在带有事件模式的 aws 事件桥中创建了一个事件规则：

目标是 CloudWatch 日志组。现在，当我在存储桶级别更改某些内容时，例如存储桶权限，然后我看到在云手表中捕获了一个事件，但是当我在 s3 存储桶中添加/删除文件时，什么也没有发生。这里有什么问题？

我正在尝试创建一个 EventBridge 事件模式，该模式仅在“阶段”数组中的一个对象的“阶段上下文”中存在特定字符串时才匹配 CodeBuild 状态更改。

我一直无法找到如何匹配对象数组中的单个对象属性的示例。是否可以？我知道我可以寻找匹配 CodeBuild 阶段更改事件，但如果可能的话希望避免这种情况。

我在下面的示例 CodeBuild 状态更改事件中标记了要匹配的字符串：

我不太清楚，当 ECR 扫描返回发现任何级别的漏洞时，触发 EventBridge 规则所需的事件模式是什么。任何人都可以分享一个允许这样做的事件模式吗？

我有一个由EventBridge自定义总线触发的 lambda。我想在函数处理结束时向客户总线发送另一个事件。我在 lambda 中创建了一个目的地以发送到相同的自定义总线。

我有以下代码，函数处理程序将返回CloudWatchEvent。这是行不通的。