python爬蟲函數(shù)名,python爬蟲指令

python爬蟲 函數(shù)返回值如何調(diào)用?

在if 里只需要yield "" + item_url.attrs['href']

為葫蘆島等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計(jì)制作服務(wù),及葫蘆島網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)、葫蘆島網(wǎng)站設(shè)計(jì),以傳統(tǒng)方式定制建設(shè)網(wǎng)站,并提供域名空間備案等一條龍服務(wù),秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求,就會(huì)得到認(rèn)可,從而選擇與我們長期合作。這樣,我們也可以走得更遠(yuǎn)!

然后Lsit(最好改可名,在python規(guī)范里,函數(shù)命名是全小寫,而list又是保留字,比如改為display_hrefs)只需要循環(huán)輸出getUrl的結(jié)果就好:

def getUrl(url: str):

....html = urlopen(url)

....for item_url in BeautifulSoup((html.read()).find ('div' , class_='AAA').findAll ("a"):

........if 'href' in item_url.attrs:

............yield "" + item_url.attrs['href']

def display_hrefs(url: str):

....for href in getUrl(url):

........print(href)

if __name__ == '__main__':

....display_hrefs("")

如何用Python做爬蟲

1)首先你要明白爬蟲怎樣工作。

想象你是一只蜘蛛,現(xiàn)在你被放到了互聯(lián)“網(wǎng)”上。那么,你需要把所有的網(wǎng)頁都看一遍。怎么辦呢?沒問題呀,你就隨便從某個(gè)地方開始,比如說人民日?qǐng)?bào)的首頁,這個(gè)叫initial pages,用$表示吧。

在人民日?qǐng)?bào)的首頁,你看到那個(gè)頁面引向的各種鏈接。于是你很開心地從爬到了“國內(nèi)新聞”那個(gè)頁面。太好了,這樣你就已經(jīng)爬完了倆頁面(首頁和國內(nèi)新聞)!暫且不用管爬下來的頁面怎么處理的,你就想象你把這個(gè)頁面完完整整抄成了個(gè)html放到了你身上。

突然你發(fā)現(xiàn), 在國內(nèi)新聞這個(gè)頁面上,有一個(gè)鏈接鏈回“首頁”。作為一只聰明的蜘蛛,你肯定知道你不用爬回去的吧,因?yàn)槟阋呀?jīng)看過了啊。所以,你需要用你的腦子,存下你已經(jīng)看過的頁面地址。這樣,每次看到一個(gè)可能需要爬的新鏈接,你就先查查你腦子里是不是已經(jīng)去過這個(gè)頁面地址。如果去過,那就別去了。

好的,理論上如果所有的頁面可以從initial page達(dá)到的話,那么可以證明你一定可以爬完所有的網(wǎng)頁。

那么在python里怎么實(shí)現(xiàn)呢?

很簡單

import Queue

initial_page = "初始化頁"

url_queue = Queue.Queue()

seen = set()

seen.insert(initial_page)

url_queue.put(initial_page)

while(True): #一直進(jìn)行直到??菔癄€

if url_queue.size()0:

current_url = url_queue.get() #拿出隊(duì)例中第一個(gè)的url

store(current_url) #把這個(gè)url代表的網(wǎng)頁存儲(chǔ)好

for next_url in extract_urls(current_url): #提取把這個(gè)url里鏈向的url

if next_url not in seen:

seen.put(next_url)

url_queue.put(next_url)

else:

break

寫得已經(jīng)很偽代碼了。

所有的爬蟲的backbone都在這里,下面分析一下為什么爬蟲事實(shí)上是個(gè)非常復(fù)雜的東西——搜索引擎公司通常有一整個(gè)團(tuán)隊(duì)來維護(hù)和開發(fā)。

2)效率

如果你直接加工一下上面的代碼直接運(yùn)行的話,你需要一整年才能爬下整個(gè)豆瓣的內(nèi)容。更別說Google這樣的搜索引擎需要爬下全網(wǎng)的內(nèi)容了。

問題出在哪呢?需要爬的網(wǎng)頁實(shí)在太多太多了,而上面的代碼太慢太慢了。設(shè)想全網(wǎng)有N個(gè)網(wǎng)站,那么分析一下判重的復(fù)雜度就是N*log(N),因?yàn)樗芯W(wǎng)頁要遍歷一次,而每次判重用set的話需要log(N)的復(fù)雜度。OK,OK,我知道python的set實(shí)現(xiàn)是hash——不過這樣還是太慢了,至少內(nèi)存使用效率不高。

通常的判重做法是怎樣呢?Bloom Filter. 簡單講它仍然是一種hash的方法,但是它的特點(diǎn)是,它可以使用固定的內(nèi)存(不隨url的數(shù)量而增長)以O(shè)(1)的效率判定url是否已經(jīng)在set中。可惜天下沒有白吃的午餐,它的唯一問題在于,如果這個(gè)url不在set中,BF可以100%確定這個(gè)url沒有看過。但是如果這個(gè)url在set中,它會(huì)告訴你:這個(gè)url應(yīng)該已經(jīng)出現(xiàn)過,不過我有2%的不確定性。注意這里的不確定性在你分配的內(nèi)存足夠大的時(shí)候,可以變得很小很少。一個(gè)簡單的教程:Bloom Filters by Example

注意到這個(gè)特點(diǎn),url如果被看過,那么可能以小概率重復(fù)看一看(沒關(guān)系,多看看不會(huì)累死)。但是如果沒被看過,一定會(huì)被看一下(這個(gè)很重要,不然我們就要漏掉一些網(wǎng)頁了?。?。 [IMPORTANT: 此段有問題,請(qǐng)暫時(shí)略過]

好,現(xiàn)在已經(jīng)接近處理判重最快的方法了。另外一個(gè)瓶頸——你只有一臺(tái)機(jī)器。不管你的帶寬有多大,只要你的機(jī)器下載網(wǎng)頁的速度是瓶頸的話,那么你只有加快這個(gè)速度。用一臺(tái)機(jī)子不夠的話——用很多臺(tái)吧!當(dāng)然,我們假設(shè)每臺(tái)機(jī)子都已經(jīng)進(jìn)了最大的效率——使用多線程(python的話,多進(jìn)程吧)。

3)集群化抓取

爬取豆瓣的時(shí)候,我總共用了100多臺(tái)機(jī)器晝夜不停地運(yùn)行了一個(gè)月。想象如果只用一臺(tái)機(jī)子你就得運(yùn)行100個(gè)月了...

那么,假設(shè)你現(xiàn)在有100臺(tái)機(jī)器可以用,怎么用python實(shí)現(xiàn)一個(gè)分布式的爬取算法呢?

我們把這100臺(tái)中的99臺(tái)運(yùn)算能力較小的機(jī)器叫作slave,另外一臺(tái)較大的機(jī)器叫作master,那么回顧上面代碼中的url_queue,如果我們能把這個(gè)queue放到這臺(tái)master機(jī)器上,所有的slave都可以通過網(wǎng)絡(luò)跟master聯(lián)通,每當(dāng)一個(gè)slave完成下載一個(gè)網(wǎng)頁,就向master請(qǐng)求一個(gè)新的網(wǎng)頁來抓取。而每次slave新抓到一個(gè)網(wǎng)頁,就把這個(gè)網(wǎng)頁上所有的鏈接送到master的queue里去。同樣,bloom filter也放到master上,但是現(xiàn)在master只發(fā)送確定沒有被訪問過的url給slave。Bloom Filter放到master的內(nèi)存里,而被訪問過的url放到運(yùn)行在master上的Redis里,這樣保證所有操作都是O(1)。(至少平攤是O(1),Redis的訪問效率見:LINSERT – Redis)

考慮如何用python實(shí)現(xiàn):

在各臺(tái)slave上裝好scrapy,那么各臺(tái)機(jī)子就變成了一臺(tái)有抓取能力的slave,在master上裝好Redis和rq用作分布式隊(duì)列。

代碼于是寫成

#slave.py

current_url = request_from_master()

to_send = []

for next_url in extract_urls(current_url):

to_send.append(next_url)

store(current_url);

send_to_master(to_send)

#master.py

distributed_queue = DistributedQueue()

bf = BloomFilter()

initial_pages = ""

while(True):

if request == 'GET':

if distributed_queue.size()0:

send(distributed_queue.get())

else:

break

elif request == 'POST':

bf.put(request.url)

好的,其實(shí)你能想到,有人已經(jīng)給你寫好了你需要的:darkrho/scrapy-redis · GitHub

4)展望及后處理

雖然上面用很多“簡單”,但是真正要實(shí)現(xiàn)一個(gè)商業(yè)規(guī)模可用的爬蟲并不是一件容易的事。上面的代碼用來爬一個(gè)整體的網(wǎng)站幾乎沒有太大的問題。

但是如果附加上你需要這些后續(xù)處理,比如

有效地存儲(chǔ)(數(shù)據(jù)庫應(yīng)該怎樣安排)

有效地判重(這里指網(wǎng)頁判重,咱可不想把人民日?qǐng)?bào)和抄襲它的大民日?qǐng)?bào)都爬一遍)

有效地信息抽取(比如怎么樣抽取出網(wǎng)頁上所有的地址抽取出來,“朝陽區(qū)奮進(jìn)路中華道”),搜索引擎通常不需要存儲(chǔ)所有的信息,比如圖片我存來干嘛...

及時(shí)更新(預(yù)測(cè)這個(gè)網(wǎng)頁多久會(huì)更新一次)

如你所想,這里每一個(gè)點(diǎn)都可以供很多研究者十?dāng)?shù)年的研究。雖然如此,

“路漫漫其修遠(yuǎn)兮,吾將上下而求索”。

所以,不要問怎么入門,直接上路就好了:)

python爬蟲,這個(gè)表示什么意思?

savepath是變量,表示存儲(chǔ)地址。

saveData是一個(gè)函數(shù),用來把數(shù)據(jù)存儲(chǔ)在savepath這個(gè)地址。

分享名稱:python爬蟲函數(shù)名,python爬蟲指令
網(wǎng)頁URL:http://muchs.cn/article36/hcjosg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供云服務(wù)器、用戶體驗(yàn)網(wǎng)站排名、企業(yè)建站小程序開發(fā)、網(wǎng)站改版

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)

h5響應(yīng)式網(wǎng)站建設(shè)