Celery,Django..制作任务/线程启动子任务/线程?
我正在将 celery 与 django 一起使用,并尝试获取一个任务,如下所示: class task1 (Task) def run (self): launch_some_other_task.delay() 但它似…
使用 Django+Celery 进行开发而不运行 `celeryd`?
在开发中,运行 celeryd 以及 Django 开发服务器有点麻烦。例如,是否可以要求 celery 在开发过程中同步运行任务?或者类似的东西?…
在 django 应用程序中使用 celery 以 root 权限运行脚本?
我需要在我的 django 项目所在的 ubuntu 机器上运行一些命令,这些命令需要 root 权限,来自我的 django 项目。我正在使用 celery 启动异步进程,该进…
celery 2.x @periodic_task 未显示在任务注册表中
我最近更新到了 celery 2.0,我正在尝试使用新的(对我来说)装饰器来执行定期任务: @periodic_task(run_every=timedelta(days=1)) def some_task(**…
撤销功能是否需要额外的 api 调用来停止队列中的任务执行?
我有一个并发设置为 1 的工作线程和一个进入无限循环的任务[用于测试]。我提交了一个任务 T1,工作人员收到它并开始工作。我提交另一个任务,它得到了…
无法让 Celery run_every 属性正常工作
我正在尝试创建一些 Celery 定期任务,其中一些需要能够在运行时更改 run_every 。 Celery 文档说我应该能够通过将 run_every 属性转换为属性来做到这…
Django Celery AbortableTask 使用
我正在尝试使用 Celery 的 AbortableTask 功能,但文档例子似乎不适合我。给出的例子是: from celery.contrib.abortable import AbortableTask def M…
在 django 中中止 Celery 中正在运行的任务
我希望能够中止从 Celery 队列运行的任务(使用rabbitMQ)。我使用 AsyncBoot 来调用该任务, task_id = AsyncBoot.apply_async(args=[name], name=na…
还有其他人在使用 django-celery 保持 ghettoq 在后台运行时遇到困难吗?
nohup python manage.py celeryd -f queue.log 2>queue.err 1>queue.out & 很好地处理一个请求,然后客户端应用程序将下一个作业发布到队列会…
RabbitMQ 上 celery 任务优先级的解决方法?
我在 RabbitMQ 之上运行 Django 和 Celery 作为队列来处理一些数据处理任务。当用户首次注册时,我会启动 celery 任务,并定期更新他们的数据。但是,…
如何使用 Celery 制作包含所有待处理任务的仪表板?
我想要有一个地方可以观看所有待处理的任务。 我不是在谈论作为任务注册的函数/类,而是我可以显示的实际计划作业:名称、task_id、eta、worker 等。 …
在生产中运行 Django-Celery
我构建了一个 Django Web 应用程序和一些 Django-Piston 服务。用户使用 Web 界面提交一些数据,这些数据被 POST 到 Web 服务,而该 Web 服务又使用 D…
Django Celery 实现 - OSError:[Errno 38] 函数未实现
我安装了 django-celery 并尝试启动工作服务器,但收到一个 OSError 消息,表明函数未实现。我在 VPS 上运行 CentOS 版本 5.4(最终版): . broker -…