测试 celery 任务是否仍在处理中
如何测试 celery 中是否仍在处理任务 (task_id)?我有以下场景: 在 Django 视图中启动任务 将BaseAsyncResult 存储在会话中 关闭 celery 守护进程(…
在 Celery 任务中使用 Redis 连接并保存数据
我有一个将数据保存到 Redis 的对象。它需要尽可能少地阻塞,所以我决定使用 Celery 来卸载任务。当我尝试在 celery 外部 .save() 对象时,它会连接到…
如何捕获一系列 Celery 任务执行过程中生成的所有 python 日志记录?
我想将我自己开发的任务队列系统转换为基于 Celery 的任务队列,但我目前拥有的一个功能给我带来了一些困扰。 现在,我的任务队列运行得非常粗糙;我…
使用 Celery 和 RabbitMQ 的简单队列
我正在尝试实现一个一次执行一项任务的简单队列。使用 Celery 从主线程卸载任务并在 Celery 配置中设置 concurrency=1 效果很好,但我可能想使用更多…
FreeBSD 上有适用于 Celery 的有效 rc 脚本吗?
我已经在 FreeBSD 上编写了一个 celeryd 的 rc 脚本,但我忍不住认为一定有更好的方法。 celeryd 本身不会守护进程,而且它似乎也很难响应 sigterm,…
Django Celery 导致 runserver 命令出现导入错误
当我发出 runserver 命令时,djcelery (Django Celery) 会引发 ImportError。 % python manage.py runserver ~/Workspace/django-projects/no-labels/…
CentOS 的 init.d celery 脚本?
我正在编写一个使用 celery 的 Django 应用程序。到目前为止,我一直在 Ubuntu 上运行,但我正在尝试部署到 CentOS。 Celery 为基于 Debian 的发行版…
有没有人成功地将芹菜与塔一起使用
我有一个基于 pylons 的网络应用程序,我喜欢使用 celery +rabbitmq 来完成一些耗时的任务。我查看了 celery-pylons 项目,但没有成功使用它。 我对 c…
Python+Celery:忽略每次调用的任务结果?
是否可以在每次调用的基础上忽略任务结果? 例如,这样我可以在 Web 请求期间运行任务时忽略任务的结果,但在交互运行任务时等待结果(可能有调试信息…
Celery Queue 似乎没有注册我的任务
我正在使用 Django 和 Celery 与 RabbitMQ 进行通信。我已经注册了所有任务,并将它们放入我的设置文件中的 CELERY_IMPORTS 元组中。当我运行任务时,…