Scrapy框架原理与使用流程

一.Scrapy框架特点

  • 框架(Framework)是一种软件设计方法,它提供了一套预先定义的组件和约定,帮助开发者快速构建应用程序。框架通常包括一组库、工具和约定,它们共同工作以简化开发过程。
  • scrapy框架是python写的 为了爬取网站数据 提取结构化数据的爬虫框架
  • 相当于人家已经给我们写好了功能,提供好了方法,我们直接拿过来用就可以完成对应v 
  • 特点: 

1.异步处理提高爬取效率

(1)异步处理的基本原理

异步处理允许程序在等待某些操作完成时继续执行其他任务,从而避免了CPU资源的浪费,这种非阻塞的工作模式显著提高了数据处理的效率和吞吐量。

(2)异步处理在爬虫中的应用

在网络爬虫中应用异步处理,可以同时处理多个请求,减少了等待服务器响应的时间,通过并发爬取,大幅提高了数据抓取的速度和效率。

(3)异步处理的优势与挑战

异步处理通过提高资源利用率和响应速度来提升爬取效率,但同时也带来了编程模型的复杂性,需要合理管理并发任务和资源,以避免潜在的性能瓶颈和错误。 

2.中间件系统扩展功能

(1)下载器中间件功能

下载器中间件通过自定义扩展,实现对下载过程的深度定制,如添加请求头信息、处理响应数据等,极大增强了Scrapy框架的灵活性和功能性。

(2)爬虫中间件作用

爬虫中间件在引擎与爬虫间架起桥梁,允许用户插入自定义代码来操作请求和响应,从而实现对爬虫流程的精细控制,提升数据处理的能力和效率。

(3)中间件系统的功能拓展

通过中间件系统,Scrapy能够实现包括网络通讯处理、下载加速、异步框架支持等功能,这些功能拓展了Scrapy的应用范围,满足了更多样化的爬虫开发需求。

3.数据管道处理存储数据

(1)定义Item类

在数据管道处理的第一步中,我们定义一个继承自`scrapy.Item`的类,这个类通过使用`scrapy.Field()`定义字段,来存储我们需要爬取的数据。

(2)编写Pipeline类

接下来,我们创建一个Pipeline类,实现`open_spider`和`process_item`两个关键方法,用于在爬虫开始时初始化资源,并在每个item被爬取后进行处理,如写入文件或数据库。

(3)数据处理与存储

在`process_item`方法中,我们可以编写逻辑来具体处理每一个item,例如将其写入文件或存入数据库。根据这个方法是否返回item对象,决定item是否继续传递到下一个Pipeline。

4.内置选择器提取数据

(1)XPath选择器提取数据

XPath选择器通过XPath表达式定位网页元素,能够精确地从复杂的HTML结构中提取出所需的数据,如使用特定路径表达式提取具有特定属性的元素文本。

(2)CSS选择器提取数据

CSS选择器利用简洁的语法通过元素的类名、ID或属性等来定位网页中的特定元素,使得数据提取过程更为直接和高效,适用于快速提取样式定义的元素内容。

(3)正则表达式匹配数据

正则表达式提供强大的字符串匹配能力,通过定义特定的模式来匹配和提取字符串中的复杂数据,是处理非结构化文本数据时不可或缺的工具,尤其适用于从文本中提取符合特定格式的信息。

5.支持分布式爬虫任务

(1)Redis作为共享队列

在Scrapy分布式爬虫中,Redis充当核心的共享队列和数据存储角色,允许不同爬虫实例通过它共享待爬取的URL和已抓取的数据,实现信息同步。

(2)调度器的角色

调度器在Scrapy框架中负责管理和分配待爬取的URLs。在分布式设置下,通过Redis实现的调度器确保多个爬虫实例能高效地获取并处理URLs。

(3)并行下载与数据处理

Scrapy分布式爬虫利用各自的下载器进行并行下载,以及多个Spider实例同时运行来处理网页,提高了下载效率和数据处理速度,Item Pipeline则负责后续的数据存储或处理工作。

二.Scrapy使用流程

1.开发步骤

(1)项目创建 创建项目:scrapy startproject xxx(项目名字,不区分大小写)!!!(在终端输入open in Explore)

(2)明确目标 (编写items.py):明确你想要抓取的目标,其实就是先确定一下你要爬取什么字段的数据

(3)制作爬虫 制作爬虫 (spiders/xxspider.py):制作爬虫开始爬取网页

(4)存储内容 存储内容 (pipelines.py):设计管道存储爬取内容取网页

实际中不必要按照顺序去遵守 自己写代码想咋写就咋写 实现功能为主

2.项目文件解释

spiders    爬虫目录

items    设置数据存储的模板

middlewares    中间件文件

pipelines    管道文件 数据持久化

settings    配置文件

3.项目创建与使用

创建项目 scrapy startproject xxx(项目名)

进入项目 cd xxx(项目名)。

创建爬虫 scrapy genspider  爬虫名 要爬取网站的域名

运行爬虫 scrapy crawl 爬虫名

4.爬虫文件

  • 创建爬虫文件默认生成一个类,里面三个属性一个方法

(1)三个属性

name = "" :这个爬虫的识别名称,必须是唯一的,在不同的爬虫必须定义不同的名字 `allow_domains = []` 是搜索的域名范围,也就是爬虫的约束区域,规定爬虫只爬取这个域名下的网页,不存在的URL会被忽略 `start_urls = [] :爬取的URL列表。爬虫从这里开始抓取数据,所以,第一次下载的数据将会从这些urls开始。其他子URL将会从这些起始URL中继承性生成。

(2)一个方法

`parse(self, response)` :解析的方法,每个初始URL完成下载后将被调用,调用的时候传入请求url的Response对象来作为唯一参数,主要作用如下: 1. 负责解析返回的网页数据(response.body),提取结构化数据(生成item) 2. 生成需要下一页的URL请求。

5.配置Settings设置

(1)修改settings.py文件

`settings.py`位于Scrapy项目的根目录,是项目配置的核心。通过修改该文件,可以调整日志级别、用户代理等关键设置,以适应不同的爬虫需求。

(2)常见设置项

Scrapy中的常见设置项包括LOG_LEVEL用于调整日志输出级别,ROBOTSTXT_OBEY决定是否遵守robots协议,以及USER_AGENT用于设置爬虫的用户代理字符串,帮助爬虫更好地伪装身份。

(3)日志等级

严重错误    critical

一般错误    error

警告 warning

一般信息 info

调试信息    debug

默认的日志等级是debug LOG_LEVEL = 'ERROR' 修改日志的输出

6.Scrapy框架组成部分!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!

(1)调度器

作用: 它负责接受引擎发送过来的Request请求,并按照一定的方式进行整理排列,入队,当引擎需要时,交还给引擎。

(2)引擎

作用:负责与其他部分的交流通讯

(3)下载器

作用:负责下载引擎发送的所有Requests请求,并将其获取到的Responses交还给引擎,由引擎交给Spider来处理

(4)爬虫

作用:它负责处理所有Responses,从中分析提取数据,获取Item字段需要的数据,并将需要跟进的URL提交给引擎,再次进入调度器

(5)管道

作用: 它负责处理Spider中获取到的Item,并进行进行后期处理(详细分析、过滤、存储等)的地方.

  7.Scrapy的运作流程

(1)8.. ``引擎``询问`Spider`, 需要爬取的网站是谁?

(2). `Spider`:告诉`引擎`目标url是谁。并且给到`引擎`

(3). `引擎`:Hi!`调度器`,我这有request请求你帮我排序入队一下。

(4). `调度器`:好的,对这个请求做对应的处理,比如排序入队,。

(5). `调度器`:排序入队完了以后把处理好的request给`引擎`

(6). `引擎`:找到 `下载器 `,你按照`下载中间件`的设置帮我下载一下这个request请求

(7). `下载器`:好的!把下载好的东西发给 ` 引擎`。(如果这个request下载失败了。然后`引擎`告诉`调度器`,这个request下载失败了,你记录一下,我们待会儿再下载)

(8). `引擎`:把下载好的内容给到 ` Spider`(注意!这儿responses默认是交给`def parse()`这个函数处理的)

(9). `Spider`:处理完毕有两个结果,一:我需要跟进的URL,二:需要保存的Item数据 如果为结果一就重复第2到最后的步骤,如果为结果二, ` Spider`把item数据发给 ` 引擎`,由 ` 引擎`给 ` 管道`进行持久化存储     重复这个步骤 直到爬虫运行完毕 注意:只有当`调度器`没有request需要处理时,整个程序才会停止。(对于下载失败的URL,Scrapy也会重新下载。)

8.数据管道处理存储数据 

(1)定义Item类

`scrapy.Item`,这个类通过使用`scrapy.Field()`定义字段,来存储我们需要爬取的数据。我们需要存几个字段的数据就定义几个字段的值, 字段名= scrapy.Field()

(2).爬虫使用

from ..items import item类名 变量名  =类名() # 实例化 变量名[字段名]=字段值 yield item # 通过yield 把数据发给管道

(3).编写Pipeline类

`process_item`这个方法里面写数据保存的代码。如文件保存到本地的代码,里面的return可以把数据传给下一个管道,管道可以定义多个,不同的管道做不同的数据保存操作,如一个管道存MySQL一个管道写代码把数据存本地,也可以一个管道即存MySQL又存本地

(4). 配置文件解开注释

 配置文件解开管道的注释 其中key的值是管道类名的路径,值是权重值,权重值越小 优先级越高,范围是0-1000会按照权重大小依次执行,先到第一个权重高的管道 执行 process_item方法 保存到本地 如果没有return出去  没有返回 那么就会阻塞在当前管道

 ## Scrapy的运作流程
# 
# 代码写好,程序开始运行...
# 
# 1. ``引擎``:Hi!`Spider`, 你要处理哪一个网站?
# 
# 2. `Spider`:老大要我处理xxxx.com。
# 
# 3. `引擎`:你把第一个需要处理的URL给我吧。
# 4. `Spider`:给你,第一个URL是xxxxxxx.com。
# 
# 5. `引擎`:Hi!`调度器`,我这有request请求你帮我排序入队一下。
# 6. `调度器`:好的,正在处理你等一下。
# 
# 7. `引擎`:Hi!`调度器`,把你处理好的request请求给我。
# 8. `调度器`:给你,这是我处理好的request
# 
# 9. `引擎`:Hi!下载器,你按照老大的`下载中间件`的设置帮我下载一下这个request请求
# 
# 10. `下载器`:好的!给你,这是下载好的东西。(如果失败:sorry,这个request下载失败了。然后`引擎`告诉`调度器`,这个request下载失败了,你记录一下,我们待会儿再下载)
# 
# 11. `引擎`:Hi!`Spider`,这是下载好的东西,并且已经按照老大的`下载中间件`处理过了,你自己处理一下(注意!这儿responses默认是交给`def parse()`这个函数处理的)
# 
# 12. `Spider`:(处理完毕数据之后对于需要跟进的URL),Hi!`引擎`,我这里有两个结果,这个是我需要跟进的URL,还有这个是我获取到的Item数据。
# 
# 13. `引擎`:Hi !`管道` 我这儿有个item你帮我处理一下!`调度器`!这是需要跟进URL你帮我处理下。然后从第四步开始循环,直到获取完老大需要全部信息。
# 
# 14. `管道``调度器`:好的,现在就做!
# 
# ***注意:只有当`调度器`没有request需要处理时,整个程序才会停止。(对于下载失败的URL,Scrapy也会重新下载。)***

9.scrapy 常见报错


报错1: AttributeError: 'AsyncioSelectorReactor' object has no attribute '_handleSignals '
原因:Twisted版本23会有不兼容的情况 
解决:卸载Twisted 安装Twisted21或者22就行 可以换成 22.10.0版本 
pip uninstall  Twisted   pip install Twisted==22.10.0

报错2:ImagesPipeline 接收不到数据 其他管道能接收
原因:缺少环境  ImagesPipeline 依赖 pillow
解决:pip install pillow
报错3:  TypeError: ExecutionEngine.crawl() got an unexpected keyword argument ‘spider‘
原因:运行分布式出现这个问题 是scrapy-redis比较老 用了新版本scrapy以后不兼容
解决:安装老版本的scrapy  经测试 2.9.0和之前的适配

selenium常见报错
报错1:ValueError:Tineout valve connect was object object at 0x00002354CDD7F80>,but it must be an int,float op None,
原因:selenium与urllib3不兼容 
解决:卸载urllib3 安装老版本 比如1.26.2就可以解决  pip uninstall  urllib3 再  pip install urllib3==1.26.2

报错2:ModuleNotFoundError: No module named 'urllib3.packages.six.moves'
原因:这个报错通常出现在环境为   selenium3.141+urllib1.26+python3.12的电脑上  因为python3.12太新了不能用selenium3.141
解决:方法1:selenium更新到4 urllib更新到最新 就可以解决了
           方法2:selenium降低到3.3.1就行 pip uninstall  selenium再  pip install selenium==3.3.1


注意:只是例举出了环境方面的报错 其他使用途中的报错大概率是代码编写问题  后续可能更新常见代码报错问题(存在最后报错相同 代码不同的情况 只能编写 报错原因和解决思路 )

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/902857.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

为什么有0.35/Tr这一信号带宽定义

从频域幅值函数可以近似认为这是一个低通滤波器模型,可以采用RC网络模型来处理,根据电路理论计算电压10%到90%所需上升时间,再根据滤波器频域特性计算幅值在-3db处的频率极限,通过两个关系式可以计算出频率极大值和上升时间关系&a…

<<机器学习实战>>15-26节笔记:逻辑回归参数估计、梯度下降及优化、模型评价指标

梯度下降缺点:有可能有鞍点(如果不是凸函数的时候),不一定能找到最小值解决方法:随机梯度下降(选一条数据)和小批量梯度下降(选几条数据这两个解决方法又会带来新问题,比…

51单片机完全学习——LCD1602液晶显示屏

一、数据手册解读 通过看数据手册我们需要知道,这个屏幕每个引脚的定义以及如何进行发送和接收。通过下面这张图我们就可以知道,这些引脚和我们的编程是有关的,需要注意的是,这里我们在接线的时候,一定要把DB0-DB7接到…

变流升压一体机:能源领域的新兴力量与优秀品牌

在当今能源转型的大背景下,变流升压一体机作为一种创新型的电力设备,正逐渐成为新能源领域的关键角色。 变流升压一体机是一种综合性很强的光伏箱式变电站设备,它将储能变流器、升压变压器、高压环网柜、低压配电箱等多种设备集成在一个集装箱…

LeetCode.冗余连接(并查集以及广度优先搜索)

684.冗余连接| 传送门:. - 力扣(LeetCode) 树可以看成是一个连通且 无环 的 无向 图。 给定往一棵 n 个节点 (节点值 1~n) 的树中添加一条边后的图。添加的边的两个顶点包含在 1 到 n 中间,且这条附加的边不属于树中…

上线 24 小时,爆了!

产研团队(兼客服)已爆单🔥🚀💥!(bushi) 在此由衷感谢各位小伙伴的信任🤩! 还没有试用的小伙伴赶紧去围观👇️👇️👇️ …

高效数据集成案例:从聚水潭·奇门到MySQL

聚水潭奇门数据集成到MySQL的技术案例分享 在企业信息化建设中,数据集成是实现业务流程自动化和数据统一管理的关键环节。本文将分享一个具体的系统对接集成案例:如何将聚水潭奇门平台上的销售出库单数据高效、可靠地集成到MySQL数据库中,以…

AUTOSAR-Com模块

COM 文章目录 COMCOM 基础介绍COM主要功能AUTOSAR COM 模块 发送模型Signal 信号/信号组发送信号属性—Triggered属性Pending属性信号的初始化信号的对齐方式(大小端)信号的收发发送接收 字节序转换和符号扩展信号的过滤机制过滤处理信号传输模式信号流和…

【十进制转十六进制数】

【十进制转十六进制数】 C语言版本C 版本Java版本Python版本 💐The Begin💐点点关注,收藏不迷路💐 从键盘接收一个整数,编程实现将其转换成十六进制数。 输入 一个整数 输出 十六进制数 样例输入 100样例输出 6…

day01-ElasticStack+Kibana

ElasticStack-数据库 #官网https://www.elastic.co/cn/ #下载7.17版环境准备 主机名IP系统版本VMware版本elk110.0.0.91Ubuntu 22.04.417.5.1elk210.0.0.92Ubuntu 22.04.417.5.1elk310.0.0.93Ubuntu 22.04.417.5.1 单机部署ES 1.下载ES软件包,放到/usr/local下 […

HTML3D旋转相册

文章目录 序号目录1HTML满屏跳动的爱心(可写字)2HTML五彩缤纷的爱心3HTML满屏漂浮爱心4HTML情人节快乐

react18中react-thunk实现公共数据仓库的异步操作

redux及react-redux都只能实现数据的同步修改更新,有点类似于vue中的mutation,只能做同步操作,异步的话不用actions来实现。由于在项目始终不可避免要实现的异步数据的更新,这明显不够用了。是时候引入我们的异步中间件redux-thun…

计算机组成原理笔记9(指令系统,立即寻址,直接寻址,间接寻址.....)

指令操作码 操作码的位数决定了不同功能指令的多少,位数越多,所能表示的操作功能就越丰富。指令的操作码通常有两种编码格式: 定长操作码 定长操作码对于简化硬件设计,减少指令译码时间非常有利,例如IBM370指令系统&a…

Matlab 火焰识别技术

课题介绍 森林承担着为人类提供氧气以及回收二氧化碳等废弃气体的作用,森林保护显得尤其重要。但是每年由于火灾引起的事故不计其数,造成重大的损失。如果有一款监测软件,从硬件处获得的图像中监测是否有火焰,从而报警&#xff0…

uv: 一个统一的Python包管理工具

uv是由Astral公司开发的一个极其快速的Python包管理器,完全用Rust编写。它最初在2月份发布,作为pip工作流的替代品。现在,uv已经扩展成为一个端到端的解决方案,可以管理Python项目、命令行工具、单文件脚本,甚至Python本身。可以说,uv就像是Python界的Cargo:一个快速、可靠、易…

XQT_UI 组件|03 |加载组件 XQtLoading

XQtLoading 使用文档 简介 XQtLoading 是一个自定义的加载动画组件,旨在为用户提供可配置的旋转花瓣动画效果。它可以在应用程序中用于指示加载状态,提升用户体验。 特征 可配置性:用户可以根据需求调整旋转周期、缩放周期、最大/最小缩放…

置换环模板题E - Permute K times 2

输入样本 1 6 3 5 6 3 1 2 4样本输出 1 6 1 3 2 4 5每次操作后, P P P 都会发生如下变化: 第一次操作后, P P P 为 ( 2 , 4 , 3 , 5 , 6 , 1 ) (2,4,3,5,6,1) (2,4,3,5,6,1) 。第二次操作后, P P P 为 ( 4 , 5 , 3 , 6 , …

溪源飨提高免疫力治未病:硒+辅酶Q10强力组合

上周我和女友在亲友的见证下举行了庄重的订婚仪式。我和女友是经朋友介绍才认识的,认识时间并不算长。第一次见面,彼此就被对方深深地吸引了,真可谓一见钟情。我喜欢她那恬静的美,难以忘怀她那散发着迷人气息的双眸;她…

CMakeLists.txt 编写规则

目录 1. 注释 1.1 注释行 1.2 注释块 2. CMakeLists.txt的编写 2.1 同意目录下的源文件 2.2 SET指令 2.3 file和aux_source_directory 2.4 包含头文件 2.5 生成动态库和静态库 2.6 链接库文件 2.7 message指令 2.8 移除操作 2.9 find_library和find_package 3. 常…

【瑞吉外卖】-day01

目录 前言 第一天项目启动 获取资料 创建项目 ​编辑 连接本地数据库 连接数据库 修改用户名和密码 ​编辑创建表 创建启动类来进行测试 导入前端页面 创建项目所需目录 检查登录功能 登录界面 登录成功 登录失败 代码 退出功能 易错点 前言 尝试一下企业级项…