【问题标题】:How to subscribe a celery task to an existing RabbitMQ exchange?如何将 celery 任务订阅到现有的 RabbitMQ 交换?
【发布时间】:2019-10-25 15:09:34
【问题描述】:

我目前正在使用 GRPC/RabbitMQ 编写用于群聊的聊天信使。我在 Django/DRF 中有一个 API,用于处理身份验证/消息日志/文本和电子邮件警报等。

为此,我想创建一个订阅每个组消息交换的 celery 任务,但我不清楚是否有办法将 celery 任务绑定到消息交换。

创建订阅我创建的聊天交流的 celery 任务是否现实/可能?如果不是,您将如何解决/处理这些职责?

【问题讨论】:

  • 订阅是什么意思?你问的是可能的,但你能准确描述会发生什么吗?
  • 我最终解决了这个问题,有一个名为“yosun”的神奇包,它可以让你生成订阅队列的任务

标签: django rabbitmq celery grpc kombu


【解决方案1】:

快速跟进,我发现一篇文章详细介绍了使用 Kombu 和 Yosun 通过 Django 发布和/或订阅。

https://medium.com/@benjamin.pereto/microservices-with-django-events-with-publish-subscribe-9cad1c7aee39

超级有用!

【讨论】:

    猜你喜欢
    • 2021-03-02
    • 2017-10-29
    • 1970-01-01
    • 2011-07-18
    • 2011-07-17
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2017-10-04
    相关资源
    最近更新 更多