Scrapy框架中如何实现增量式爬取数据_通过Redis指纹判重避免重复采集
Scrapy默认RFPDupeFilter不支持增量爬取,因其指纹仅内存存储、不可持久化且无法跨进程共享;需替换为scrapy-redis的RFPDupeFilter并配置Redis连接、调度器及命名空间隔离。
为什么默认的 DUPEFILTER_CLASS 不适合增量爬取
Scrapy 默认用 RFPDupeFilter(基于请求指纹的内存去重),但它的指纹只在单次运行生命周期内有效,进程一结束,所有已访问 URL 的指纹就丢了。下次启动爬虫,它完全“失忆”,照样重复请求——这和增量爬取“记住上次状态”的核心目标直接冲突。
更关键的是,这个默认类不支持跨进程、跨机器共享,分布式部署时各 worker 各自维护一套指纹,互相之间毫无感知,去重形同虚设。
- 指纹生成逻辑依赖
scrapy.utils.request.request_fingerprint(),默认包含 method、url、body、headers 等,但不自动带时间戳或版本标识 - 内存存储(
set())无法持久化,重启即清空 - 不提供外部查询接口,你没法主动检查某个 URL 是否已被处理过
用 scrapy-redis 替换去重器的实操要点
真正起作用的是 scrapy_redis.dupefilter.RFPDupeFilter,它把指纹存进 Redis 的 set 结构里,实现持久化 + 共享。但光改配置还不够,容易踩几个坑:
- 必须确保
REDIS_URL可写且连接稳定,否则爬虫会静默跳过去重,退化为全量模式 -
SCHEDULER也得配成scrapy_redis.scheduler.Scheduler,否则 request 队列还是走内存,Redis 里的指纹没人查 - 如果用了
CrawlSpider和LinkExtractor,要确认提取出的 URL 是标准化后的(比如去掉末尾斜杠、统一协议),否则https://a.com/和https://a.com会被当成两个指纹 - Redis 中的指纹 key 默认是
dupefilter:,多个 spider 共用一个 Redis 实例时,别忘了加 namespace 隔离
指纹内容可定制:URL 去重 vs 内容去重
单纯靠 URL 去重(即默认指纹行为)只防“重复请求”,防不了“页面内容更新”。比如新闻详情页 URL 不变,但正文改了,你还是拿不到新内容。
这时候就得干预指纹生成逻辑。常见做法是在 spider 的 start_requests() 或 make_requests_from_url() 中,给 request 加上自定义 meta,再配合重写 request_fingerprint 函数(需继承并替换 dupefilter 类),把关键字段如 last_modified 或 etag 拼进指纹。
更轻量的做法是:在 pipeline 里用内容哈希二次过滤。例如:
Red Panda AI
AI文本生成图像
import hashlib
def process_item(self, item, spider):
content = f"{item.get('title', '')}{item.get('content', '')}".encode()
sig = hashlib.md5(content).hexdigest()
if self.redis.sismember("item_sig_set", sig):
raise DropItem(f"Duplicate content: {sig[:8]}")
self.redis.sadd("item_sig_set", sig)
return item
注意:这里用的是内容哈希,不是 URL 指纹,二者目的不同,可以共存。
Redis 数据清理与冷热分离的实际考量
指纹集合不会自动过期,长期运行后可能膨胀到几 GB。你不能简单地定期 FLUSHDB,否则就又变全量爬了。
可行策略是按业务周期切片管理:
- 对新闻类站点,按日期建 key,如
dupefilter:news:202605,每月初新建,旧 key 归档或 TTL 设置为 90 天 - 对商品页,用分类 ID + 时间戳组合 key,比如
dupefilter:goods:electronics:20260509,便于按类回收 - 慎用
SCRAPEY_REDIS_START_URLS_KEY自动加载 start_urls——如果 Redis 里残留了失效链接(如 404 页面),爬虫会卡住,建议搭配健康检查脚本预清理
真正难的不是存指纹,而是判断哪些指纹该留、哪些该删。没有通用规则,得看你的数据更新节奏和业务容忍度:新闻要小时级新鲜度,小说章节可能只需天级,而企业黄页半年不变一次也正常。
如非特殊说明,本站内容均来自于网友自主分享,如有任何问题均请联系我们进行处理!
猜您喜欢
Agent 编排艺术:MiMo Code 如何实现复杂的开发任务拆解
2026-06-28MiMoCode通过Compose模式构建结构化任务图谱,由分工明确的子Agent协同执行,支持MaxMode多方案自评与DynamicWorkflow可编程编排,提升长程任务稳定性与一次性通过率。 ☞☞☞AI智能聊天,问答助手,AI智能搜索,多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜ MiMoCode不靠单一大模型硬扛复杂任务,而是把开发过程当作可调度、可验证的工程流水线来处理。它用Age...
如何修复Python aiohttp请求时出现的ClientPayloadError?
2026-06-04ClientPayloadError表明服务端提前关闭连接,非客户端代码错误;常见于服务端超时、拒绝大响应或代理截断,需通过抓包、检查响应头、服务端日志及添加读取超时和异常处理来定位解决。 ClientPayloadError通常意味着服务端提前关闭了连接 这个错误不是客户端代码写错了,而是aiohttp在读取响应体时发现服务端已经断开了连接。常见于服务端超时、主动拒绝大响应、或代理/网关(如Ng...
如何使用Python监控服务器CPU温度并邮件告警_通过psutil模块读取系统信息
2026-06-04psutil无法直接读取CPU温度,因其依赖系统硬件接口且Linux需lm_sensors支持、Windows/macOS完全不支持;可靠方式是用subprocess调用sensors命令解析输出,并配合邮件告警与健壮性设计。 psutil本身不提供CPU温度读取功能——它无法直接获取温度传感器数据,强行调用psutil.sensors_temperatures()在多数Linux发行版(尤其是无...
如何在Python中验证文件的MD5校验和以确保数据完整性?
2026-06-04必须分块读取,推荐8192或65536字节块大小,以rb模式打开文件,循环调用update(),最后用hexdigest()获取32位小写十六进制字符串;校验时需strip().lower()统一格式并做长度校验。 用hashlib.md5()读取文件并计算校验和 直接调用hashlib.md5()并传入整个文件内容(比如md5.update(f.read()))在大文件上会爆内存。必须分块读取,...
怎样在Python Tkinter中使用线程池处理高并发的GUI数据更新?
2026-06-04不能直接用ThreadPoolExecutor更新Tkinter控件,因为Tkinter的Tcl解释器只允许主线程操作UI;子线程(包括线程池中的工作线程)调用widget方法会引发TclError或卡死;必须通过queue.Queue+root.after()将结果安全传回主线程更新。 为什么不能直接用concurrent.futures.ThreadPoolExecutor更新Tkinter控...
如何在Python 3中正确判断一个对象是否为某个类的实例?
2026-06-04应优先使用isinstance()而非type()做类型判断,因isinstance()遵循MRO、支持继承与ABC,体现鸭子类型哲学;type()仅判别直接类型,适用极少数需严格身份校验的场景。 用isinstance()而不是type() 直接比较type(obj)==SomeClass在绝大多数场景下是错的——它无法识别子类实例。比如isinstance(42,int)返回True,但typ...
为什么Python Django默认使用PBKDF2算法进行密码哈希?
2026-06-04Django默认使用PBKDF2而非Argon2或bcrypt,因其零依赖、NIST合规、迭代与salt可扩展,且默认26万次迭代兼顾安全与性能;make_password和check_password均动态读取PASSWORD_HASHERS[0],支持渐进式算法迁移。 PBKDF2是Django默认密码哈希算法,因为它在安全性、兼容性与可配置性之间取得了最务实的平衡。 为什么不是更“新”的Ar...
如何在Python中自定义NumPy的打印格式以方便调试?
2026-06-04np.set_printoptions()可直接控制NumPy数组显示格式;默认格式因小数位不一致、科学计数法混用及自动截断而影响调试效率;关键参数需协同设置,如precision控制有效位数、suppress禁用科学计数法、threshold避免省略、linewidth防换行混乱、floatmode='fixed'统一小数位;调试时应按目标切换组合,并注意全局生效与及时还原。 直接用np.set...
如何使用Python自动化同步GitLab与GitHub代码_利用Subprocess调用指令
2026-06-04直接用subprocess调用git命令同步GitLab和GitHub是轻量、可控、不依赖第三方库的可靠方案,核心三步:裸克隆→添加远程→gitpush--mirror,支持全分支、标签及完整历史同步,且避免API封装带来的繁琐遍历与权限管理。 直接用subprocess调用git命令同步GitLab和GitHub,是轻量、可控、不依赖第三方库的可靠方案。它绕开了API权限配置、token管理和网...
如何创建一个每天定时向 Telegram 群组发送消息的独立机器人
2026-06-04telegram机器人本身不具备“自动唤醒”或“离线执行”能力,必须持续运行在一台24/7在线的服务器上;本地电脑关机即停止发送,需借助云平台(如pythonanywhere、heroku或vps)实现真正的每日定时推送。 telegram机器人本身不具备“自动唤醒”或“离线执行”能力,必须持续运行在一台24/7在线的服务器上;本地电脑关机即停止发送,需借助云平台(如pythonanywhere、...
