我应该如何处理代码中的 celeryd_multi 工作?
到目前为止,我只使用 python manage.py celeryd,像这样启动: python manage.py celeryd -l info --settings=settings 代码在我看来,这样做是这样…
RabbitMQ 和 Celery 的新手问题
今天早上我开始使用 Celery 和 RabbitMQ 并定义了一些基本任务来看看我的服务器的性能将如何提高。 我已经添加了我的rabbitmq 用户、虚拟主机并设置了…
celery+rabbitmq 空队列
我正在使用 celery+rabbitmq。我找不到在 celery+rabbitmq 中清除队列的便捷方法。我通过删除并创建虚拟主机来完成此操作。 rabbitmqctl delete_vhost…
为什么 MongoDB 无法识别我在 Celery 连接上的用户?
我在 DotCloud 托管上有一个带有 MongoDB 数据库的 Python/Flask Web 应用程序。 我想使用 MongoDB 服务作为 Celery 队列在 Python 服务上设置 Celery…
celery 任务中的翻译
我在一项任务中使用了 ugettext。我已经编辑了 po 文件。但这没有用。有谁知道为什么?谢谢! from django.utils.translation import ugettext @task …
django djcelery:构建事务性任务不会回滚
我正在尝试执行事务性任务,如果无法发送电子邮件,该任务将回滚数据库更新。 下面是我的代码,任何人都可以建议这里做错了什么? from celery.task i…
Celery result.get 超时
我有两个不同的 django 项目,分别是 projA 和 projB,每个项目都有自己的 celery 守护进程在不同的队列上运行,但相同的虚拟主机,projA 有一个任务 …
使用域套接字的 Python 兼容分布式消息/任务系统(如 Celery)
有没有像 Celery 这样的东西可以与 unix 域套接字一起使用?我当前的主机 (dreamhost) 禁止运行侦听 IP 套接字的服务器,因此我需要一些可以与域套接…
django-celery url 提供的数据存储在哪里?数据可用多久?内存消耗是多少?
我正在使用 django celery 启动一个项目,并对“djcelery.urls”提供的任务 url 进行 ajax 调用。 我想了解有关此数据的一些信息: 该信息存储在哪里…
我可以重新启动失败的 celery 任务吗?
我将 celery 与 djkombu 队列一起使用。 我已为我的任务设置了 max_retries=3。一旦第三次重试失败,它就会执行带有 status=FAILURE 的 after_return …
Pymongo、连接池和通过 Celery 的异步任务
我正在一个应用程序中使用 pymongo 访问 mongodb,该应用程序还使用 Celery 执行许多异步任务。我知道 pymongo 的连接池不支持异步工作人员(基于文档…