在线观看不卡亚洲电影_亚洲妓女99综合网_91青青青亚洲娱乐在线观看_日韩无码高清综合久久

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

Tornado如何實(shí)現(xiàn)這樣一種任務(wù)隊(duì)列

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

回答
編輯回答
維他命

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

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

用數(shù)據(jù)庫恐怕還是最好的方式

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

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

2017年2月26日 08:01