2011-05-04 57 views
0

可以說我有一個python程序,我想運行總是最多10次並行使用芹菜/ rabbigmq,如果一些過程完成我想知道它,所以我可以開始一個新的過程。我怎麼能這樣做?一些例子將是不錯蟒蛇創建芹菜任務作業

回答

1

舉個例子是困難的,因爲消息是有點複雜,但你基本上可以做的是:

  • 重寫你的程序是一個任務或者編寫調用程序任務使用子
  • 配置芹菜有,因爲你需要得到你的工作做了10名工人
  • 執行許多任務,芹菜將它們添加到自己的隊列
  • 芹菜將完成剩下的給你,一旦任務完成,另一個啓動,直到隊列爲emp TY

另外,如果你想開始一個任務完成後,手動,您可以配置芹菜後的成品發送消息(我沒有嘗試過,但看看CELERY_RESULT_BACKEND),您可以然後使用這些消息並開始您的任務。