上期我們理性的分析了為什么要學(xué)習(xí)Scrapy,理由只有一個,那就是免費,一分錢都不用花!
成都一家集口碑和實力的網(wǎng)站建設(shè)服務(wù)商,擁有專業(yè)的企業(yè)建站團隊和靠譜的建站技術(shù),十年企業(yè)及個人網(wǎng)站建設(shè)經(jīng)驗 ,為成都數(shù)千家客戶提供網(wǎng)頁設(shè)計制作,網(wǎng)站開發(fā),企業(yè)網(wǎng)站制作建設(shè)等服務(wù),包括成都營銷型網(wǎng)站建設(shè),品牌網(wǎng)站制作,同時也為不同行業(yè)的客戶提供網(wǎng)站建設(shè)、網(wǎng)站設(shè)計的服務(wù),包括成都電商型網(wǎng)站制作建設(shè),裝修行業(yè)網(wǎng)站制作建設(shè),傳統(tǒng)機械行業(yè)網(wǎng)站建設(shè),傳統(tǒng)農(nóng)業(yè)行業(yè)網(wǎng)站制作建設(shè)。在成都做網(wǎng)站,選網(wǎng)站制作建設(shè)服務(wù)商就選創(chuàng)新互聯(lián)建站。咦?怎么有人扔西紅柿?好吧,我承認(rèn)電視看多了。不過今天是沒得看了,為了趕稿,又是一個不眠夜。。。言歸正傳,我們將在這一期介紹完Scrapy的基礎(chǔ)知識, 如果想深入研究,大家可以參考官方文檔,那可是出了名的全面,我就不占用公眾號的篇幅了。
下面是Scrapy的架構(gòu),包括組件以及在系統(tǒng)中發(fā)生的數(shù)據(jù)流的概覽(紅色箭頭所示)。 之后會對每個組件做簡單介紹,數(shù)據(jù)流也會做一個簡要描述。
組件
Engine: 引擎負(fù)責(zé)控制數(shù)據(jù)流在系統(tǒng)中所有組件中流動,并在相應(yīng)動作發(fā)生時觸發(fā)事件。
Scheduler: 調(diào)度器從引擎接受Request并將他們?nèi)腙?,以便之后引擎請求他們時提供給引擎。
Downloader: 下載器負(fù)責(zé)獲取頁面數(shù)據(jù)并提供給引擎,而后提供給Spider。
Spiders: Spider是Scrapy用戶編寫的用于分析Response并提取Item或提取更多需要下載的URL的類。 每個Spider負(fù)責(zé)處理特定網(wǎng)站。
Item Pipeline: 負(fù)責(zé)處理被Spider提取出來的Item。典型的功能有清洗、 驗證及持久化操作。
Downloader middlewares: 下載器中間件是在Engine及Downloader之間的特定鉤子(specific hooks),處理Downloader傳遞給Engine的Response。 其提供了一個簡便的機制,通過插入自定義代碼來擴展Scrapy功能。
Spider middlewares: 是在Engine及Spider之間的特定鉤子(specific hook),處理Spider的輸入(Response)和輸出(Items及Requests)。 其提供了一個簡便的機制,通過插入自定義代碼來擴展Scrapy功能。
數(shù)據(jù)流
Scrapy中的數(shù)據(jù)流由執(zhí)行引擎控制,其過程如下:
Engine從Spider獲取第一個需要爬取URL(s)。
Engine用Scheduler調(diào)度Requests,并向Scheduler請求下一個要爬取的URL。
Scheduler返回下一個要爬取的URL給Engine。
Engine將URL通過Downloader middlewares轉(zhuǎn)發(fā)給Downloader。
一旦頁面下載完畢,下載器生成一個該頁面的Response,并將其通過Downloader middlewares發(fā)送給Engine。
引擎從Downloader中接收到Response并通過Spider middlewares發(fā)送給Spider處理。
Spider處理Response并返回爬取到的Item及新的Request給Engine。
Engine將爬取到的Item給Item Pipeline,然后將Request給Scheduler。
從第一步開始重復(fù)這個流程,直到Scheduler中沒有更多的URLs。
架構(gòu)就是這樣,流程和我第二篇里介紹的迷你架構(gòu)差不多,但擴展性非常強大。
One more thing
Scrapy基于事件驅(qū)動網(wǎng)絡(luò)框架 Twisted 編寫,Twisted是一個異步非阻塞框架。一說到網(wǎng)絡(luò)通信框架就會提什么同步、異步、阻塞和非阻塞,到底是些啥玩意???為啥老是有人暗示或者明示異步=非阻塞?比如Scrapy文檔里:Scrapy is written with Twisted, a popular event-driven networking framework for Python. Thus, it’s implemented using a non-blocking (aka asynchronous) code for concurrency. 這種說法對嗎?舉個栗子:
出場人物:老張,水壺兩把(普通水壺,簡稱水壺;會響的水壺,簡稱響水壺)
1. 老張把水壺放到火上,立等水開。(同步阻塞)
老張覺得自己有點傻。
2. 老張把水壺放到火上,去客廳看電視,時不時去廚房看看水開沒有。(同步非阻塞)
老張還是覺得自己有點傻,于是變高端了,買了把會響笛的那種水壺。水開之后,能大聲發(fā)出嘀~~~~的噪音。
3. 老張把響水壺放到火上,立等水開。(異步阻塞)
老張覺得這樣傻等意義不大。
4. 老張把響水壺放到火上,去客廳看電視,水壺響之前不再去看它了,響了再去拿壺。(異步非阻塞)
老張覺得自己聰明了。
所謂同步異步,只是對于水壺而言。普通水壺,同步;響水壺,異步。雖然都能干活,但響水壺可以在自己完工之后,提示老張水開了。這是普通水壺所不能及的。同步只能讓調(diào)用者去輪詢自己(情況2中),造成老張效率的低下。
所謂阻塞非阻塞,僅僅對于老張而言。立等的老張,阻塞;看電視的老張,非阻塞。情況1和情況3中老張就是阻塞的,媳婦喊他都不知道。雖然3中響水壺是異步的,可對于立等的老張沒有太大的意義。所以一般異步是配合非阻塞使用的,這樣才能發(fā)揮異步的效用。
創(chuàng)建項目
在開始爬取之前,您必須創(chuàng)建一個新的Scrapy項目。 進入您打算存儲代碼的目錄中,運行下列命令:
scrapy startproject tutorial
該命令將會創(chuàng)建包含下列內(nèi)容的 tutorial 目錄:
tutorial/ scrapy.cfg # 項目的配置文件 tutorial/ # 該項目的python模塊。之后您將在此加入代碼 __init__.py items.py # 項目中的item文件 pipelines.py # 項目中的pipelines文件 settings.py # 項目的設(shè)置文件 spiders/ # 放置spider代碼的目錄 __init__.py
編寫第一個爬蟲
Spider是用戶編寫用于從單個網(wǎng)站(或者一些網(wǎng)站)爬取數(shù)據(jù)的類。其包含了一個用于下載的初始URL,以及如何跟進網(wǎng)頁中的鏈接以及如何分析頁面中的內(nèi)容的方法。
以下為我們的第一個Spider代碼,保存在 tutorial/spiders 目錄下的 quotes_spider.py文件中:
import scrapyclass QuotesSpider(scrapy.Spider): name = "quotes" def start_requests(self): urls = [ 'http://quotes.toscrape.com/page/1/', 'http://quotes.toscrape.com/page/2/', ] for url in urls: yield scrapy.Request(url=url, callback=self.parse) def parse(self, response): page = response.url.split("/")[-2] filename = 'quotes-%s.html' % page with open(filename, 'wb') as f: f.write(response.body) self.log('Saved file %s' % filename)
為了創(chuàng)建一個Spider,你必須繼承 scrapy.Spider 類, 且定義以下三個屬性:
name: 用于區(qū)別Spider。 該名字必須是唯一的,您不可以為不同的Spider設(shè)定相同的名字。
start_urls: 包含了Spider在啟動時進行爬取的url列表。 因此,第一個被獲取到的頁面將是其中之一。 后續(xù)的URL則從初始的URL獲取到的數(shù)據(jù)中提取。
parse() 是spider的一個方法。 被調(diào)用時,每個初始URL完成下載后生成的Response 對象將會作為唯一的參數(shù)傳遞給該函數(shù)。 該方法負(fù)責(zé)解析返回的數(shù)據(jù)(response data),提取數(shù)據(jù)以及生成需要進一步處理的URL的 Request 對象。
運行我們的爬蟲
進入項目的根目錄,執(zhí)行下列命令啟動spider:
scrapy crawl quotes
這個命令啟動用于爬取 quotes.toscrape.com 的spider,你將得到類似的輸出:
2017-05-10 20:36:17 [scrapy.core.engine] INFO: Spider opened 2017-05-10 20:36:17 [scrapy.extensions.logstats] INFO: Crawled 0 pages (at 0 pages/min), scraped 0 items (at 0 items/min) 2017-05-10 20:36:17 [scrapy.extensions.telnet] DEBUG: Telnet console listening on 127.0.0.1:6023 2017-05-10 20:36:17 [scrapy.core.engine] DEBUG: Crawled (404) <GET http://quotes.toscrape.com/robots.txt> (referer: None) 2017-05-10 20:36:17 [scrapy.core.engine] DEBUG: Crawled (200) <GET http://quotes.toscrape.com/page/1/> (referer: None) 2017-05-10 20:36:17 [scrapy.core.engine] DEBUG: Crawled (200) <GET http://quotes.toscrape.com/page/2/> (referer: None) 2017-05-10 20:36:17 [quotes] DEBUG: Saved file quotes-1.html2017-05-10 20:36:17 [quotes] DEBUG: Saved file quotes-2.html 2017-05-10 20:36:17 [scrapy.core.engine] INFO: Closing spider (finished)
提取數(shù)據(jù)
我們之前只是保存了HTML頁面,并沒有提取數(shù)據(jù)?,F(xiàn)在升級一下代碼,把提取功能加進去。至于如何使用瀏覽器的開發(fā)者模式分析網(wǎng)頁,之前已經(jīng)介紹過了。
import scrapyclass QuotesSpider(scrapy.Spider): name = "quotes" start_urls = [ 'http://quotes.toscrape.com/page/1/', 'http://quotes.toscrape.com/page/2/', ] def parse(self, response): for quote in response.css('div.quote'): yield { 'text': quote.css('span.text::text').extract_first(), 'author': quote.css('small.author::text').extract_first(), 'tags': quote.css('div.tags a.tag::text').extract(), }
再次運行這個爬蟲,你將在日志里看到被提取出的數(shù)據(jù):
2017-05-10 20:38:33 [scrapy.core.scraper] DEBUG: Scraped from <200 http://quotes.toscrape.com/page/1/>{'tags': ['life', 'love'], 'author': 'André Gide', 'text': '“It is better to be hated for what you are than to be loved for what you are not.”'}2017-05-10 20:38:33 [scrapy.core.scraper] DEBUG: Scraped from <200 http://quotes.toscrape.com/page/1/>{'tags': ['edison', 'failure', 'inspirational', 'paraphrased'], 'author': 'Thomas A. Edison', 'text': "“I have not failed. I've just found 10,000 ways that won't work.”"}
保存爬取的數(shù)據(jù)
最簡單存儲爬取的數(shù)據(jù)的方式是使用 Feed exports:
scrapy crawl quotes -o quotes.json
該命令將采用 JSON 格式對爬取的數(shù)據(jù)進行序列化,生成quotes.json文件。
在類似本篇教程里這樣小規(guī)模的項目中,這種存儲方式已經(jīng)足夠。如果需要對爬取到的item做更多更為復(fù)雜的操作,你可以編寫 Item Pipeline,tutorial/pipelines.py在最開始的時候已經(jīng)自動創(chuàng)建了。
最后,初學(xué)者進階的福音
想學(xué)習(xí),基礎(chǔ)不夠?沒關(guān)系,我們提供免費提供VIP基礎(chǔ)學(xué)習(xí)課程,讓你快速入門,掌握Python!
有基礎(chǔ)的小伙伴想學(xué)習(xí)項目實戰(zhàn)?沒問題,每晚八點都有博士大牛帶你學(xué)習(xí)操作項目!
只要你有一顆想學(xué)習(xí)的心,我們隨時歡迎~
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn,海內(nèi)外云服務(wù)器15元起步,三天無理由+7*72小時售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢,專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
網(wǎng)站名稱:手把手教你寫網(wǎng)絡(luò)爬蟲(4)Scrapy入門-創(chuàng)新互聯(lián)
文章起源:http://jinyejixie.com/article26/dpogjg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供商城網(wǎng)站、全網(wǎng)營銷推廣、營銷型網(wǎng)站建設(shè)、企業(yè)建站、電子商務(wù)、企業(yè)網(wǎng)站制作
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)