【问题标题】:Adding dependencies between jobs in asynchronous queue在异步队列中添加作业之间的依赖关系
【发布时间】:2018-06-05 14:37:41
【问题描述】:

我正在寻找一个执行异步任务的队列(如rabbitMQ),其中可以将新任务添加到队列中,并且只有在之前的任务(依赖于)完成后才会执行。

所以我正在寻找的 API 是为插入队列中的任何任务提供一组标识符,并且当有另一个具有匹配标识符的任务尚未执行时,该任务将不会被执行。

有什么可能吗?

【问题讨论】:

  • 您可以随时在您使用的任何工作服务中自己编写该逻辑,但如果您希望它作为原语使用,celery 可以使用chorddocs.celeryproject.org/en/latest/userguide/canvas.html#chords
  • 感谢您的回复。我看不出它对我有什么帮助,因为任务应该异步添加到队列中,所以我不能在任何时候创建和弦 - 每当应该产生一个新任务时,它必须是队列直到所有之前依赖的任务已经完成。

标签: amazon-web-services asynchronous rabbitmq celery task-queue


【解决方案1】:

您可以使用celery's work-flows 创建任务之间的依赖关系。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2019-02-17
    • 2013-03-09
    • 1970-01-01
    • 2015-11-06
    • 1970-01-01
    • 2021-07-05
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多