Django Celery retry() 任务但继续当前任务
我遇到过这样的情况：我收到第三方服务的响应，表明我的初始请求失败，我应该重试。我正在 Celery 任务中调用该服务。重试调用不会在异常中捕获，并且…
Windows 上的 Celery：subprocess.call 在 Celery 中访问被拒绝，在 Django 中运行良好
我有以下任务： @task(track_started = True) def run_transcode_server(): commands = ('java', '-cp', settings.TRANSCODE_CLASSPATH, settings.TRA…
django celery 终止任务的子进程
这是我之前问题的后续问题： 用 Celery 取消已经执行的任务？ celery.task.control.revoke({task_id}, terminate=True) 确实杀死我运行任务的工人。我…
如何在 Celery 中检查任务状态？
如何检查任务是否在 celery 中运行（具体来说，我正在使用 celery-django）？ 我已经阅读了文档，并且用谷歌搜索了，但我看不到这样的调用： my_examp…
主管 celeryd 的用户不正确
我有一些使用 celery 运行的定期任务（由supervisord 守护），但是在尝试在用户的主目录中创建一个目录后，我为supervisord 进程设置了一个“权限被拒…
Python SEM_OPEN 错误
我正在尝试使用与 RabbitMQ 和 Django 一起运行的 Celery。到目前为止，我的服务器上安装了 RabbitMQ 2.7，以及 python 2.7 、 Django 1.3 、 celery …
无法在 djcelery admin（mongodb 后端）中显示 celery 任务
我的环境由 django、celery 和 mongodb 作为后端组成。 我设法使用 djcelery 管理界面创建定期任务，启动 celerybeat 后我可以看到它运行。这个任务很…
Celery、rabbitmq：如何安装远程工作人员？
我可以有多台机器来执行 django 分发的任务并返回消息吗？我研究了 celery/rabbitmq，我不确定是否可以在远程计算机上设置 celery 工作人员。有人可以…
Django Celery：仅执行长时间运行的进程的一个实例
我有一个长时间运行的进程，必须每五分钟运行一次，但进程的多个实例不应该同时运行。该过程通常不应运行超过五分钟，但我想确保第二个实例在运行结束…
任务状态和 django-celery
我使用 django-celery 并有这样的任务： class TestTask(Task): name = "enabler.test_task" def run(self, **kw): debug_log("begin test task") tim…
Django-celery 状态已收到？
我通过django-celery（以rabbitmq作为后端）运行一些任务，这些任务非常耗时且占用CPU资源。 我有 2 个工作 Ec2 实例（一个是小型实例，另一个是高 cp…
celery python 对象方法
我正在尝试围绕 python 对象方法获取 celery 任务包装器。就像： class A: @task def test_task(self,args): print "BLah..test" def main(): a= A() …
为什么我会收到“SyntaxError：非 ASCII 字符 '\xa3'”当运行 celeryd 时？
我正在尝试使用 Django & 运行 celeryd Ubuntu 上的 Virtualenv，我收到此错误： celeryd-multi v2.4.5 > Starting nodes... > celery.heron: File "/…
Celery 和 Redis 总是内存不足
我有一个部署到 Heroku 的 Django 应用程序，有一个运行 celery 的工作进程（+ 用于监控的 celerycam）。我使用 RedisToGo 的 Redis 数据库作为代理。…
