是否可以指定如果 celeryd 未运行,task.delay 或 task.apply_async 应该失败?
我正在使用 djcelery 和 djkombu。我本来会使用 RabbitMQ(因为这是推荐的选项),但 RabbitMQ 在我的 VPS 上使用了太多内存,而且我是一个小气鬼。 …
Django 管理监视器中的空 STARTED 任务
任务部分的 Django 管理监视器中有空记录。它每隔几个小时出现一次。一切正常,但看起来有时会丢失数据。 后端是针对 Amazon SQS 定制的。我几乎确定…
python 创建 celery 任务作业
假设我有一个 python 程序,我想使用 celery / rabbigmq 最多并行运行 10 次,如果某些进程完成,我想了解它,以便我可以启动一个新进程。我怎样才能…
Celery 的类似信号量的机制
我们正在使用 Python + Celery 为我们的任务队列开发一个分布式应用程序。 我们的应用程序要求我们通过 IMAP(例如:gmail)从远程 ISP 下载电子邮件…
Celery - task_ids 的冲突
我的任务遇到 HardTimeLimit 异常。经过日志检查后,我发现 - celery 未接收任务(任务 id 没有“从代理获取任务:”消息) 几天前执行了具有相同 id …
java世界里有没有类似celery的任务队列?
鉴于java如此成熟,我希望有人能告诉我java是否有类似的东西 http://celeryproject.org/ 它是一个分布式任务队列。 我正在写信给rabbitmq,想知道除了…
在 Celery 中给定“task_id”,检索任务结果对象
我将 celery.result.AsyncResult 中的 task_id 存储在数据库中,并将其与任务影响的项目相关联。这允许我执行查询来检索与特定项目相关的任务的所有 t…
Django 中异步任务和 Redis 的线程安全
我有一个 Django 应用程序,它在查询集上调用异步任务(使用 celery)。该任务获取查询集并执行一大堆操作,根据其中的对象,这些操作可能需要很长时…
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 -…