Python 在数据处理节点中嵌入 Web 服务器

Question

我正在开发一个带有简单事件循环的 Python 2.7 项目，该循环检查各种数据源（rabbitmq、mongodb、postgres 等）的新数据、处理数据并将数据写入下一阶段。

我想在应用程序中嵌入一个 Web 服务器，以便它可以接收简单的 REST 命令，用于关闭、诊断等。

但是，通过阅读有关可用 Web 服务器的文档，并不清楚它们是否允许上述事件循环在 Web 服务器的事件循环之外运行。 IE。看起来我必须做一些事情，比如使用 REST 调用启动事件循环，并让循环在 io 线程或类似线程上运行。

谁能解释一下哪种嵌入式服务器（cherrypy、bottle、flask 等）/并发框架（tornado、gevent、twisted 等）最适合这个问题？

提前谢谢你！

Answer 1

我建议您为您的应用程序使用一个单独的进程，该进程将接收 REST 命令（使用 Pyramid 或 Flask），并让它通过 RabbitMQ 将消息发送到实时部分。我喜欢 Kombu 本人与 RabbitMQ 的接口，并且您的消息总线将很好地将您的 web/rest 需求与事件驱动的需求分离。您的事件驱动部分只是从总线上获取消息，并且不需要了解任何有关 REST 的信息。