50行Python代碼實現簡單的任務隊列

當你的項目需要一個任務隊列時，當然你會先想到celery，然後你花了三個月弄懂了基本的配置選項，你覺得已經生無可戀了。也許你可以使用簡單一點的任務隊列，如huey和rq。

或者，你自己寫一個如何？你能做到的！

首先，我們使用redis作為消息的存儲組件。我們不需要單獨安裝redis，我們用docker來獲取一個redis。打開終端，然後運行

對，你做到了。然後我們創建一個Python虛擬環境來管理依賴庫。我們需要redis的Python鏈接庫和dill。

很好。我們的代碼使用dill來把要執行的函數序列化為一個任務，然後存儲到redis中。

客戶端部分（任務隊列的客戶端，不是APP）

客戶端把消息發送到任務隊列中。打開一個編輯器，創建一個名為client.py的文件。然後我們定義要發送給worker（工作者進程）的任務，例如：

現在我們需要配置我們的redis客戶端：

這些都完成後，我們開始生產一些任務，並且把它推送到任務隊列中

工作者進程

工作者進程實際地完成任務。它們就是盯著消息隊列，隊列中有任務了就抓取下來，把任務完成，然後告訴隊列我完成了，刪除這個任務吧。就這麼簡單。打開編輯器，創建一個名為worker.py的文件，然後輸入下面內容：

你已經完成了所以的代碼，運行這個工作者進程吧：

你甚至可以在其他機器上運行，任務隊列是天生支持分布式的。然後再運行客戶端創造一些任務：

50行代碼都不到，是不是很佩服自己？

英文原文：

https://github.com/JoseTomasTocino/yotaq

譯者：詩書塞外

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！