零基础小白入门篇,网络爬虫Scrapy从入门到进阶
通过The Scrapy Tutorial(中文版)你可以在几分钟之内上手你的第一只爬虫。然后,当你需要完成一些复杂的任务时,你很可能会发现有内置好的、文档良好的方式来实现它。(Scrapy内置了许多强大的功能,但Scrapy的框架结构良好,如果你还不需要某个功能,它就不会影响你。)再者,如果你最终需要某些新功能,例如一个布隆过滤器来去重大量的链接,通常只需要简单地子类化某个组件,并做点小小的修改就可以了。
- 注:作者为了爬虫道德,在教程中使用了虚拟的目标网站Zipru,假想它为一个种子站点。自己尝试时,修改为自己的需求网址即可。
新建项目
- scrapy安装参看新手向爬虫(三)别人的爬虫在干啥
- 命令行新建名为zipru_scraper的工程目录。
scrapy startproject zipru_scraper
- 这会创建如下的目录结构:
└── zipru_scraper ├── zipru_scraper │ ├── __init__.py │ ├── items.py │ ├── middlewares.py │ ├── pipelines.py │ ├── settings.py │ └── spiders │ └── __init__.py └── scrapy.cfg
默认情况下,大多数这些文件实际上不会被使用,它们的存在只是建议我们以一个合理的方式组织我们的代码。当前,你只需要考虑zipru_scraper(第一个)作为项目的顶层目录,这就是任何scrapy命令应该运行的地方,也是任何相对路径的根。
添加一个基本爬虫
- 现在我们需要添加一个小爬虫来真正做点什么。
- 创建文件zipru_scraper/spiders/zipru_spider.py添加如下内容:
import scrapy class ZipruSpider(scrapy.Spider): name = 'zipru' start_urls = ['网页链接]
- 我们的小爬虫继承了scrapy.Spider,它内置的start_requests()方法会自动遍历start_urls列表中的链接来开始我们的抓取。我们先尝试一个类似下图的种子列表页面。
- 对页码审查元素我们会看到:
<a href="/torrents.php?...page=2" title="page 2">2</a> <a href="/torrents.php?...page=3" title="page 3">3</a> <a href="/torrents.php?...page=4" title="page 4">4</a>
- 为了让我们的小爬虫知道如何爬取这些链接,我们需要为ZipruSpider类添加一个parse(response)方法:(页面元素选取可参看Selectors选择器简介或新手向爬虫(一)利用工具轻松爬取简书并分析)
def parse(self, response): # 从页面中取出页码里包含的链接 for page_url in response.css('a[title ~= page]::attr(href)').extract(): page_url = response.urljoin(page_url) # 将解析出的href里的链接自动判断补全 yield scrapy.Request(url=page_url, callback=self.parse) # 由解析出的url生成新的请求对象
- 在爬取从start_urls自动开始后,服务器返回的响应会自动传递给parse(self, response)方法。在解析了页面中的页码元素里包含的链接后,我们由每个解析出的url生成新的请求对象,它们的响应的解析方法即回调函数还是这个parse方法。只要这些url还没被处理过,这些请求将被转换为响应对象,仍然馈入parse(self, response)方法(感谢dupe过滤器帮我们自动去重链接)。
- 现在我们的小爬虫已经可以不断地爬取新的列表页面了。但是我们还没有获取到实际的信息。让我们加上对表格中元素的解析来获取种子信息。
def parse(self, response): # 从页面中取出页码里包含的链接 for page_url in response.xpath('//a[contains(@title, "page ")]/@href').extract(): page_url = response.urljoin(page_url) yield scrapy.Request(url=page_url, callback=self.parse) # 提取种子信息 for tr in response.css('table.lista2t tr.lista2'): tds = tr.css('td') link = tds[1].css('a')[0] yield { 'title' : link.css('::attr(title)').extract_first(), 'url' : response.urljoin(link.css('::attr(href)').extract_first()), 'date' : tds[2].css('::text').extract_first(), 'size' : tds[3].css('::text').extract_first(), 'seeders': int(tds[4].css('::text').extract_first()), 'leechers': int(tds[5].css('::text').extract_first()), 'uploader': tds[7].css('::text').extract_first(), }
- 在解析出url生成新的请求后,我们的小爬虫会处理当前页面的种子信息,生成一个字典项目,作为我们爬虫数据输出的一部分。(Scrapy会根据类型自动判断我们yield产出的是新的请求还是数据信息。)
- 对大多数网站的数据抓取来说,我们的任务就已经完成了。在命令行运行:
scrapy crawl zipru -o torrents.jl
几分钟后,一个格式良好的JSON Lines文件torrents.jl就生成了,包含了我们需要的种子信息。相反,我们会得到这样的输出:
[scrapy.extensions.logstats] INFO: Crawled 0 pages (at 0 pages/min), scraped 0 items (at 0 items/min) [scrapy.extensions.telnet] DEBUG: Telnet console listening on 127.0.0.1:6023 [scrapy.core.engine] DEBUG: Crawled (403) <GET 网页链接(referer: None) ['partial'] [scrapy.core.engine] DEBUG: Crawled (403) <GET 网页链接(referer: None) ['partial'] [scrapy.spidermiddlewares.httperror] INFO: Ignoring response <403 网页链接 [scrapy.core.engine] INFO: Closing spider (finished)
这时我们要考虑是否有公开API可以使用,或者耐心分析下问题。
简单的问题
- 我们的第一个请求获得了一个403响应,它会被忽略,然后因为我们只给了一个目标网址爬虫停止了。
- 如果手动浏览器访问该链接显示正常,我们可以用tcpdump来比较两次请求的差异。但我们首先需要检查的是User Agent参数。
- 默认情况下,Scrapy将其标识为“Scrapy / 1.3.3(+ http://scrapy.org)”,某些服务器可能会阻止它或者甚至只是将有限数量的User Agent列入白名单。
- 我们可以找到最常用的User Agents,使用其中之一通常足以绕过基本的防爬措施。这里我们将zipru_scraper/settings.py文件中的
# Crawl responsibly by identifying yourself (and your website) on the user-agent #USER_AGENT = 'zipru_scraper (+网页链接)'
替换为
USER_AGENT = 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_10_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/55.0.2883.95 Safari/537.36'
为了使我们的爬虫访问表现得更像人类的操作,让我们降低请求速率(原理上借助AutoThrottle 拓展),在settings.py中继续添加
CONCURRENT_REQUESTS = 1 DOWNLOAD_DELAY = 5
此外,我们的爬虫还会自动遵守robots.txt,可谓爬虫界的好公民了。现在运行 scrapy crawl zipru -o torrents.jl 应该会有如下输出:
[scrapy.core.engine] DEBUG: Crawled (200) <GET 网页链接(referer: None) [scrapy.downloadermiddlewares.redirect] DEBUG: Redirecting (302) to <GET 网页链接 [scrapy.core.engine] DEBUG: Crawled (200) <GET 网页链接(referer: None) ['partial'] [scrapy.core.engine] INFO: Closing spider (finished)
不错,有所进展。我们得到两个200状态码和一个下载器中间件会自动处理的302重定向响应。不幸的是,302将我们指向一个看上去不详的链接threat_defense.php。毫不意外,爬虫在那没找到什么有用的信息,爬取终止了。
下载器中间件
- 在我们深入探索之前了解下Scrapy是如何处理请求和响应的很有帮助。
- 当我们创建基本爬虫时,生成了scrapy.Request对象,然后它以某种方式转换为对应服务器响应的scrapy.Response。某种方式中的一大部分是下载器中间件的作用。
- 下载器中间件继承scrapy.downloadermiddlewares.DownloaderMiddleware,并且同时实现了process_request(request, spider)和process_response(request, response, spider)方法。顾名思义,可以猜得它们是做什么的。实际上,有一大堆默认的下载器中间件在工作。这是标准配置的样子(当然你可以修改它们):
DOWNLOADER_MIDDLEWARES_BASE = { 'scrapy.downloadermiddlewares.robotstxt.RobotsTxtMiddleware': 100, 'scrapy.downloadermiddlewares.httpauth.HttpAuthMiddleware': 300, 'scrapy.downloadermiddlewares.downloadtimeout.DownloadTimeoutMiddleware': 350, 'scrapy.downloadermiddlewares.defaultheaders.DefaultHeadersMiddleware': 400, 'scrapy.downloadermiddlewares.useragent.UserAgentMiddleware': 500, 'scrapy.downloadermiddlewares.retry.RetryMiddleware': 550, 'scrapy.downloadermiddlewares.ajaxcrawl.AjaxCrawlMiddleware': 560, 'scrapy.downloadermiddlewares.redirect.MetaRefreshMiddleware': 580, 'scrapy.downloadermiddlewares.httpcompression.HttpCompressionMiddleware': 590, 'scrapy.downloadermiddlewares.redirect.RedirectMiddleware': 600, 'scrapy.downloadermiddlewares.cookies.CookiesMiddleware': 700, 'scrapy.downloadermiddlewares.httpproxy.HttpProxyMiddleware': 750, 'scrapy.downloadermiddlewares.stats.DownloaderStats': 850, 'scrapy.downloadermiddlewares.httpcache.HttpCacheMiddleware': 900, }
- 在一个请求到达服务器的路上,它依次通过每个使能的中间件的process_request(request, spider)方法。按照数字由小到大的顺序依次进行,RobotsTxtMiddleware首先处理该请求,HttpCacheMiddleware最后处理。一旦响应被服务器返回,它也会依次经历这些中间件的process_response(request, response, spider)方法。这以相反的顺序发生(数字大的先处理)。也就是说,数字越大,越靠近服务器端,数字越小,越接近爬虫端。
- 一个特别简单的中间件是CookiesMiddleware。它只是简单地检查传入响应的Set-Cookie头,并且持久化cookies。当传出请求时,它会适当地设置Cookie头。当然,由于考虑cookie过期等因素它会复杂一点,但是概念是比较清楚的。
- 另一个相当基础的中间件是RedirectMiddleware,它只处理3XX重定向。对于所有非3XX状态码的响应它一律放行。当有重定向发生时,它会由服务器返回的重定向链接地址生成一个新的请求。当process_response(request, response, spider)方法返回一个请求对象而不是一个响应对象时,当前的响应对象会被丢弃,然后一切随着新请求重新开始。之前看到的输出信息就是如此。
- 如果你对这么多默认的下载器中间件感兴趣,可以查看架构总览。实际上还有很多其它的东西。但Scrapy伟大的地方在于你不必了解很多,正如不需要知道下载器中间件的存在也能写出功能足够的爬虫,写出一个工作良好的下载器中间件也不需要你对其它部分的了解。
困难的问题
- 回到我们的小爬虫,我们发现我们被重定向到threat_defense.php?defense=1&...链接而得不到想要的页面。在浏览器中查看这个页面,会是这样:
- 在被重定向到threat_defense.php?defense=2&...之前是这样的:
- 查看第一个页面的源码可以发现,页面中有一些JavaScript代码用于构造一个特殊的重定向URL与设置浏览器cookies。
- 我们需要解决这两个问题,当然也需要识别验证码并提交答案。如果我们不小心弄错了,有时会被重定向到其他的验证码页面,有时我们会终止于这样的页面:
- 我们需要点击Click here来开始整个重定向周期。小菜一碟,对吧!
- 既然所有的问题都来自于一开始的302重定向,那么顺理成章,让我们在定制的redirect middleware(重定向中间件)里解决它们。在遇到特殊的302重定向到threat_defense.php之外,我们想要这个中间件仍然像普通重定向中间件一样工作。当它遇到了这个特殊的302,我们希望它绕过所有这些防范措施,为会话添加访问Cookie,最终请求到原始网页。如果顺利的话,对于我们之前写的小爬虫来说,就不需要关心这些细节,像过去一样正常请求即可。
- 替换zipru_scraper/middlewares.py中的内容为
import os, tempfile, time, sys, logging logger = logging.getLogger(__name__) import dryscrape import pytesseract from PIL import Image from scrapy.downloadermiddlewares.redirect import RedirectMiddleware class ThreatDefenceRedirectMiddleware(RedirectMiddleware): def _redirect(self, redirected, request, spider, reason): # 如果没有特殊的防范性重定向那就正常工作 if not self.is_threat_defense_url(redirected.url): return super()._redirect(redirected, request, spider, reason) logger.debug(f'Zipru threat defense triggered for {request.url}') request.cookies = self.bypass_threat_defense(redirected.url) request.dont_filter = True # 防止原始链接被标记为重复链接 return request def is_threat_defense_url(self, url): return '://zipru.to/threat_defense.php' in url
- 我们继承了RedirectMiddleware中间件,使得我们可以复用内置的重定向处理操作,而只需要将我们的代码插入_redirect(redirected, request, spider, reason)方法,一旦构建了重定向请求,它会被process_response(request, response, spider)方法调用。对于非防范性重定向,我们调用父类的标准方法处理。这里,我们还未实现bypass_threat_defense(url)方法,但是它任务很明确,就是返回访问cookies,使得我们可以刷新原始请求的cookies,而重新处理原始请求。
- 为了启用我们的新中间件,要在zipru_scraper/settings.py中添加如下内容:
DOWNLOADER_MIDDLEWARES = { 'scrapy.downloadermiddlewares.redirect.RedirectMiddleware': None, 'zipru_scraper.middlewares.ThreatDefenceRedirectMiddleware': 600, }
它禁用了默认的重定向中间件,并将我们自己的中间件插入到相同的位置。此外,我们还需要安装一些需求包:
pip install dryscrape # headless webkit 无头webkit pip install Pillow # image processing 图像处理 pip install pytesseract # OCR 字符识别
要注意,这些包都具有pip不能处理的外部依赖。如果安装出错,你需要访问dryscrape,Pillow以及 pytesseract来获取安装指导。
- 接下来,我们只需要实现bypass_thread_defense(url)。我们可以解析JavaScript来获取需要的变量,并在python中重建逻辑,不过那显得琐碎而麻烦。让我们选择笨拙而简单的做法,使用无头webkit实例。这有不少选择,不过我独爱dryscrape(之前安装的)。
- 首先,在我们的中间件构造器里初始化一个dryscrape会话。
def __init__(self, settings): super().__init__(settings) # start xvfb to support headless scraping if 'linux' in sys.platform: dryscrape.start_xvfb() self.dryscrape_session = dryscrape.Session(base_url='网页链接)
你可以把这个会话当作一个浏览器标签,它会做所有浏览器通常所做的事(如获取外部资源,获取脚本)。我们可以在选项卡中导航到新的URL,点击按钮,输入文本以及做其它各类事务。Scrapy支持请求和项目处理的并发,但响应的处理是单线程的。这意味着我们可以使用这个单独的dryscrape会话,而不用担心线程安全。
- 现在我们来看一下绕过服务器防御的基本逻辑。
可以看到,如果验证码解析失败,我们会回到bypass_threat_defense()。这样我们拥有多次尝试的机会,直到成功一次。
看起来我们的爬虫应该成功了,可是它陷入了无限循环中:
[object Object]
最后,想学习Python的小伙伴们!
请关注+私信回复:“学习”就可以拿到一份我为大家准备的Python学习资料!
pytyhon学习资料
python学习资料