low-level~python scrapy多级页面爬取并存储为JSON格式

在上一篇scrapy(low-level~python scrapy自动爬取网页的爬虫)[https://www.jianshu.com/p/9b07e556216e]中我们实现了翻页操作,但是这种操作不利于改动。这次改进为分模块编程的思想。
思路:
第一步:提取每页的链接
第二步:提取每页商品的链接
第三步:提取每页商品的具体信息
这里的难点在于

for i in range(1,3):
     url ="http://category.dangdang.com/pg"+str(i)+"-cp01.05.16.00.00.00.html
      #通过yield返回Reques,并指定要爬取的网址和回调函数
      yield Request(url,callback=self.parse)

Request函数的参数callback,这个参数决定着接下来执行什么操作。
首先我们知道spider中初始的request是通过调用start_requests()来获取,start_requests()读取start_urls中的URL,所以我们每页链接的提取放在start_requests()中处理

def start_requests(self):
         start_urls = ['http://category.dangdang.com/pg1-cp01.05.16.00.00.00.html',]
          start,end=1,3
          for i in range(start,end):
              print(str(i))
              url="http://category.dangdang.com/pg"+str(i)+"-cp01.05.16.00.00.00.html"
              print(url)
              yield scrapy.http.Request(url,self.parse)

yield scrapy.http.Request(url,self.parse)含义:

 Request请求url链接,回调parse()函数

接下来我们定义函数parse(),这个函数负责提取每个页面商品的链接。分析页面代码

《low-level~python scrapy多级页面爬取并存储为JSON格式》 image.png

如图所示,所有的商品信息都在<li>*</li>标签下,而这些li标签在<ul class=”bigimg” id=”component_0__0__6612″>下面。所以当我们得到页面的url之后,先提取ul class….这个大标签,然后循环提取每一个商品的链接标签,代码如下:

 def parse(self,response):
         urls = response.xpath("//*[@id='component_0__0__6612']/li")
         for url in urls:
              href=url.xpath("a[@class='pic']/@href").extract_first()
             print(href)
              request=scrapy.http.Request(href,callback=self.parseArticle)
             yield request

最后一步,进入商品详细链接中提取title属性
首先定义一个item,存储爬取的数据信息,然后用xpath提取我们需要的标签

def parseArticle(self,response):
          item =AutopjtItem()
          item['name']=response.xpath('//
           [@id="product_info"]/div[1]/h2/span[1]/@title').extract()
          print(item['name'])
          yield item

完成,中间遇到很多的坑,一一列举,避免再次发生
1,class类中的name值必须是我们的文件名,否则会报错:

KeyError: ‘Spider not found: autospd

2,当我们提取<ul class=”bigimg” id=”component_0__0__6612″>大标签时,不能用extract()函数。否则什么都得不到(不要问我怎么知道的,都是泪,,,,,,,)

《low-level~python scrapy多级页面爬取并存储为JSON格式》 image.png

完整代码如下

# -*- coding: utf-8 -*-
  2 import scrapy
  3 from autopjt.items import AutopjtItem
  4 from scrapy.http import Request
  5 from scrapy.selector import Selector
  6 #创建一个爬虫类AutospdSpider,该类继承了scrapy.Spider基类
  7 class AutospdSpider(scrapy.Spider):
  8     name = "autospd"
  9    # urlList = []
 10     #name属性代表的是爬虫名称
 11     #allowed_domains属性代表的是允许爬行的域名
 12     allowed_domains = ["dangdang.com"]
 13     #爬行的起始网址
 14    # start_urls = ['http://category.dangdang.com/pg1-cp01.05.16.00.00.00.html',]
 15     def start_requests(self):
 16         start_urls = ['http://category.dangdang.com/pg1-cp01.05.16.00.00.00.html',]
 17         start,end=1,3
 18         for i in range(start,end):
 19             print(str(i))
 20             url="http://category.dangdang.com/pg"+str(i)+"-cp01.05.16.00.00.00.html"
 21             print(url)
 22             yield scrapy.http.Request(url,self.parse)
 23 #得到页链接,对每个页链接找到每一个商品链接
 24     def parse(self,response):
 25         urls = response.xpath("//*[@id='component_0__0__6612']/li")
 26         for url in urls:
 27             href=url.xpath("a[@class='pic']/@href").extract_first()
 28             print(href)
 29             request=scrapy.http.Request(href,callback=self.parseArticle)
 30             yield request
 31     def parseArticle(self,response):
 32         item =AutopjtItem()
 33         item['name']=response.xpath('//*[@id="product_info"]/div[1]/h2/span[1]/@title').extract()
 34         yield item

当item在Spider中被收集之后,将会被传递到item Pipeline,Item Pipeline,在pipeline.py文件中对提取到的数据进行进一步的处理。

class AutopjtPipeline(object):
      def __init__(self):
          self.file = codecs.open("mydata.json","wb",encoding="utf-8")
       #这个方法必须返回一个Item对象,参数item:被爬取的item,spider爬取该item的spider
      def process_item(self, item, spider):
         #打开JSON文件,向里面以dumps的方式吸入数据,其中ensure_ascii=False,   不然数据会直接为utf编码的方式存入
          i = json.dumps(dict(item),ensure_ascii=False)
          #每条数据后加上换行
          line = i +'\n'
          #数据写到mydata.json文件中
          self.file.write(line)
         return item
      def close_spider(self,spider):
          self.file.close()

保存的文件的打开路径直接写想保存的XXX.json即可
再有一步就可以完成了,在pipelines.py处理成为json格式时,还需要在settings.py文件告诉系统pipelines文件在哪里以及pipeline文件里面对应的类是什么,找到settings.py文件中关于pipelines的设置部分,

ITEM_PIPELINES={
          'autopjt.pipelines.AutopjtPipeline':300,
    #分配给每个类的整型值,确定他们的运行顺序,item按数字从低到高的顺序通过pipeline
         }

在上面代码中,’autopjt.pipelines.AutopjtPipeline’中的autopjt为项目名(即Scrapy项目的核心目录名),pipelines代表autopjt目录下的pipelines.py文件的文件名,AutopjtPipeline代表对应的pipelines文件里的类。

再次运行spider文件,vim XXXX.json就可以打开json格式的文件

《low-level~python scrapy多级页面爬取并存储为JSON格式》 image.png

参考来源

狸狸深深【补充更新Report B2】Scrapy分页爬取四川大学公共管理学院全职教师信息及学院新闻
Requests and Responses

    原文作者:潘雪雯
    原文地址: https://www.jianshu.com/p/82ab21cdd019
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞