我有一个外部数据源作为ActiveMQ主题。我只能连接和使用消息。它们很少出现，大约每 10-10 秒 30 条消息。
我想收集所有消息并将它们放入数据库。我还想要一个活跃的网页，可以通过 WebSocket 接收新消息并绘制图表。
我有一个用Python/Flask/MongoDB/SocketIO构建的原型，但是...
我想使用 Amazon AWS 云基础设施来避免处理服务器上的数据。
我相信 AWS Lambda 可以接受消息并将其存储到数据库 （DynamoDB？） 中，还可以发送转换为 WebSocket 消息的通知（可能使用 SQS）。（那里还不是所有的事情都清楚，也许简单的 ajax 轮询就足够了）。
这里有一个问题：如何使用来自外部 ActiveMQ 主题的消息并使用 AWS Lambda 对其进行处理？
我正在寻找 Kinesis，但它看起来只支持推送到它的数据，但不支持通过某些协议轮询数据......
您可以将 Lambda 用作类似 cron 的工具并按计划进行轮询。请参阅 Lambda 计划事件。