为什么找不到我的celery配置文件？
/home/myuser/mysite-env/lib/python2.6/site-packages/celery/loaders/default.py:53: NotConfigured: 找不到 celeryconfig.py 模块！请确保其存在并对 Python 可用。（NotConf...
单元测试Flask视图模拟Celery任务
我有一个Flask视图，它将一个celery任务添加到队列中，并向用户返回200。from flask.views import MethodView from app.tasks import launch_task class ExampleView(MethodView): d...
在Celery中如何对多个队列进行优先级排队？
我们正在使用celery来处理异步后台任务，并为不同优先级的任务设置了2个队列。我们有两个节点集群分别提供服务。目前一切正常，效果符合预期。 问题： 我们大多数时候都会获得低优先级的任务。为了优化资源利用，我想知道是否有一种方法可以配置worker（监听高优先级队列）来同时监听两个队列，但只...
如何清理Celery任务元数据？
我一直在阅读django-celery，试图找到一种本地方法来清理celery_taskmeta，以便在生产环境中这个表不会过度增长。 但是我什么也没有找到。我应该做一个命令来处理这个问题吗？
Celery CRITICAL/MainProcess] 无法恢复的错误：AttributeError("'float' object has no attribute 'items'",)
我一直在使用三个分别独立的docker容器（flask应用程序、celery worker和redis）运行我的flask应用程序，并且没有遇到任何问题。 这是我如何启动它的： celery worker -A app.controller.engine.celery -l info --...
从一个Docker容器连接到另一个容器
我希望在一个Docker容器中运行rabbitmq-server，并使用celery（http://celeryproject.org/）从另一个容器连接到它。 我已经使用以下命令运行了rabbitmq... sudo docker run -d -p :5672 markellul/ra...
在Heroku Django中无法导入名称为_uuid_generate_random的内容。
我正在开发一个项目，它会扫描用户的Gmail收件箱并提供报告。我已经在Heroku上部署了该项目，并使用以下规格： 语言：Python 2.7 框架：Django 1.8 任务调度程序：Celery（使用Rabbitmq-bigwig作为代理URL） 现在在Heroku执行时，Cele...
Celery任务运行更多的任务
我正在使用celerybeat来启动一个主任务，该任务会启动许多次要任务。我已经编写好了这两个任务。 有没有一种简单的方法可以做到这一点？Celery是否允许从任务中运行任务？ 我的示例：@task def compute(users=None): if users is None: ...
每次重试周期增加celery重试时间
我像文档示例一样使用celery进行重试：@task() def add(x, y): try: ... except Exception, exc: add.retry(exc=exc, countdown=60) # override th...
如何设置 Celery 调用自定义工作初始化？
我对Celery还比较陌生，我一直在尝试使用两个独立的队列（一个用于计算，另一个用于执行）来设置项目。目前为止，一切都很好。 我的问题是，执行队列中的工作程序需要实例化一个具有唯一object_id的类（每个工作程序一个id）。我想知道是否可以编写自定义工作程序初始化来初始化对象，并将其保存...