scrapy-redis使用詳解


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

wps96F0.tmp

選擇最新版和你電腦的對應版本下載安裝

安裝完成后,

運行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

wps96F1.tmp

在本機上測試是否能讀取master的redis

wps96F2.tmp

在遠程機器上讀取是否有該數據

wps96F3.tmp

可以確信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沒有東西)

圖片3

 由此確認好了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對應的類型如下

wps9705.tmp

在centos7上使用redis-dump命令(redis-dump -u 127.0.0.1:6379 > db_full.json)導出該數據庫,再查看存儲到的數據(在這里我只提取了每個數據庫的前幾條)

圖片2

下圖就是上面數據庫“dmoz:items”里所爬取的內容

圖片1

 

將爬取到的數據導入到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


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM