这里有人有使用 Django 实现 pika 的经验吗?我基本上是使用 django rest 框架运行基于事件的微服务。并使用 RabbitMQ 作为消息总线。我知道在这种情况下使用的默认库是 Celery,但我正在寻找一个更轻的版本,我可以在消息上实现一个简单的 pub/sub。
以前有人用 pika 实现过这样的服务吗?我的问题是你如何将 pika 作为一个单独的进程与 Django 一起生成?还是有更优雅的解决方案?
提前致谢。
- - 更新 - -
我们最终做的是:
对于发布者:
- 我们生成了一个单独的线程(如果您需要发布大量/秒,则可以创建多个线程)来保持 pika 连接处于活动状态。
对于订户:
- 我们生成一个单独的工作进程(在一个单独的容器中),它具有 django 上下文(使用 django.setup()),它使用来自 RabbitMQ 的消息