java启动scrapy爬虫,爬虫入门之Scrapy 框架基础功能(九)详解
Scrapy是用純Python實(shí)現(xiàn)一個(gè)為了爬取網(wǎng)站數(shù)據(jù)、提取結(jié)構(gòu)性數(shù)據(jù)而編寫的應(yīng)用框架,用途非常廣泛。
框架的力量,用戶只需要定制開發(fā)幾個(gè)模塊就可以輕松的實(shí)現(xiàn)一個(gè)爬蟲,用來(lái)抓取網(wǎng)頁(yè)內(nèi)容以及各種圖片,非常之方便。
Scrapy 使用了 Twisted(其主要對(duì)手是Tornado)多線程異步網(wǎng)絡(luò)框架來(lái)處理網(wǎng)絡(luò)通訊,可以加快我們的下載速度,不用自己去實(shí)現(xiàn)異步框架,并且包含了各種中間件接口,可以靈活的完成各種需求。
1 Scrapy架構(gòu)圖(綠線是數(shù)據(jù)流向)
Scrapy Engine(引擎): 負(fù)責(zé)Spider、ItemPipeline、Downloader、Scheduler中間通訊,信號(hào)、數(shù)據(jù)傳遞等。
Scheduler(調(diào)度器): 它負(fù)責(zé)接受引擎發(fā)送過(guò)來(lái)的Request請(qǐng)求,并按照一定的方式進(jìn)行整理排隊(duì),當(dāng)引擎需要時(shí),交還給引擎。
Downloader(下載器):負(fù)責(zé)下載Scrapy Engine(引擎)發(fā)送的所有Requests請(qǐng)求,并將其獲取到的Responses交還給Scrapy Engine(引擎),由引擎交給Spider來(lái)處理.
Spider(爬蟲):它負(fù)責(zé)處理所有Responses,從中分析提取數(shù)據(jù),獲取Item字段需要的數(shù)據(jù),并將需要跟進(jìn)的URL提交給引擎,再次進(jìn)入Scheduler(調(diào)度器),
Item Pipeline(管道):負(fù)責(zé)處理Spider中獲取到的Item,并進(jìn)行后期處理(分析、過(guò)濾、存儲(chǔ)等)地方.
Downloader Middlewares(下載中間件):你可以當(dāng)作是一個(gè)可以自定義擴(kuò)展下載功能的組件。
Spider Middlewares(Spider中間件):你可以理解為是一個(gè)可以自定擴(kuò)展和操作引擎和Spider中間通信的功能組件(比如進(jìn)入Spider的Responses;和從Spider出去的Requests)
2 Scrapy的運(yùn)作流程
代碼寫好,程序開始運(yùn)行...
引擎:Hi!Spider, 你要處理哪一個(gè)網(wǎng)站?
Spider:老大要我處理xxxx.com。
引擎:你把第一個(gè)需要處理的URL給我吧。
Spider:給你,第一個(gè)URL是xxxxxxx.com。
引擎:Hi!調(diào)度器,我這有request請(qǐng)求你幫我排序入隊(duì)一下。
調(diào)度器:好的,正在處理你等一下。
引擎:Hi!調(diào)度器,把你處理好的request請(qǐng)求給我。
調(diào)度器:給你,這是我處理好的request
引擎:Hi!下載器,你按照老大的下載中間件的設(shè)置幫我下載一下這個(gè)request請(qǐng)求
下載器:好的!給你,這是下載好的東西。(如果失敗:sorry,這個(gè)request下載失敗了。然后引擎告訴調(diào)度器,這個(gè)request下載失敗了,你記錄一下,我們待會(huì)兒再下載)
引擎:Hi!Spider,這是下載好的東西,并且已經(jīng)按照老大的下載中間件處理過(guò)了,你自己處理一下(注意!這兒responses默認(rèn)是交給def parse()這個(gè)函數(shù)處理的)
Spider:(處理完畢數(shù)據(jù)之后對(duì)于需要跟進(jìn)的URL),Hi!引擎,我這里有兩個(gè)結(jié)果,這個(gè)是我需要跟進(jìn)的URL,還有這個(gè)是我獲取到的Item數(shù)據(jù)。
引擎:Hi !管道我這兒有個(gè)item你幫我處理一下!調(diào)度器!這是需要跟進(jìn)URL你幫我處理下。然后從第四步開始循環(huán),直到獲取完老大需要全部信息。
管道``調(diào)度器:好的,現(xiàn)在就做!
注意!只有當(dāng)調(diào)度器中不存在任何request了,整個(gè)程序才會(huì)停止,(也就是說(shuō),對(duì)于下載失敗的URL,Scrapy也會(huì)重新下載。)
3 Scrapy的安裝介紹
1、安裝wheel pip3 install wheel
2、安裝lxml pip3 install lxml-4.2.1-cp36-cp36m-win_amd64.whl
3、安裝pyopenssl (已安裝就不需要安裝)
4、安裝Twisted pip3 install Twisted-18.4.0-cp36-cp36m-win_amd64.whl
5、安裝pywin32 pip3 install pypiwin32
6、安裝scrapy pip3 install scrapy
或者pip3 install Scrapy-1.5.0-py2.py3-none-any.whl
Windows 安裝方式
Python 2 / 3
升級(jí)pip版本:
pip install --upgrade pip
通過(guò)pip 安裝 Scrapy 框架
pip install Scrapy
Ubuntu 需要9.10或以上版本安裝方式
Python 2 / 3
安裝非Python的依賴
sudo apt-get install python-dev python-pip libxml2-dev libxslt1-dev zlib1g-dev libffi-dev libssl-dev
通過(guò)pip 安裝 Scrapy 框架
sudo pip install scrapy
安裝后,只要在命令終端輸入 scrapy,提示類似以下結(jié)果,代表已經(jīng)安裝成功
具體Scrapy安裝流程參考:http://doc.scrapy.org/en/latest/intro/install.html#intro-install-platform-notes里面有各個(gè)平臺(tái)的安裝方法
4 制作 Scrapy 爬蟲 一共需要4步:
新建一個(gè)新的爬蟲項(xiàng)目
scrapy startproject mySpider
進(jìn)入該目錄 cd mySpider
scrapy genspider stack http://stackoverflow.com/ #創(chuàng)建一個(gè)爬蟲stack 指定爬取路徑
明確目標(biāo) (編寫items.py):明確你想要抓取的目標(biāo)(目標(biāo)信息采用類與字段的方式實(shí)現(xiàn))
制作爬蟲 (spiders/xxspider.py):制作爬蟲開始爬取網(wǎng)頁(yè)(實(shí)現(xiàn)主要邏輯地方,并返回item)
存儲(chǔ)內(nèi)容 (pipelines.py):設(shè)計(jì)管道存儲(chǔ)爬取內(nèi)容(接受item,一般重寫幾個(gè)常用的方法(open_spider,process_item,close_spider)
啟動(dòng)爬蟲項(xiàng)目
命令啟動(dòng): scrapy crawl spidername(爬蟲名)
文件啟動(dòng)
from scrapy import cmdline
# 方式一:注意execute的參數(shù)類型為一個(gè)列表
cmdline.execute('scrapy crawl spidername'.split())
# 方式二:注意execute的參數(shù)類型為一個(gè)列表
cmdline.execute(['scrapy', 'crawl', 'spidername'])
5 入門案例
一. 新建項(xiàng)目(scrapy startproject)
在開始爬取之前,必須創(chuàng)建一個(gè)新的Scrapy項(xiàng)目。進(jìn)入自定義的項(xiàng)目目錄中,運(yùn)行下列命令:
scrapy startproject mySpider
其中, mySpider 為項(xiàng)目名稱,可以看到將會(huì)創(chuàng)建一個(gè) mySpider 文件夾,目錄結(jié)構(gòu)大致如下:
下面來(lái)簡(jiǎn)單介紹一下各個(gè)主要文件的作用:
scrapy.cfg :項(xiàng)目的配置文件
mySpider/ :項(xiàng)目的Python模塊,將會(huì)從這里引用代碼
mySpider/items.py :項(xiàng)目的目標(biāo)文件
mySpider/pipelines.py :項(xiàng)目的管道文件
mySpider/settings.py :項(xiàng)目的設(shè)置文件
mySpider/spiders/ :存儲(chǔ)爬蟲代碼目錄
二、明確目標(biāo)(mySpider/items.py)
我們打算抓取:http://bbs.tianya.cn/post-140-393968-1.shtml 網(wǎng)站里的郵箱。
打開mySpider目錄下的items.py
Item 定義結(jié)構(gòu)化數(shù)據(jù)字段,用來(lái)保存爬取到的數(shù)據(jù),類似dict,但是提供了一些額外的保護(hù)減少錯(cuò)誤。
可以通過(guò)創(chuàng)建一個(gè) scrapy.Item 類, 并且定義類型為 scrapy.Field的類屬性來(lái)定義一個(gè)Item(可以理解成類似于ORM的映射關(guān)系)。
接下來(lái),創(chuàng)建一個(gè)TianyaItem類,和構(gòu)建item模型(model)。
import scrapy
class TianyaItem(scrapy.Item):
email = scrapy.Field() #只定義爬取email字段
三、制作爬蟲 (spiders/itcastSpider.py)
爬蟲功能要分兩步:
1. 爬數(shù)據(jù)
在當(dāng)前目錄下輸入命令
scrapy genspider mytianya "bbs.tianya.cn" #指定爬蟲文件名 爬取的域名
打開 mySpider/spider目錄里的 mytianya .py,默認(rèn)增加了下列代碼:
import scrapy
import re
from tianya import items
class MytianyaSpider(scrapy.Spider):
name = 'mytianya'
allowed_domains = ['bbs.tianya.cn']
start_urls = ['http://bbs.tianya.cn/post-140-393977-1.shtml']
#主要的邏輯模塊
def parse(self, response):
pass
其實(shí)也可以由我們自行創(chuàng)建itcast.py并編寫上面的代碼,只不過(guò)使用命令可以免去編寫固定代碼的麻煩
要建立一個(gè)Spider, 你必須用scrapy.Spider類創(chuàng)建一個(gè)子類,并確定了三個(gè)強(qiáng)制的屬性 和 一個(gè)方法。
name = "":這個(gè)爬蟲的識(shí)別名稱,必須是唯一的,在不同的爬蟲必須定義不同的名字。
allow_domains = []是搜索的域名范圍,也就是爬蟲的約束區(qū)域,規(guī)定爬蟲只爬取這個(gè)域名下的網(wǎng)頁(yè),不存在的URL會(huì)被忽略。
start_urls = ():爬取的URL元組/列表。爬蟲從這里開始抓取數(shù)據(jù),第一次下載的數(shù)據(jù)將會(huì)從這些urls開始。其他子URL將會(huì)從這些起始URL中繼承性生成. 將start_urls的值修改為需要爬取的第一個(gè)url.
parse(self, response):解析的方法,每個(gè)初始URL完成下載后將被調(diào)用,調(diào)用的時(shí)候傳入從每一個(gè)URL傳回的Response對(duì)象來(lái)作為唯一參數(shù),主要作用如下:
負(fù)責(zé)解析返回的網(wǎng)頁(yè)數(shù)據(jù)(response.body),提取結(jié)構(gòu)化數(shù)據(jù)(生成item)
生成需要下一頁(yè)的URL請(qǐng)求。
修改parse()方法
def parse(self, response):
html = response.body.decode()
# [email?protected]
email = re.compile(r"([A-Z0-9_]+@[A-Z0-9]+\.[A-Z]{2,4})", re.I)
emailList = email.findall(html)
mydict = []
for e in emailList:
item = items.TianyaItem()
item["email"] = e
# mydict[e] = "http://bbs.tianya.cn/post-140-393977-1.shtml"
mydict.append(item)
return mydict
然后運(yùn)行一下看看,在mySpider目錄下執(zhí)行:
scrapy crawl mytianya
2.保存數(shù)據(jù)
scrapy保存信息的最簡(jiǎn)單的方法主要有四種,-o 輸出指定格式的文件,,命令如下:
scrapy crawl mytianya -o mytianya.json
scrapy crawl mytianya -o mytianya.csv
scrapy crawl mytianya -o mytianya.xml
yield 在這里的作用:
def parse(self, response):
html = response.body.decode()
# [email?protected]
email = re.compile(r"([A-Z0-9_]+@[A-Z0-9]+.[A-Z]{2,4})", re.I)
emailList = email.findall(html)
mydict = []
for e in emailList:
item = items.TianyaItem()
item["email"] = e
yield mydict #得到生成器對(duì)象,每循環(huán)一次,返回一個(gè)item
總結(jié)
以上是生活随笔為你收集整理的java启动scrapy爬虫,爬虫入门之Scrapy 框架基础功能(九)详解的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: 必应集成 AI 对话,调查称不少用户开始
- 下一篇: oracle rowID切片,Oracl