可以使用AWS Eventbridge将SQS消息传递给其他AWS服务吗？
我想在收到SQS消息时触发一种机制，在该机制中，它会将此消息的内容传递到其他AWS服务，如DynamoDB、Kinesis和SNS。
现在可以做吗？目前，我能够从EventBridge中的SQS中捕获的唯一事件是SQS队列属性更改。如果可能，我可以在将此消息传递到其他流之前处理它吗？
如果不可能，有哪些替代方案？Lambda函数会在收到SQS消息时触发哪个？
共有1个答案
是的，当SQS收到新消息时，您可以触发lambda函数。对消息进行处理，然后将其转发到下一个服务。如果您将该消息扇出到多个服务，那么您可以使用SNS，或者如果只是想要一个特定的目标服务，那么您也可以使用Eventbridge。我希望这能有所帮助。
-
我的公司有一个消息传递系统，它以JSON格式发送实时消息，它不是建立在AWS上我们的团队试图使用AWS SQS接收这些消息，然后用DynamoDB存储这些消息，我想用EC2读取这些消息，然后保存它们，有什么更好的解决方案吗？或者怎么做我没有很好的经验
-
FCM服务未向我的iOS应用程序发送消息。 > App CAN成功接收APNs令牌和实例ID令牌 App CAN使用推送通知实用程序利用. p8令牌在后台成功接收来自APN的推送 #2中使用的相同APNs密钥上传到Firebase控制台 应用程序无法接收Firebase控制台中Notification Composer发送的消息，也无法使用CURL请求接收消息。 应用程序在通过FCM发送时不显示任
-
我对尝试将微服务/SOA作为一种体系结构非常感兴趣，并且很难对服务之间的集成进行概念化。 我喜欢使用消息传递将客户端与服务分离的想法，但不理解系统如何独占地使用它。典型的异步操作和发布/订阅显然是有意义的——比如创建新订单、广播数据以进行报告等。我不明白的是，人们是否通常尝试在常见的请求/回复场景中使用消息传递——例如，用户点击他们的“个人资料”页面，而需要在页面上呈现的部分数据来自用户服务。 我
-
我有一个工作人员运行在弹性Beanstalk上，它通过来自队列的消息接受POST请求。这些消息触发了耗时数分钟（有时甚至数小时）的长操作，并且该操作必须只执行一次。 问题是，当我登录到worker控制台查看进程时，消息似乎每分钟都在一遍又一遍地传递（接收请求触发的方法每分钟都被调用）。我怎样才能摆脱这种行为呢？ 我阅读了文档，并将服务队列和死信队列的可见超时周期都设置为最大值（12小时）。然而，这
-
我们有基于微服务架构的应用程序的第一个版本。我们使用REST进行外部和内部通信。 现在我们想从 CP（CAP 定理）* 切换到 AP，并使用消息总线在微服务之间进行通信。有很多关于如何基于 Kafka、RabbitMQ 等创建事件总线的信息。但是我找不到任何结合 REST 和消息传递的最佳实践。例如，您创建一个汽车服务，您需要添加不同的汽车组件。为此，将 REST 与 POST 请求一起使用会更有
-
我想在SQS上发布一条消息，并在几个小时后处理该消息。 如何根据某些属性安排消息传递或从SQS中选择消息？ 我已经实现了一个SQS消费者，但我正在接收来自SQS队列的每条消息。有可能在SQS上实现类似的功能吗？我正在考虑接收每条消息，如果还没到处理该消息的时间，就再次发送到队列。