Celery自动重新加载在任何更改时
我可以让celery在settings.py中的CELERY_IMPORTS模块发生更改时自动重新加载。 尝试过使用母模块检测子模块的更改，但无法检测到子模块的更改。这让我了解到celery不会递归地进行检测。我查阅了文档，但没有找到解决我的问题的答案。 需要将所有与celery相关的部分...
如何在Celery中将定期任务发送到特定队列
默认情况下，Celery将所有任务发送到'celery'队列，但您可以通过添加额外参数来更改此行为： @task(queue='celery_periodic') def recalc_last_hour(): log.debug('sending new task') re...
如何记录在Django Celery任务中发生的异常？
我已按照他们的守护程序说明（http://docs.celeryproject.org/en/latest/tutorials/daemonizing.html#daemonizing）设置了 celery 以与我的 Django 应用程序一起使用。这是我的测试任务。@periodic_tas...
Celery - 链式组和子任务。-> 无序执行
当我有以下内容时 group1 = group(task1.si(), task1.si(), task1.si()) group2 = group(task2.si(), task2.si(), task2.si()) workflow = chain(group1, group2, t...
Django和Celery - 在更改后重新加载代码到Celery中
如果我在celery运行时更改了tasks.py文件，是否有机制可以重新加载更新的代码？还是我必须关闭Celery然后重新加载？ 我读过celery旧版本中有--autoreload参数，但是我在当前版本中找不到： celery: error: unrecognized arguments...
为什么CeleryCAM不能与Amazon SQS配合使用？
我正在使用Celery 2.4.6和django-celery 2.4.2。 当我按照这个问题的解决方案配置Celery来使用Amazon SQS时：Celery with Amazon SQS 我在Django管理页面的celerycam表中看不到任何内容。如果我切换回RabbitMQ，...
如何使用Celery和Django将任务路由到不同的队列
我正在使用以下技术栈： Python 3.6 Celery v4.2.1（Broker：RabbitMQ v3.6.0） Django v2.0.4。 根据Celery文档的说法，将定时任务运行在不同队列上应该很容易，只需要在CELERY_ROUTES中为任务定义相应的队列即可。然而，...
启动Celery时出现错误：AttributeError: 'module'对象没有属性'celery'。
我尝试从命令行启动Celery工作服务器： celery -A tasks worker --loglevel=info tasks.py 中的代码： import os os.environ[ 'DJANGO_SETTINGS_MODULE' ] = "proj.settings" ...
Django和Celery的例子：周期性任务
我一直在努力理解Django/Celery文档，但需要些帮助。 我想使用django-celery运行定期任务。我在互联网上（以及文档中）看到了几种不同的格式和模式，用于使用Celery实现这一点... 有人能提供一个基本的、可运行的django-celery定期任务创建、注册和执行的示例...
创建celery任务然后同步运行
我的应用程序在页面上收集了一堆电话号码。当用户点击提交按钮后，我会创建一个celery任务来呼叫每个号码并提醒他们，然后将他们重定向到一个页面，他们可以在该页面上看到有关通话的实时更新。我正在使用web sockets来实时更新每个呼叫的状态，并且需要同步执行任务，因为我只能从一个号码拨出电话...