鍍金池/ 問答/Python/ Tornado如何實現(xiàn)這樣一種任務隊列

Tornado如何實現(xiàn)這樣一種任務隊列

我現(xiàn)在有一個這樣的需求:有一個爬蟲函數是用Python寫的,剛好現(xiàn)在有一個網站也是用Python的Tornado寫的。我想實現(xiàn)在Tornado接收到一個新增任務的請求之后,自動將這個請求放入任務隊列,然后爬蟲函數自動從任務隊列中取出數據來。
由于網站規(guī)模并不大,為了部署方便不想使用redis或者其他消息隊列服務,如何讓爬蟲函數和Tornado寫的web程序能夠相互通信呢?
我現(xiàn)在的思路是建立一個main.py文件,然后先用queue模塊創(chuàng)建一個隊列,然后用threading庫同時啟動n個爬蟲函數的線程從queue中取數據,然后Toronto的handler里面再往queue中put數據,但是用代碼實現(xiàn)就會出現(xiàn)包循環(huán)引用導致報錯的現(xiàn)象。有什么辦法能夠讓兩個模塊共享一個線程安全的數據結構呢?

回答
編輯回答
維他命

你說的包循環(huán)引用出錯,這種情況是可以避免的。你只要調整下主程序運行的方式,使得Queue在兩個項目主程序啟動之前申明,作為一個公共變量分別傳入到兩個項目的主程序里去,主程序再層層下發(fā)配置這個Queue的使用。并不會存在什么循環(huán)引用的問題,出現(xiàn)這個問題只是你代碼結構沒調整好。

2017年4月24日 18:46
編輯回答
朕略萌

用數據庫恐怕還是最好的方式

因為
1、要考慮任務修改,增加,中斷, 放內存馬上涉及到持久化的問題,自己解決不如用數據庫。
2、哪些爬過了,哪些沒有,什么時間爬出的,多久需要重爬一次,爬過的數據如何篩選處理,數據庫都能輕而易舉地實現(xiàn)
3、并發(fā)、擴展、備份數據都有現(xiàn)成的方案

建議參考一下pyspider的設計,題主提的功能對pyspider來說都是現(xiàn)成,重新寫代碼的必要性是不是要考慮一下呢?

2017年2月26日 08:01