Django-celery: 未配置结果后端
我正在尝试在我的项目中使用django-celery。 在settings.py文件中，我有以下代码：CELERY_RESULT_BACKEND = "amqp" 服务器正常启动python manage.py celeryd --setting=settings 但是如果我想要访问延迟任务...
如何在django-celery中判断任务是否已经排队？
这是我的设置： django 1.3 celery 2.2.6 django-celery 2.2.4 djkombu 0.9.2 在我的settings.py文件中，我有：BROKER_BACKEND = "djkombu.transport.DatabaseTransport" 即...
Celery - 找不到模块名为five
将celery和django-celery更新至3.1版本后：$ pip freeze | grep celery celery==3.1.18 django-celery==3.1.16 当我开始启动我的服务器时，我遇到了这个错误：Traceback (most recent call la...
Celery：具有并发性和保留任务的工作程序仅运行1个任务
我的代码中有些任务执行的时间越来越长。 仔细检查后发现，尽管我将工作节点设置为并发为6，并且存在6个进程“执行工作”，但只有1个任务显示在“运行任务”下。这里是一个小小的视觉证明： 这是工作者选项： 这是那个工作者的任务选项卡，只有1个运行进程： 我发现，如果我重新启动cele...
重试Celery链中失败的任务
我有一个celery链，它运行一些任务。每个任务都可能失败并重试。请参见下面的快速示例：from celery import task @task(ignore_result=True) def add(x, y, fail=True): try: if fail: ...
如何使用Celery、RabbitMQ和Django确保每个用户的任务执行顺序？
我正在运行Django、Celery和RabbitMQ。我想要实现的目标是确保与一个用户相关的任务按顺序执行（具体来说，一次只执行一个任务，我不希望每个用户同时执行多个任务）。 当为用户添加新任务时，它应该依赖于最近添加的任务。额外的功能可能包括如果此类型的任务已经为该用户排队并且尚未启动...
Django中的后台处理无需Celery
我有一个Django网站的极小部分，用于在两个用户之间维护一个经过审核的聊天会话状态。基本上，第一个用户讲话3分钟（其他人不能讲话），然后第二个用户讲话，接着是30秒的暂停，再重复一次这个过程。我目前正在使用数据库和“RoomState”模型来管理房间的当前状态（谁可以说话等）。状态转换受到客...
无法使用celery delay保存表单：对象不可JSON序列化
使用Django 1.8，在视图中保存表单后，我想触发一个延迟的celery函数。 def new_topic(request, forum_id): form = TopicForm() uid = request.user.id if request.method...
停止Supervisor并不能停止Celery workers
如何确保在停止Supervisord时，子进程也被停止？我正在使用Supervisord运行两个Celery工作进程。每个工作进程的命令如下:command=/usr/local/myapp/src/manage.py celery worker --concurrency=1 --logle...
Celerybeat未执行定期任务
你如何诊断manage.py celerybeat为什么无法执行任何任务？ 我通过以下命令在supervisord下运行celerybeat：/usr/local/myapp/src/manage.py celerybeat --schedule=/tmp/celerybeat-schedu...