rabbitmq+celery 内存泄漏?
我已经在生产中愉快地运行了 celery+rabbitmq+django 一个月左右。昨天,我决定从 celery 2.1.4 升级到 2.2.4,现在rabbitmq 正在失控。运行一段时间…
Django Celery 和多个数据库(Celery、Django 和 RabbitMQ)
是否可以设置与 Django Celery 一起使用的不同数据库? 我有一个配置了多个数据库的项目,并且不希望 Django Celery 使用默认数据库。 如果我仍然可以…
Django Celery:管理界面显示零任务/工作人员
我已经使用 Django ORM 设置了 Celery 作为后端。试图监视幕后发生的事情。 我已经使用 -E 标志启动了celeryd python manage.py celeryd -E -l INFO -…
使用 Django 安装 Celery
我正在尝试使用 celery 安装="/questions/tagged/django" class="post-tag" title="show questions tagged 'django'" rel="tag">django 我收到以下…
在 Django 请求/响应周期中使用 celery/RabbitMQ(队列)命中 API
我正在开发一个产品,需要抓取API并计算并返回结果。 我目前正在使用 Django 作为产品。我详细查看了 Celery 和 RabbitMQ 的文档以及一般队列。 我想…
Django Celery:manage.py celeryd 返回“未知命令”
我正在尝试使用 Django ORM 作为后端来设置 Celery。 我已经安装了所有必需的软件包(django-celery,djkombu),完成了 文档指定的所有操作,运行syn…
Celery 任务计划(Celery、Django 和 RabbitMQ)
我想要一个每 5 分钟执行一次的任务,但它会等待最后一次执行完成,然后开始计算这 5 分钟。 (这样我也可以确保只有一个任务正在运行)我发现的最简…
重试丢失或失败的任务(Celery、Django 和 RabbitMQ)
有没有办法确定任务是否丢失并重试? 我认为丢失的原因可能是调度程序错误或工作线程崩溃。 我打算重试它们,但我不确定如何确定哪些任务需要退役? …
Celery 任务重试(Celery、Django 和 RabbitMQ)
你能告诉我当你在芹菜中告诉任务重试时发生了什么吗?它会在同一个工作线程中重试,还是会返回到代理,代理可能会将其发送到其他地方? 如果工作人员…
与 Twitter 通信的 Celery Task
当编写与有速率限制的服务通信的 celery 任务时,正确的方法是什么?有时会长时间丢失(不响应)? 我必须使用任务重试吗?如果服务错过太多时间怎么…
通过任务 ID 重试 celery 中的任务
我启动了很多任务,但其中一些尚未完成(763 个任务),处于 PENDING 状态,但系统未处理任何内容... 是否可以通过给 celery 提供 task_id 来重试此任…
django 的 runserver 选项是否提供了用于运行其他重启脚本的钩子?
我最近一直在玩 django 和 celery。开发过程中一件烦人的事情是每次修改任务时我都必须重新启动 celery 守护进程。当我开发时,我通常喜欢使用“manag…
为什么 RabbitMQ 不将消息持久保存在持久队列上?
我通过 Celery 将 RabbitMQ 与 Django 结合使用。我正在使用最基本的设置: # RabbitMQ connection settings BROKER_HOST = 'localhost' BROKER_PORT …
停止 celeryd 时出现问题
我将 celeryd 作为守护进程运行,但有时我无法优雅地停止它。当我发送 TERM 信号并且队列中有项目时(在本例中为 service celeryd stop),celeryd 将…
使用自定义状态时任务状态不更新
我有一个这样的任务: @task def test(): time.sleep(10) test.update_state(state="PROGRESS") time.sleep(10) return "done" 然后我运行这个: >&…