博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
5 CrawlSpider操作
阅读量:6592 次
发布时间:2019-06-24

本文共 4242 字,大约阅读时间需要 14 分钟。

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 scrapyfrom scrapy.linkextractors import LinkExtractorfrom scrapy.spiders import CrawlSpider, Ruleclass 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 scrapyfrom scrapy.linkextractors import LinkExtractorfrom scrapy.spiders import CrawlSpider, Rulefrom qiubaiBycrawl.items import QiubaibycrawlItemimport reclass 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.htmlimport scrapyclass 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.htmlclass 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

转载于:https://www.cnblogs.com/wenyule/p/9992475.html

你可能感兴趣的文章
七、MySQL中的字符集 - 系统的撸一遍MySQL
查看>>
centos7的php5.4竟然不支持原生的mysql
查看>>
使用IntelliJ IDEA开发SpringMVC网站(四)用户管理
查看>>
ajax加载数据到页面无法打印的解决办法
查看>>
js 验证中文
查看>>
Linux下运行java DES AES加解密
查看>>
DataNode 运行状况
查看>>
牛津词典 2018 年度词汇 ——「有毒」!
查看>>
XIB的是用
查看>>
Learning Data Structure_2_线性表、栈和队列
查看>>
Android Arcface人脸识别sdk使用工具类
查看>>
android studio单个工程文件的代理设置
查看>>
Agent admitted failure to sign using the key
查看>>
grep 应用
查看>>
我的友情链接
查看>>
Linux实验室 CentOS关机大法
查看>>
一行命令获取当前JVM所有可设置的参数以及当前默认值
查看>>
spring与struts2 mvc共存web.xml简单配置
查看>>
Python web爬虫
查看>>
详解性能调优命令
查看>>