celery - 避免在 celery 经纪人中重复任务

标签 celery

我想使用celery configuration\api创建以下流程:

  • 仅当 celery 队列中没有TaskA(argB)已经挂起时才发送TaskA(argB)

  • 是否可以?如何?

    最佳答案

    我除了想办法

  • 通过 celery inspect 检索所有正在执行和计划的任务
  • 遍历它们以查看您的任务是否在那里。

  • 检查this SO问题以了解第一点是如何完成的。

    祝你好运

    关于celery - 避免在 celery 经纪人中重复任务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26831103/

    相关文章:

    python - 使用事件循环的 Celery Worker

    python - 导入错误 : No module named timeutils

    django - 为数据库中的每个 celery 任务存储一个任务 ID

    python - Celery如何在读取后删除redis中的任务结果

    amazon-ec2 - Celery:AWS ECS Autoscale 缩减事件(如何不破坏长时间运行的任务?)

    python - 集成 Tornado 与 celery : RuntimeError: tornado-redis must be installed to use the redis backend

    python - 我怎样才能等到所有 celery 任务完成后再继续我的代码

    python - 在 Celery 任务中 Pydoop 调用不起作用

    java - Celery 管理 java 任务

    django - 当 celery 中的任务组完成时发送成功信号