Scrapy 分布式爬虫框架 Scrapy-Redis

server/2024/10/20 1:20:17/

github官网代码示例:https://github.com/rmax/scrapy-redis/blob/master/example-project/example/spiders/myspider_redis.py

什么是 Scrapy-Redis

Scrapy-Redis 是一个基于 Scrapy 的扩展,用于实现分布式爬虫。它利用 Redis 作为分布式队列来共享待爬取的 URL 和去重数据,这样可以让多个爬虫实例(即多个爬虫节点)并行工作,从而实现大规模的分布式数据抓取。

把普通爬虫改造成分布式爬虫

使用普通爬虫,改造成分布式爬虫,更便于理解

1. 安装 scrapy_redis框架模块

pip install scrapy_redis

2. 爬虫类修改如下:

import scrapy
# --- 1. 导入分布式爬虫类
from scrapy_redis.spiders import RedisSpider# --- 2. 继承分布式爬虫类
class BaiduSpider(RedisSpider):name = "baidu"# --- 3. 注释原来普通爬虫的 allowed_domains,start_urls# allowed_domains = ["baidu.com"]# start_urls = ["https://www.baidu.com"]# --- 4. 设置redis的key,起始url就存在这个key里redis_key = "baidu"# --- 5. 设置 __init__,固定写法如下def __init__(self, *args, **kwargs):domain = kwargs.pop('domain', '')self.allowed_domains = list(filter(None, domain.split(',')))  # 获取启动爬虫命令时输入的域名super().__init__(*args, **kwargs)def parse(self, response):print("解析数据:", response.xpath('//title/text()').get())

3. 配置 settings.py 文件

# myproject2 是项目名称
SPIDER_MODULES = ["myproject2.spiders"]
NEWSPIDER_MODULE = "myproject2.spiders"# USER_AGENT = "scrapy-redis (+https://github.com/rolando/scrapy-redis)"
USER_AGENT = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.0.0 Safari/537.36"# 重复过滤器使用的模块
DUPEFILTER_CLASS = "scrapy_redis.dupefilter.RFPDupeFilter"
# 设置调度器,scrapy_redis中的调度器具备与数据库交互的功能
SCHEDULER = "scrapy_redis.scheduler.Scheduler"
# 保持任务队列,当程序结束时不清空 Redis 中的队列
SCHEDULER_PERSIST = True# 设置任务队列使用的类型,可选的类型有:
# SCHEDULER_QUEUE_CLASS = "scrapy_redis.queue.SpiderPriorityQueue"  # 基于优先级的队列
# SCHEDULER_QUEUE_CLASS = "scrapy_redis.queue.SpiderQueue"          # 基于 FIFO 的队列
# SCHEDULER_QUEUE_CLASS = "scrapy_redis.queue.SpiderStack"          # 基于 LIFO 的队列ITEM_PIPELINES = {# "myproject2.pipelines.ExamplePipeline": 300,"scrapy_redis.pipelines.RedisPipeline": 400,
}# 配置 redis 连接信息
REDIS_HOST = "localhost"
REDIS_PORT = 6379
# REDIS_DB = 0
# REDIS_PASSWORD = "123456"LOG_LEVEL = "DEBUG"# Introduce an artifical delay to make use of parallelism. to speed up the
# crawl.
# 延迟时间,单位秒
DOWNLOAD_DELAY = 1

4. 启动分布式爬虫

爬虫类所在目录打开多个命令行窗口,使用如下命令启动爬虫

# scrapy runspider 爬虫scrapy runspider baidu.py

如下:表示启动了多个程序,一起用于对这个爬虫进行爬取

5. 向redis中添加爬取的url

向redis中添加爬取的url,启动的爬虫会从redis中读取url进行爬取

# lpush key value1 value2 value3
lpush baidu "https://www.baidu.com"

6. 效果

向 redis 中存入多个url后,可以看到有多个窗口同时爬取不同url的数据

lpush baidu "https://www.baidu.com" "https://tieba.baidu.com/f?kw=沙井"

实际使用场景

当一个网站的数据特别多的时候,有很多分页,或者下拉分页。通过对分页比较找出分页规则,通过分页规则计算拿到所有的分页地址。把所有的分页地址存到 redis 中


http://www.ppmy.cn/server/107056.html

相关文章

第六章 rust中的错误处理

本系列文章已升级、转移至我的自建站点中,本章原文为:rust中的错误处理 目录 一、前言二、不同之处三、枚举处理错误四、泛型五、标准错误处理1.Result2.Option六、panic、传递错误七、常见用法八、为Enum绑定方法一、前言 本章将要介绍的是Rust中的错误处理方式,这是一个与…

使用ElementUI + Vue框架实现学生管理系统前端页面设计

目录 一.什么是ElementUI? 二.使用ElementUI和Vue-cli搭建前端页面 三.具体步骤 1.创建vue-cli项目 2.分析 3.创建组件 四.总结 一.什么是ElementUI? ElementUI是一种网站快速成型工具,一套为开发者,设计师准备的基于Vue2.…

HTML中渲染空格和换行符样式的实现方式

在HTML中&#xff0c;连续的空格和换行符会被合并为一个空格&#xff0c;所以无法直接通过添加换行符来实现缩进效果。如果您希望在HTML中显示缩进的效果&#xff0c;可以使用CSS样式中的white-space: pre属性。 以下是使用<pre>标签和CSS样式实现缩进效果的示例&#x…

【Qt】容器类控件GroupBox

容器类控件GroupBox 使用QGroupBox实现一个带有标题的分组框&#xff0c;可以把其他的控件放在里面里面作为一组&#xff0c;这些内部的控件的父元素也就不是this了。 其目的只是为了让界面看起来更加好看&#xff0c;例如当一个界面比较复杂的时候&#xff0c;包含了很多的控…

QT Quick QML 实例之定制 TableView

QT Quick QML 实例之定制 TableView 一、演示二、C关键步骤1. beginInsertRows()&#xff08;用户插入行&#xff09;2. roleNames() &#xff08;表格中列映射&#xff09;3. data() &#xff08;用户获取数据&#xff09;4. headerData() &#xff08;表头&#xff09;5. fla…

WPF 界面缓存优化

在 WPF 中&#xff0c;如果你希望避免界面的频繁创建和销毁&#xff0c;可以通过以下几种方法来实现界面缓存&#xff1a; 1. 使用 NavigationService 缓存页面 在使用 WPF 的导航框架时&#xff0c;可以通过 NavigationService 实现页面的缓存。WPF 提供了 KeepAlive 属性&a…

第五章-OpenMV4 色块识别的图形圆形 正方形识别、 黑色红色识别颜色、坐标识别

项目比赛中需要识别黑色圆形和黄色方形状 要是识别的圆形 openmv代码如下代码带了阈值如何更改阈值 可以使用下面方法 这里是循迹 把循迹线调节成白色就是颜色追踪阈值 把线 调整成 import sensor, image, timesensor.reset() # 重置图像传感器 sensor.set_pixformat…

Redis复制

目录 9.1 介绍9.2 作用(功能)&#xff1a;9.3 基本操作**配置一个master&#xff0c;两个slave**常用三招常见问题 9.4 主从复制的工作原理9.5 主从复制的缺点 9.1 介绍 主从复制 master以写为主&#xff0c;slave以读为主当master数据变化时&#xff0c;自动将新的数据异步同…