用python也差不多一年多了,python應(yīng)用最多的場(chǎng)景還是web快速開(kāi)發(fā)、爬蟲、自動(dòng)化運(yùn)維:寫過(guò)簡(jiǎn)單網(wǎng)站、寫過(guò)自動(dòng)發(fā)帖腳本、寫過(guò)收發(fā)郵件腳本、寫過(guò)簡(jiǎn)單驗(yàn)證碼識(shí)別腳本。
爬蟲在開(kāi)發(fā)過(guò)程中也有很多復(fù)用的過(guò)程,這里總結(jié)一下,以后也能省些事情。
1、基本抓取網(wǎng)頁(yè)
get方法
1
2
3
4
5
|
import urllib2 url = "http://www.baidu.com" response = urllib2.urlopen(url) print response.read() |
post方法
1
2
3
4
5
6
7
8
9
|
import urllib import urllib2 url = "http://abcde.com" form = { 'name' : 'abc' , 'password' : '1234' } form_data = urllib.urlencode(form) request = urllib2.Request(url,form_data) response = urllib2.urlopen(request) print response.read() |
2、使用代理IP
在開(kāi)發(fā)爬蟲過(guò)程中經(jīng)常會(huì)遇到IP被封掉的情況,這時(shí)就需要用到代理IP;
在urllib2包中有ProxyHandler類,通過(guò)此類可以設(shè)置代理訪問(wèn)網(wǎng)頁(yè),如下代碼片段:
1
2
3
4
5
6
7
|
import urllib2 proxy = urllib2.ProxyHandler({ 'http' : '127.0.0.1:8087' }) opener = urllib2.build_opener(proxy) urllib2.install_opener(opener) response = urllib2.urlopen( 'http://www.baidu.com' ) print response.read() |
3、Cookies處理
cookies是某些網(wǎng)站為了辨別用戶身份、進(jìn)行session跟蹤而儲(chǔ)存在用戶本地終端上的數(shù)據(jù)(通常經(jīng)過(guò)加密),python提供了cookielib模塊用于處理cookies,cookielib模塊的主要作用是提供可存儲(chǔ)cookie的對(duì)象,以便于與urllib2模塊配合使用來(lái)訪問(wèn)Internet資源.
代碼片段:
1
2
3
4
5
6
|
import urllib2, cookielib cookie_support = urllib2.HTTPCookieProcessor(cookielib.CookieJar()) opener = urllib2.build_opener(cookie_support) urllib2.install_opener(opener) content = urllib2.urlopen( 'http://XXXX' ).read() |
關(guān)鍵在于CookieJar(),它用于管理HTTP cookie值、存儲(chǔ)HTTP請(qǐng)求生成的cookie、向傳出的HTTP請(qǐng)求添加cookie的對(duì)象。整個(gè)cookie都存儲(chǔ)在內(nèi)存中,對(duì)CookieJar實(shí)例進(jìn)行垃圾回收后cookie也將丟失,所有過(guò)程都不需要單獨(dú)去操作。
手動(dòng)添加cookie
1
2
3
4
|
cookie = "PHPSESSID = 91rurfqm2329bopnosfu4fvmu7 ; kmsign = 55d2c12c9b1e3 ; KMUID = b6Ejc1XSwPq9o756AxnBAg = " request.add_header( "Cookie" , cookie) |
4、偽裝成瀏覽器
某些網(wǎng)站反感爬蟲的到訪,于是對(duì)爬蟲一律拒絕請(qǐng)求。所以用urllib2直接訪問(wèn)網(wǎng)站經(jīng)常會(huì)出現(xiàn)HTTP Error 403: Forbidden的情況
對(duì)有些 header 要特別留意,Server 端會(huì)針對(duì)這些 header 做檢查
1.User-Agent 有些 Server 或 Proxy 會(huì)檢查該值,用來(lái)判斷是否是瀏覽器發(fā)起的 Request
2.Content-Type 在使用 REST 接口時(shí),Server 會(huì)檢查該值,用來(lái)確定 HTTP Body 中的內(nèi)容該怎樣解析。
這時(shí)可以通過(guò)修改http包中的header來(lái)實(shí)現(xiàn),代碼片段如下:
1
2
3
4
5
6
7
8
9
10
|
import urllib2 headers = { 'User-Agent' : 'Mozilla/5.0 (Windows; U; Windows NT 6.1; en-US; rv:1.9.1.6) Gecko/20091201 Firefox/3.5.6' } request = urllib2.Request( url = 'http://my.oschina.net/jhao104/blog?catalog=3463517' , headers = headers ) print urllib2.urlopen(request).read() |
5、頁(yè)面解析
對(duì)于頁(yè)面解析最強(qiáng)大的當(dāng)然是正則表達(dá)式,這個(gè)對(duì)于不同網(wǎng)站不同的使用者都不一樣,就不用過(guò)多的說(shuō)明,其次就是解析庫(kù)了,常用的有兩個(gè)lxml和BeautifulSoup,對(duì)于這兩個(gè)庫(kù),我的評(píng)價(jià)是,都是HTML/XML的處理庫(kù),Beautifulsoup純python實(shí)現(xiàn),效率低,但是功能實(shí)用,比如能用通過(guò)結(jié)果搜索獲得某個(gè)HTML節(jié)點(diǎn)的源碼;lxmlC語(yǔ)言編碼,高效,支持Xpath
6、驗(yàn)證碼的處理
對(duì)于一些簡(jiǎn)單的驗(yàn)證碼,可以進(jìn)行簡(jiǎn)單的識(shí)別。本人也只進(jìn)行過(guò)一些簡(jiǎn)單的驗(yàn)證碼識(shí)別。但是有些反人類的驗(yàn)證碼,比如12306,可以通過(guò)打碼平臺(tái)進(jìn)行人工打碼,當(dāng)然這是要付費(fèi)的。
7、gzip壓縮
有沒(méi)有遇到過(guò)某些網(wǎng)頁(yè),不論怎么轉(zhuǎn)碼都是一團(tuán)亂碼。哈哈,那說(shuō)明你還不知道許多web服務(wù)具有發(fā)送壓縮數(shù)據(jù)的能力,這可以將網(wǎng)絡(luò)線路上傳輸?shù)拇罅繑?shù)據(jù)消減 60% 以上。這尤其適用于 XML web 服務(wù),因?yàn)?XML 數(shù)據(jù) 的壓縮率可以很高。
但是一般服務(wù)器不會(huì)為你發(fā)送壓縮數(shù)據(jù),除非你告訴服務(wù)器你可以處理壓縮數(shù)據(jù)。
于是需要這樣修改代碼:
1
2
3
4
5
|
import urllib2, httplib request = urllib2.Request( 'http://xxxx.com' ) request.add_header( 'Accept-encoding' , 'gzip' ) 1 opener = urllib2.build_opener() f = opener. open (request) |
這是關(guān)鍵:創(chuàng)建Request對(duì)象,添加一個(gè) Accept-encoding 頭信息告訴服務(wù)器你能接受 gzip 壓縮數(shù)據(jù)
然后就是解壓縮數(shù)據(jù):
1
2
3
4
5
6
7
|
import StringIO import gzip compresseddata = f.read() compressedstream = StringIO.StringIO(compresseddata) gzipper = gzip.GzipFile(fileobj = compressedstream) print gzipper.read() |
8、多線程并發(fā)抓取
單線程太慢的話,就需要多線程了,這里給個(gè)簡(jiǎn)單的線程池模板 這個(gè)程序只是簡(jiǎn)單地打印了1-10,但是可以看出是并發(fā)的。
雖然說(shuō)python的多線程很雞肋,但是對(duì)于爬蟲這種網(wǎng)絡(luò)頻繁型,還是能一定程度提高效率的。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
from threading import Thread from Queue import Queue from time import sleep # q是任務(wù)隊(duì)列 #NUM是并發(fā)線程總數(shù) #JOBS是有多少任務(wù) q = Queue() NUM = 2 JOBS = 10 #具體的處理函數(shù),負(fù)責(zé)處理單個(gè)任務(wù) def do_somthing_using(arguments): print arguments #這個(gè)是工作進(jìn)程,負(fù)責(zé)不斷從隊(duì)列取數(shù)據(jù)并處理 def working(): while True : arguments = q.get() do_somthing_using(arguments) sleep( 1 ) q.task_done() #fork NUM個(gè)線程等待隊(duì)列 for i in range (NUM): t = Thread(target = working) t.setDaemon( True ) t.start() #把JOBS排入隊(duì)列 for i in range (JOBS): q.put(i) #等待所有JOBS完成 q.join() |