蟒蛇创建芹菜任务作业

Question

可以说我有一个python程序，我想运行总是最多10次并行使用芹菜/ rabbigmq，如果一些过程完成我想知道它，所以我可以开始一个新的过程。我怎么能这样做？一些例子将是不错

Answer 1

举个例子是困难的，因为消息是有点复杂，但你基本上可以做的是：

• 重写你的程序是一个任务或者编写调用程序任务使用子
• 配置芹菜有，因为你需要得到你的工作做了10名工人
• 执行许多任务，芹菜将它们添加到自己的队列
• 芹菜将完成剩下的给你，一旦任务完成，另一个启动，直到队列为emp TY

另外，如果你想开始一个任务完成后，手动，您可以配置芹菜后的成品发送消息（我没有尝试过，但看看CELERY_RESULT_BACKEND），您可以然后使用这些消息并开始您的任务。