目录
2. 安装依赖包:pip install pypiwin32
- pip/pip3 install scrapy (换源安装命令:pip install scrapy -i Simple Index --trusted-host pypi.douban.comn )
-
- 如果不安装,以后的项目会报错
- window系统需要安装,Linux,Mac不需要
scrapy startproject mySpider
scrapy genspider lianjia lianjia.com
根据网站结构在spider中实现数据采集相关内容
使用pipeline进行数据后续处理和保存
通过命令将scrapy项目的的文件生成出来,后续步骤都是在项目文件中进行相关操作,下面以抓取链家来学习scrapy的入门使用
创建scrapy项目的命令:
scrapy startproject <项目名字>
示例:
scrapy startproject myspider
生成的目录和文件结果如下:
通过命令创建出爬虫文件,爬虫文件为主要的代码文件,通常一个网站的爬取动作都会在爬虫文件中进行编写。
命令:
在项目路径下执行:
scrapy genspider <爬虫名字> <允许爬取的域名>
爬虫名字: 作为爬虫运行时的参数
允许爬取的域名: 为对于爬虫设置的爬取范围,设置之后用于过滤要爬取的url,如果爬取的url与允许的域不通则被过滤掉。
示例:
- cd myspider # 这一步是进入当前项目路径
-
- scrapy genspider lianjia lianjia.com # 再创建爬虫文件
以上操作完成后再打开pycharm就可以清楚查看到项目层级结构
现对如下几个py文件做说明:
1.scrapy.cfg 详细项目配置文件, 不需要做改动
2.items.py 定义数据存储模型
3.middlewares.py 用于编写中间件(下载中间件+爬虫中间件) -- 无特殊需求,一般不需要编写
4.lianjia.py (爬虫文件,文件名称自己定义) [后面再来完善该爬虫模块]
5.pipelines.py 管道 -- 主要用于编写数据处理步骤 (数据的清洗+保存)
6.settings.py 详细的配置信息(设置文件UA 并启动管道)
在上一步生成出来的爬虫文件中编写指定网站的数据采集操作,实现数据提取
5.1 在/myspider/myspider/spiders/itcast.py中修改内容如下:
- import scrapy
- from mySpider.items import MyspiderItem
-
- class LianjiaSpider(scrapy.Spider):
- # 爬虫名字
- name = 'lianjia'
- # 限定爬取的域名范围
- allowed_domains = ['cs.lianjia.com']
- # 起始请求的URL
- start_urls = ['https://cs.lianjia.com/zufang/']
-
- # 该方法会接受下载中间件传过来的response,并对其进行解析
- def parse(self, response):
- # print("响应对象:",response) # response是一个响应对象
- # html_data = response.body # 获取网页源码
- # print("源码信息:", html_data)
- # # 将获取回来的网页源码保存为本地html文件,方便做分析
- # with open('lj.html','wb')as f:
- # f.write(html_data)
- # 正式解析想要的数据
- # 会返回一个为列表的Selector选择器对象
- # 将列表遍历成字符串再通过.extract()取选择器里的所有值,.extract_first()取出选择器里的第一个值
- name = response.xpath(
- '//div[@class="content__list--item--main"]//p[@class="content__list--item--title"]/a/text()').extract()
- price = response.xpath('//div[@class="content__list--item--main"]//em/text()').extract()
- link = response.xpath('//div[@class="content__list--item--main"]//a[@class="twoline"]/@href').extract()
- for names, prices, links in zip(name, price, link):
- # 创建一个数据字典
- # item = {}
- # 调用items模板类
- item = MyspiderItem() #实例化之后可以直接使用 目前是一个空字典
- # 给实例之后的空字典组建数据 要注意得与items文件中定义的变量一致
- item["name"] = names.strip()
- item["price"] = prices
- item["link"] = "https://cs.lianjia.com/" + links
- # print(names.strip())
- # print(prices)
- # print("https://cs.lianjia.com/"+links)
- # print('=='*10)
- # print(item)
-
- # 将组建好的dict形式数据通过yield返回给引擎 再交给管道文件Pipeline
- yield item
注意:
解析并获取scrapy爬虫中的数据: 利用xpath规则字符串进行定位和提取
利用管道pipeline来处理(保存)数据
- # Define your item pipelines here
- #
- # Don't forget to add your pipeline to the ITEM_PIPELINES setting
- # See: https://docs.scrapy.org/en/latest/topics/item-pipeline.html
-
- # useful for handling different item types with a single interface
- import json
-
- from itemadapter import ItemAdapter
-
- class MyspiderPipeline:
- def __init__(self):
- self.file = open('lianjia.json','w')
-
- # 爬虫文件中提取数据的方法每yield一次item,就会运行一次
- # 该方法为固定名称函数
- def process_item(self, item, spider):
- # 参数item默认是一个
类信息,需要处理成字典 - dict_data = dict(item)
- print(type(item), type(dict_data))
- # 将返回的字典数据转为JSON数据
- json_data = json.dumps(dict_data,ensure_ascii=False)+',\n'
- # 写入JSON数据
- self.file.write(json_data)
- # 参数item:是爬虫文件中yield的返回的数据对象(引擎会把这个交给管道中的这个item参数)
- print("建模之后的返回值:",item,)
- # 默认使用完管道之后将数据又返回给引擎
- return item
-
- def __del__(self):
- self.file.close()
- # 设置目录文件 该值的大小决定管道执行的顺序,值越小优先级越高(该值最好 不要大于1000)
- ITEM_PIPELINES = {
- 'mySpider.pipelines.MyspiderPipeline': 300,
- }
以上配置项中键为使用的管道类,管道类使用.进行分割,第一个为项目目录,第二个为文件,第三个为定义的管道类。
配置项中值为管道的使用顺序,设置的数值约小越优先执行,该值一般设置为1000以内。
命令:在项目目录下执行scrapy crawl <爬虫名字>
示例:scrapy crawl 爬虫名字 --nolog 忽略日志信息
每次我们写完代码进行测试的时候,都要去安装目录执行,所以为了方便,我们要写一个再爬虫项目根目录中创建.py结尾的文件,执行以下指令:
- from scrapy import cmdline
- cmdline.execute(['scrapy','crawl','lianjia'])

我们想要爬虫中使用xpath,BS4,正则,css选择器等来提取想要的数据时,由于Scrapy是一个重量级框架,每次运行起来都要等待一段时间,因此要去验证我们书写的规则是否正确,是一个比较麻烦的事情,因此Scrapy提供了一个shell,用起来方便测试规则
打开cmd终端,进入到Scrapy项目所在目录,进入到Scrapy框架所在的环境中,输入命令:
scrapy shell url ,就会进入到scrapy的shell环境中,在这个环境中,你可以跟在爬虫的parse方法中一样使用了
对于要提取如下图中所有页面上的数据该怎么办?
回顾requests模块是如何实现翻页请求的:
scrapy实现翻页的思路:(scrapy并无单独的url这个概念,scrapy中都是需要将url打包成一个请求对象)
思路分析:
在爬虫文件的parse方法中:
- ...
- # 开始构造翻页
- # 1,提取下一页url
- all_url = response.xpath('//ul[@style="display:hidden"]//li/a/@href').extract()
- print(all_url)
- for part_url in all_url:
- # 2,判断条件
- if '/zufang/' in part_url:
- next_url = response.urljoin(part_url)
- print("下一页参数信息:", part_url)
- print("下一页链接:", next_url)
- # 构建请求对象 并且返回给引擎
- yield scrapy.Request(url=next_url,callback=self.parse)