python应用:爬虫框架Scrapy系统学习第四篇——scrapy爬取笔趣阁小说
使用cmd创建一个scrapy项目:
scrapy startproject project_name (project_name 必须以字母开头,只能包含字母、数字以及下划线
项目目录层级如下:
声明Item
声明我们可能用到的所有字段,包括管理字段等。管理字段可以让我们清楚何时(date)、何地(url server)及如何(spider)执行爬去,此外,还可以自动完成诸如使item失效、规划新的抓取迭代或是删除来自有问题的爬虫的item。
管理字段 |
Python表达式 |
url |
response.url 例:‘http://www.baidu.com’ |
project |
self.ettings.get('BOT_NAME') 例:‘crawl_novel’ |
spider |
self.name 例:‘basic’ |
server |
socket.gethostname() 例:‘scrapyserverl’ |
date |
datetime.datetime.now() 例:‘datetime.datetime(2019,1,21……)’ |
1 # -*- coding: utf-8 -*- 2 3 # Define here the models for your scraped items 4 # 5 # See documentation in: 6 # https://doc.scrapy.org/en/latest/topics/items.html 7 8 import scrapy 9 10 11 class CrawlNovelItem(scrapy.Item): 12 # Primary fields 13 title = scrapy.Field() 14 author = scrapy.Field() 15 classify = scrapy.Field() 16 recommend = scrapy.Field() 17 chapter_urls = scrapy.Field() 18 19 # Calculated fields 20 chapter = scrapy.Field() 21 22 # Housekeeping fields 23 url = scrapy.Field() 24 project = scrapy.Field() 25 spider = scrapy.Field() 26 server = scrapy.Field() 27 date = scrapy.Field()
编写爬虫并填充item
使用scrapy genspider 命令
scrapy genspider -l 查看可用模板
scrapy genspider -t 使用任意其他模板创建爬虫
e.g. scrapy genspider basic www spiders目录中新增一个basic.py文件,并限制只能爬取www域名下的url
使用 scrapy crawl 命令运行爬虫文件
e.g. scrapy crawl basic (basic是spider下的爬虫文件)
使用 scrapy parse命令用不同页面调试代码
e.g. scrapy parse --spider=basic http://www.……
使用scrapy crawl basic -o +文件名.文件类型 保存文件
e.g. scrapy crawl basic -o items.json(items.csv、items.j1、items.xml)
basic.py
1 # -*- coding: utf-8 -*- 2 import scrapy 3 4 from crawl_novel.items import CrawlNovelItem 5 6 7 class BasicSpider(scrapy.Spider): 8 name = 'basic' 9 allowed_domains = ['www'] 10 start_urls = ['http://www.biquge.info/22_22559/'] 11 12 def parse(self, response): 13 ''' 14 self.log("title: %s" % response.xpath('//h1[1]/text()').extract()) 15 self.log("author: %s" % response.xpath('//*[@id="info"]/p[1]/text()').extract()) 16 self.log("classify: %s" % response.xpath('//*[@id="info"]/p[2]/text()').extract()) 17 self.log("recommend: %s" % response.xpath('//*[@id="listtj"]//text()').extract()) 18 self.log("chapter_urls %s" % response.xpath('//*[@id="list"]//a').extract()) 19 ''' 20 # 填充item 21 item = CrawlNovelItem() 22 item['title'] = response.xpath('//h1[1]/text()').extract() 23 item['author'] = response.xpath('//*[@id="info"]/p[1]/text()').extract() 24 item['classify'] = response.xpath('//*[@id="info"]/p[2]/text()').extract() 25 item['recommend'] = response.xpath('//*[@id="listtj"]//text()').extract()
26 item['chapter_urls'] = response.xpath('//*[@id="list"]//a/@href').extract()
27 return item
清理——item装载器、添加管理字段,并对数据进行格式化和清洗
使用ItemLoader以代替那些杂乱的extract()和xpath()操作
使用MapCompose参数
使用lambda表达式
1 # -*- coding: utf-8 -*- 2 import datetime 3 import socket 4 import urlparse 5 6 import scrapy 7 from scrapy.loader import ItemLoader 8 from scrapy.loader.processors import MapCompose, Join 9 10 from crawl_novel.items import CrawlNovelItem 11 12 13 class BasicSpider(scrapy.Spider): 14 name = 'basic' 15 allowed_domains = ['www'] 16 start_urls = ['http://www.biquge.info/22_22559/'] 17 18 def parse(self, response): 19 # 定义装载器 20 l = ItemLoader(item=CrawlNovelItem(), response=response) 21 # 使用处理器 22 # 去除首位空白符,使结果按照收尾标题格式 23 l.add_xpath('title', '//h1[1]/text()', MapCompose(unicode.strip, unicode.title)) 24 l.add_xpath('author', '//*[@id="info"]/p[1]/text()', MapCompose(unicode.strip)) 25 l.add_xpath('classify', '//*[@id="info"]/p[2]/text()', MapCompose(unicode.strip)) 26 # 将多个结果连接在一起 27 l.add_xpath('recommend', '//*[@id="listtj"]//text()', Join()) 28 # 使用lambda表达式(以response.url为基础,将相对路径i转化为绝对路径) 29 l.add_xpath('chapter_urls', '//*[@id="list"]//a/@href', MapCompose(lambda i: urlparse.urljoin(response.url, i))) 30 # 添加管理字段 31 l.add_value('url', response.url) 32 l.add_value('project', self.settings.get('BOT_NAME')) 33 l.add_value('spider', self.name) 34 l.add_value('server', socket.gethostname()) 35 l.add_value('date', datetime.datetime.now()) 36 37 return l.load_item()
创建contract,检验代码可用性
使用scrapy check + 文件名 执行
e.g. scrapy check basic
1 def parse(self, response): 2 """This function parses a property page. 3 4 @url http://www.biquge.info/22_22559/ 5 @returns items 1 6 @scrapes title author classify recommend chapter_urls 7 @scrapes url project spider server date 8 """ 9 # 定义装载器 10 l = ItemLoader(item=CrawlNovelItem(), response=response) 11 ……