我有一个应用程序,它使用aws sqs和lambda来处理推送到队列上的消息。lambda继续轮询队列,当出现新消息时,它将处理该消息。对于这种情况,是否可以在aws上用kafka替换sqs。换句话说,我们可以使用kafka作为这个用例的队列吗?
odopli941#
你绝对可以。看看aws amazon managed streaming for apache kafka(amazon msk)。它是apachekafka的托管服务。至于lambda触发器,不幸的是它不是一个内置触发器。您可以通过使用周期性触发的lambda函数轻松复制行为,该函数检查消息是否可见,然后调用将处理消息或直接处理消息的函数。对于某些方向,您可以参考这个官方指南,它设置了一个类似的管道,但是对于aws mq。
1条答案
按热度按时间odopli941#
你绝对可以。看看aws amazon managed streaming for apache kafka(amazon msk)。它是apachekafka的托管服务。
至于lambda触发器,不幸的是它不是一个内置触发器。您可以通过使用周期性触发的lambda函数轻松复制行为,该函数检查消息是否可见,然后调用将处理消息或直接处理消息的函数。对于某些方向,您可以参考这个官方指南,它设置了一个类似的管道,但是对于aws mq。