芹菜 - 有連續的任務而不是併發？

Question

我有幾個使用亞馬遜API的任務限於1個請求/秒。

因此，我想將使用Amazon API的任務分組並將它們排列在順序隊列中。

我所想的全部是如何將隊列關聯到每個任務。但不知道如何刪除特定隊列中的併發。

任何想法？

非常感謝！ :)

Answer 1

從併發隊列消耗的單個工作人員等於一個確保任務將按順序處理。換句話說，你可以創建一個特殊的隊列，併發等於一個只運行一個芹菜工人：

celery -A tasks worker -Q amazon_queue -c 1 

，並提交任務到隊列：

tasks.add.apply_async(args=[1,2], kwargs={}, queue='amazon_queue') 

或者使用automatic routing某些任務類型。