scrapy-redis使用詳解
描述:
1.使用兩台機器,一台是win10,一台是centos7,分別在兩台機器上部署scrapy來進行分布式抓取一個網站
2.centos7的ip地址為192.168.1.112,用來作為redis的master端,win10的機器作為slave
3.master的爬蟲運行時會把提取到的url封裝成request放到redis中的數據庫:“dmoz:requests”,並且從該數據庫中提取request后下載網頁,再把網頁的內容存放到redis的另一個數據庫中“dmoz:items”
4.slave從master的redis中取出待抓取的request,下載完網頁之后就把網頁的內容發送回master的redis
5.重復上面的3和4,直到master的redis中的“dmoz:requests”數據庫為空,再把master的redis中的“dmoz:items”數據庫寫入到mongodb中
6.master里的reids還有一個數據“dmoz:dupefilter”是用來存儲抓取過的url的指紋(使用哈希函數將url運算后的結果),是防止重復抓取的
安裝redis(http://blog.fens.me/linux-redis-install/)
windows安裝redis
下載地址:https://github.com/rgl/redis/downloads
選擇最新版和你電腦的對應版本下載安裝
安裝完成后,
運行redis服務器的命令:安裝目錄下的redis-server.exe
運行redis客戶端的命令:安裝目錄下的redis-cli.exe
centos7安裝redis
直接運行命令:yum install redis -y即可,安裝完成后默認啟動redis服務器
安裝完成后,redis默認是不能被遠程連接的,此時要修改配置文件/etc/redis.conf
#注釋bind #bind 127.0.0.1
修改后,重啟redis服務器
systemctl restart redis
在centos7環境下啟動redis服務器的命令:systemctl start redis,啟動客戶端的命令:redis-cli
如果要增加redis的訪問密碼,修改配置文件/etc/redis.conf
#取消注釋requirepass requirepass redisredis # redisredis就是密碼(記得自己修改)
增加了密碼后,啟動客戶端的命令變為:redis-cli -a redisredis
測試是否能遠程登陸
使用windows的命令窗口進入redis安裝目錄,用命令進行遠程連接centos7的redis:
redis-cli -h 192.168.1.112 -p 6379
在本機上測試是否能讀取master的redis
在遠程機器上讀取是否有該數據
可以確信redis安裝完成
安裝部署scrapy-redis
安裝scrapy-redis命令(https://github.com/rolando/scrapy-redis)
pip install scrapy-redis
部署scrapy-redis:
slave端:在windows上的settings.py文件的最后增加如下一行
REDIS_URL = 'redis://192.168.1.112:6379'
master端:在centos7上的settings.py文件的最后增加如下兩行
REDIS_HOST = 'localhost' REDIS_PORT = 6379
在windows中配置好了遠程的redis地址后啟動兩個爬蟲(啟動爬蟲沒有順序限制),此時在windows上查看redis,可以看到windows上運行的爬蟲的確是從遠程的reids里獲取request的(因為本地的redis沒有東西)
由此確認好了scrapy-redis安裝配置完成
使用redis-dump將redis的數據導出來查看(可選)
在centos7上安裝redis-dump (https://github.com/delano/redis-dump)
yum -y install gcc ruby-devel rubygems compass gem
修改rvm安裝源(http://genepeng.com/index.php/346)
gem sources --remove https://rubygems.org/ gem sources -a https://ruby.taobao.org/ gem sources -l gem install redis-dump -y
運行了example里的dmoz之后,連接redis,查看到生成了以下的三個數據庫,並且每個value對應的類型如下
在centos7上使用redis-dump命令(redis-dump -u 127.0.0.1:6379 > db_full.json)導出該數據庫,再查看存儲到的數據(在這里我只提取了每個數據庫的前幾條)
下圖就是上面數據庫“dmoz:items”里所爬取的內容
將爬取到的數據導入到mongodb中
等到爬蟲結束后,此時運行process_items.py來把位於master的redis中的“dmoz:items”逐一讀取到json中,所以如果要把item存儲到mongodb中,就應該修改process_items.py文件,如下
#!/usr/bin/env python # -*- coding: utf-8 -*- import json import redis import pymongo def main(): # r = redis.Redis() r = redis.Redis(host='192.168.1.112',port=6379,db=0) client = pymongo.MongoClient(host='localhost', port=27017) db = client['dmoz'] sheet = db['sheet'] while True: # process queue as FIFO, change `blpop` to `brpop` to process as LIFO source, data = r.blpop(["dmoz:items"]) item = json.loads(data) sheet.insert(item) try: print u"Processing: %(name)s <%(link)s>" % item except KeyError: print u"Error procesing: %r" % item if __name__ == '__main__': main()
其實可以在爬蟲一邊運行的時候,一邊運行process_items.py文件
注意:如果要重新運行爬蟲記得把master上的redis清空,因為master里的數據庫“dmoz:dupefilter”是用來過濾重復的請求
192.168.1.112:6379> flushdb