【发布时间】:2018-06-05 14:37:41
【问题描述】:
我正在寻找一个执行异步任务的队列(如rabbitMQ),其中可以将新任务添加到队列中,并且只有在之前的任务(依赖于)完成后才会执行。
所以我正在寻找的 API 是为插入队列中的任何任务提供一组标识符,并且当有另一个具有匹配标识符的任务尚未执行时,该任务将不会被执行。
有什么可能吗?
【问题讨论】:
-
您可以随时在您使用的任何工作服务中自己编写该逻辑,但如果您希望它作为原语使用,celery 可以使用
chord:docs.celeryproject.org/en/latest/userguide/canvas.html#chords -
感谢您的回复。我看不出它对我有什么帮助,因为任务应该异步添加到队列中,所以我不能在任何时候创建和弦 - 每当应该产生一个新任务时,它必须是队列直到所有之前依赖的任务已经完成。
标签: amazon-web-services asynchronous rabbitmq celery task-queue