1. 程式人生 > >5 CrawlSpider操作

5 CrawlSpider操作

CrawlSpider

提問:如果想要通過爬蟲程式去爬取”糗百“全站資料新聞資料的話,有幾種實現方法?

方法一:基於Scrapy框架中的Spider的遞迴爬取進行實現(Request模組遞歸回調parse方法)。

方法二:基於CrawlSpider的自動爬取進行實現(更加簡潔和高效)。

CrawlSpider

一.簡介

  CrawlSpider其實是Spider的一個子類,除了繼承到Spider的特性和功能外,還派生除了其自己獨有的更加強大的特性和功能。其中最顯著的功能就是”LinkExtractors連結提取器“。Spider是所有爬蟲的基類,其設計原則只是為了爬取start_url列表中網頁,而從爬取到的網頁中提取出的url進行繼續的爬取工作使用CrawlSpider更合適。

二.使用

  1.建立scrapy工程:scrapy startproject projectName

  2.建立爬蟲檔案:scrapy genspider -t crawl spiderName www.xxx.com

    --此指令對比以前的指令多了 "-t crawl",表示建立的爬蟲檔案是基於CrawlSpider這個類的,而不再是Spider這個基類。

  3.觀察生成的爬蟲檔案

# -*- coding: utf-8 -*-
import scrapy
from scrapy.linkextractors import LinkExtractor
from scrapy.spiders import
CrawlSpider, Rule class ChoutidemoSpider(CrawlSpider): name = 'choutiDemo' #allowed_domains = ['www.chouti.com'] start_urls = ['http://www.chouti.com/'] rules = ( Rule(LinkExtractor(allow=r'Items/'), callback='parse_item', follow=True), ) def parse_item(self, response): i = {} #i['domain_id'] = response.xpath('//input[@id="sid"]/@value').extract()
#i['name'] = response.xpath('//div[@id="name"]').extract() #i['description'] = response.xpath('//div[@id="description"]').extract() return i

      - 2,3行:匯入CrawlSpider相關模組

  - 7行:表示該爬蟲程式是基於CrawlSpider類的

  - 12,13,14行:表示為提取Link規則

  - 16行:解析方法

  CrawlSpider類和Spider類的最大不同是CrawlSpider多了一個rules屬性,其作用是定義”提取動作“。在rules中可以包含一個或多個Rule物件,在Rule物件中包含了LinkExtractor物件。

    3.1 LinkExtractor:顧名思義,連結提取器。

LinkExtractor(
allow=r'Items/',# 滿足括號中“正則表示式”的值會被提取,如果為空,則全部匹配。
         deny=xxx,  # 滿足正則表示式的則不會被提取。
         restrict_xpaths=xxx, # 滿足xpath表示式的值會被提取
         restrict_css=xxx, # 滿足css表示式的值會被提取
         deny_domains=xxx, # 不會被提取的連結的domains。 
    )
    - 作用:提取response中符合規則的連結。

  3.2 Rule : 規則解析器。根據連結提取器中提取到的連結,根據指定規則提取解析器連結網頁中的內容。

Rule(LinkExtractor(allow=r'Items/'), callback='parse_item', follow=True)

    - 引數介紹:

      引數1:指定連結提取器

      引數2:指定規則解析器解析資料的規則(回撥函式)

      引數3:是否將連結提取器繼續作用到連結提取器提取出的連結網頁中。當callback為None,引數3的預設值為true。

  3.3 rules=( ):指定不同規則解析器。一個Rule物件表示一種提取規則。

  3.4 CrawlSpider整體爬取流程:

    a)爬蟲檔案首先根據起始url,獲取該url的網頁內容

    b)連結提取器會根據指定提取規則將步驟a中網頁內容中的連結進行提取

    c)規則解析器會根據指定解析規則將連結提取器中提取到的連結中的網頁內容根據指定的規則進行解析

    d)將解析資料封裝到item中,然後提交給管道進行持久化儲存

  4.簡單程式碼實戰應用

  4.1 爬蟲檔案:

# -*- coding: utf-8 -*-
import scrapy
from scrapy.linkextractors import LinkExtractor
from scrapy.spiders import CrawlSpider, Rule
from qiubaiBycrawl.items import QiubaibycrawlItem
import re
class QiubaitestSpider(CrawlSpider):
    name = 'qiubaiTest'
    #起始url
    start_urls = ['http://www.qiushibaike.com/']

    #定義連結提取器,且指定其提取規則
    page_link = LinkExtractor(allow=r'/8hr/page/\d+/')

    rules = (
        #定義規則解析器,且指定解析規則通過callback回撥函式
        Rule(page_link, callback='parse_item', follow=True),
    )

    #自定義規則解析器的解析規則函式
    def parse_item(self, response):
        div_list = response.xpath('//div[@id="content-left"]/div')

        for div in div_list:
            #定義item
            item = QiubaibycrawlItem()
            #根據xpath表示式提取糗百中段子的作者
            item['author'] = div.xpath('./div/a[2]/h2/text()').extract_first().strip('\n')
            #根據xpath表示式提取糗百中段子的內容
            item['content'] = div.xpath('.//div[@class="content"]/span/text()').extract_first().strip('\n')

            yield item #將item提交至管道
view

  4.2 item檔案:

# -*- coding: utf-8 -*-

# Define here the models for your scraped items
#
# See documentation in:
# https://doc.scrapy.org/en/latest/topics/items.html

import scrapy


class QiubaibycrawlItem(scrapy.Item):
    # define the fields for your item here like:
    # name = scrapy.Field()
    author = scrapy.Field() #作者
    content = scrapy.Field() #內容
view

  4.3 管道檔案:

# -*- coding: utf-8 -*-

# Define your item pipelines here
#
# Don't forget to add your pipeline to the ITEM_PIPELINES setting
# See: https://doc.scrapy.org/en/latest/topics/item-pipeline.html

class QiubaibycrawlPipeline(object):

    def __init__(self):
        self.fp = None

    def open_spider(self,spider):
        print('開始爬蟲')
        self.fp = open('./data.txt','w')

    def process_item(self, item, spider):
        #將爬蟲檔案提交的item寫入檔案進行持久化儲存
        self.fp.write(item['author']+':'+item['content']+'\n')
        return item

    def close_spider(self,spider):
        print('結束爬蟲')
        self.fp.close()
view