使用Celery运行“唯一”任务
我使用celery来更新我的新闻聚合网站中的RSS源。我为每个源使用一个@task，事情似乎进展顺利。 然而，有一个细节我不确定是否处理得好：所有的源都会使用@periodic_task每分钟更新一次，但是如果一个源在上一个定期任务仍在更新时启动了新的任务怎么办？（例如，如果该源非常缓慢或离...
Celery AttributeError: 异步错误
我在我的 Mac (OS/X 10.13.4) 上本地运行 RabbitMQ 和 Celery，当我运行 add.delay(x,y) 时，下面的代码在本地工作：#!/usr/bin/env python from celery import Celery from celery.utils....
如何动态地向Celery（celerybeat）添加/删除周期性任务
如果我有一个定义如下的函数：def add(x,y): return x+y 有没有一种方法可以在运行时将此函数作为celery周期性任务动态添加并启动它？我希望能够像这样做（伪代码）：some_unique_task_id = celery.beat.schedule_task(add,...
Django Celery - 无法连接到 amqp://guest@127.0.0.8000:5672//
我正在尝试设置Django-Celery。我正在按照教程进行操作 http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html 当我运行以下命令： $ python manage.py celery...
Celery任务运行更多的任务
我正在使用celerybeat来启动一个主任务，该任务会启动许多次要任务。我已经编写好了这两个任务。 有没有一种简单的方法可以做到这一点？Celery是否允许从任务中运行任务？ 我的示例：@task def compute(users=None): if users is None: ...
在Heroku Django中无法导入名称为_uuid_generate_random的内容。
我正在开发一个项目，它会扫描用户的Gmail收件箱并提供报告。我已经在Heroku上部署了该项目，并使用以下规格： 语言：Python 2.7 框架：Django 1.8 任务调度程序：Celery（使用Rabbitmq-bigwig作为代理URL） 现在在Heroku执行时，Cele...
如何在不同的机器上设置celery工作进程？
我刚开始接触 celery。我知道如何安装和运行一个服务器，但我需要将任务分配到多台机器上。 我的项目使用 celery 将传递给 Web 框架的用户请求分配给不同的机器，然后返回结果。 我阅读了文档，但里面没有提到如何设置多台机器。 我错过了什么？
Celery工作者数据库连接池
我使用独立的Celery(不在Django中)。我计划在多台物理机器上运行一个工作任务类型。该任务执行以下操作： 接受XML文档。 进行转换。 进行多个数据库读取和写入。 我正在使用PostgreSQL，但同样适用于使用连接的其他存储类型。过去，我使用过数据库连接池来避免在每个请求上创...
Django，ImportError：无法导入名为Celery的模块，可能是循环导入？
我在这里参考了这个例子： http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html 我的所有任务都在名为 tasks.py 的文件中。 在更新了 celery 并添加了来自示例的文件后，无论我尝...