Jobs: pausing and resuming crawls1
Sometimes, for big sites, it’s desirable to pause crawls and be able to resume them later.html
Scrapy supports this functionality out of the box by providing the following facilities:python
- a scheduler that persists scheduled requests on disk
- a duplicates filter that persists visited requests on disk
- an extension that keeps some spider state (key/value pairs) persistent between batches
Job directory
To enable persistence support you just need to define a job directory through the JOBDIR
setting. This directory will be for storing all required data to keep the state of a single job (ie. a spider run). It’s important to note that this directory must not be shared by different spiders, or even different jobs/runs of the same spider, as it’s meant to be used for storing the state of a single job.cookie
How to use it
To start a spider with persistence support enabled, run it like this:python爬虫
scrapy crawl somespider -s JOBDIR=crawls/somespider-1
Then, you can stop the spider safely at any time (by pressing Ctrl-C or sending a signal), and resume it later by issuing the same command:scrapy
scrapy crawl somespider -s JOBDIR=crawls/somespider-1
Keeping persistent state between batches
Sometimes you’ll want to keep some persistent spider state between pause/resume batches. You can use the spider.state
attribute for that, which should be a dict. There’s a built-in extension that takes care of serializing, storing and loading that attribute from the job directory, when the spider starts and stops.分布式
Here’s an example of a callback that uses the spider state (other spider code is omitted for brevity):ide
def parse_item(self, response): # parse item here self.state['items_count'] = self.state.get('items_count', 0) + 1
Persistence gotchas
There are a few things to keep in mind if you want to be able to use the Scrapy persistence support:学习
Cookies expiration
Cookies may expire. So, if you don’t resume your spider quickly the requests scheduled may no longer work. This won’t be an issue if you spider doesn’t rely on cookies.ui
Request serialization
Requests must be serializable by the pickle module, in order for persistence to work, so you should make sure that your requests are serializable.this
The most common issue here is to use lambda
functions on request callbacks that can’t be persisted.
So, for example, this won’t work:
def some_callback(self, response): somearg = 'test' return scrapy.Request('http://www.example.com', callback=lambda r: self.other_callback(r, somearg)) def other_callback(self, response, somearg): print("the argument passed is: %s" % somearg)
But this will:
def some_callback(self, response): somearg = 'test' return scrapy.Request('http://www.example.com', callback=self.other_callback, meta={'somearg': somearg}) def other_callback(self, response): somearg = response.meta['somearg'] print("the argument passed is: %s" % somearg)
If you wish to log the requests that couldn’t be serialized, you can set the SCHEDULER_DEBUG setting to True
in the project’s settings page. It is False
by default.
注意:
运行爬虫的时候将中间信息保存:
- 方式一:在settings.py文件中设置JOBDIR = ‘path’。
- 方式二:在具体的爬虫文件中指定:
custom_settings = { "JOBDIR": "path" }
Windows or Linux环境下,一次Ctrl+C进程将收到中断信号,两次Ctrl+C则强制杀掉进程。
Linux环境下,kill -f main.py
进程会收到一个中断信号,有了这个信号,scrapy就能够作一些后续的处理,若直接kill -f -9 main.py
则进程没法收到一个中断信号,进程将被操做系统给强制杀掉,不会再进行任何后续处理。
示例:
scrapy crawl jobbole -s JOBDIR=job_info/001
- -s是-set的意思
- 不一样的spider须要不一样的目录,不一样时刻启动的spider也须要不一样的目录
- ctrl-c 后就会将暂停信息保存到job_info/001,要想从新开始则再次运行
scrapy crawl jobbole -s JOBDIR=job_info/001
而后会继续爬取没有作完的东西。
参考:
第六章 慕课网学习-scrapy的暂停与重启 https://blog.csdn.net/shaququ/article/details/77587941
python爬虫进阶之scrapy的暂停与重启 https://blog.csdn.net/m0_37338590/article/details/81332540
三十二 Python分布式爬虫打造搜索引擎Scrapy精讲—scrapy的暂停与重启 https://www.cnblogs.com/meng-wei-zhi/p/8182788.html
Scrapy 官方文档 https://doc.scrapy.org/en/latest/topics/jobs.html 2019-3-8 ↩︎