scrapy框架持久化儲存

阿新 • • 發佈：2020-07-12

今日概要

基於終端指令的持久化儲存
基於管道的持久化儲存

今日詳情

1.基於終端指令的持久化儲存

保證爬蟲檔案的parse方法中有可迭代型別物件（通常為列表or字典）的返回，該返回值可以通過終端指令的形式寫入指定格式的檔案中進行持久化操作。

執行輸出指定格式進行儲存：將爬取到的資料寫入不同格式的檔案中進行儲存
    scrapy crawl 爬蟲名稱 -o xxx.json
    scrapy crawl 爬蟲名稱 -o xxx.xml
    scrapy crawl 爬蟲名稱 -o xxx.csv

2.基於管道的持久化儲存

scrapy框架中已經為我們專門整合好了高效、便捷的持久化操作功能，我們直接使用即可。要想使用scrapy的持久化操作功能，我們首先來認識如下兩個檔案：

    items.py：資料結構模板檔案。定義資料屬性。
    pipelines.py：管道檔案。接收資料（items），進行持久化操作。

持久化流程：
    1.爬蟲檔案爬取到資料後，需要將資料封裝到items物件中。
    2.使用yield關鍵字將items物件提交給pipelines管道進行持久化操作。
    3.在管道檔案中的process_item方法中接收爬蟲檔案提交過來的item物件，然後編寫持久化儲存的程式碼將item物件中儲存的資料進行持久化儲存
    4.settings.py配置檔案中開啟管道

小試牛刀：將糗事百科首頁中的段子和作者資料爬取下來，然後進行持久化儲存

- 爬蟲檔案：qiubaiDemo.py

# -*- coding: utf-8 -*-
import scrapy
from secondblood.items import SecondbloodItem

class QiubaidemoSpider(scrapy.Spider):
    name = 'qiubaiDemo'
    allowed_domains = ['www.qiushibaike.com']
    start_urls = ['http://www.qiushibaike.com/']

    def parse(self, response):
        odiv = response.xpath('//div[@id="content-left"]/div')
        for div in odiv:
            # xpath函式返回的為列表，列表中存放的資料為Selector型別的資料。我們解析到的內容被封裝在了Selector物件中，需要呼叫extract()函式將解析的內容從Selecor中取出。
            author = div.xpath('.//div[@class="author clearfix"]//h2/text()').extract_first()
            author = author.strip('\n')#過濾空行
            content = div.xpath('.//div[@class="content"]/span/text()').extract_first()
            content = content.strip('\n')#過濾空行

            #將解析到的資料封裝至items物件中
            item = SecondbloodItem()
            item['author'] = author
            item['content'] = content

            yield item#提交item到管道檔案（pipelines.py）

- items檔案：items.py

import scrapy


class SecondbloodItem(scrapy.Item):
    # define the fields for your item here like:
    # name = scrapy.Field()
    author = scrapy.Field() #儲存作者
    content = scrapy.Field() #儲存段子內容

-管道檔案：pipelines.py

# -*- 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 SecondbloodPipeline(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):
        self.fp.close()
        print('爬蟲結束')

-配置檔案：settings.py

#開啟管道
ITEM_PIPELINES = {
    'secondblood.pipelines.SecondbloodPipeline': 300, #300表示為優先順序，值越小優先順序越高
}

2.1 基於mysql的管道儲存

小試牛刀案例中，在管道檔案裡將item物件中的資料值儲存到了磁碟中，如果將item資料寫入mysql資料庫的話，只需要將上述案例中的管道檔案修改成如下形式：

- pipelines.py檔案

# -*- 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

#匯入資料庫的類
import pymysql
class QiubaiproPipelineByMysql(object):

    conn = None  #mysql的連線物件宣告
    cursor = None#mysql遊標物件宣告
    def open_spider(self,spider):
        print('開始爬蟲')
        #連結資料庫
        self.conn = pymysql.Connect(host='127.0.0.1',port=3306,user='root',password='123456',db='qiubai')
    #編寫向資料庫中儲存資料的相關程式碼
    def process_item(self, item, spider):
        #1.連結資料庫
        #2.執行sql語句
        sql = 'insert into qiubai values("%s","%s")'%(item['author'],item['content'])
        self.cursor = self.conn.cursor()
        #執行事務
        try:
            self.cursor.execute(sql)
            self.conn.commit()
        except Exception as e:
            print(e)
            self.conn.rollback()

        return item
    def close_spider(self,spider):
        print('爬蟲結束')
        self.cursor.close()
        self.conn.close()

- settings.py

ITEM_PIPELINES = {
    'qiubaiPro.pipelines.QiubaiproPipelineByMysql': 300,
}

2.2 基於redis的管道儲存

小試牛刀案例中，在管道檔案裡將item物件中的資料值儲存到了磁碟中，如果將item資料寫入redis資料庫的話，只需要將上述案例中的管道檔案修改成如下形式：

# -*- 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

import redis

class QiubaiproPipelineByRedis(object):
    conn = None
    def open_spider(self,spider):
        print('開始爬蟲')
        #建立連結物件
        self.conn = redis.Redis(host='127.0.0.1',port=6379)
    def process_item(self, item, spider):
        dict = {
            'author':item['author'],
            'content':item['content']
        }
        #寫入redis中
        self.conn.lpush('data', dict)
        return item

- pipelines.py檔案

ITEM_PIPELINES = {
    'qiubaiPro.pipelines.QiubaiproPipelineByRedis': 300,
}

- 面試題：如果最終需要將爬取到的資料值一份儲存到磁碟檔案，一份儲存到資料庫中，則應該如何操作scrapy？　　

- 答：管道檔案中的程式碼為

#該類為管道類，該類中的process_item方法是用來實現持久化儲存操作的。
class DoublekillPipeline(object):

    def process_item(self, item, spider):
        #持久化操作程式碼 （方式1：寫入磁碟檔案）
        return item

#如果想實現另一種形式的持久化操作，則可以再定製一個管道類：
class DoublekillPipeline_db(object):

    def process_item(self, item, spider):
        #持久化操作程式碼 （方式1：寫入資料庫）
        return item

在settings.py開啟管道操作程式碼為：

#下列結構為字典，字典中的鍵值表示的是即將被啟用執行的管道檔案和其執行的優先順序。
ITEM_PIPELINES = {
   'doublekill.pipelines.DoublekillPipeline': 300,
    'doublekill.pipelines.DoublekillPipeline_db': 200,
}

#上述程式碼中，字典中的兩組鍵值分別表示會執行管道檔案中對應的兩個管道類中的process_item方法，實現兩種不同形式的持久化操作。