标签:http pipeline 结构 top import 节点 没有 win32 提取数据
pip install scrapy
即可安装。 如果在windows
系统下,提示这个错误ModuleNotFoundError: No module named ‘win32api‘
,那么使用以下命令可以解决:pip install pypiwin32
。
进入到你想把这个项目存放的目录。然后使用控制台创建项目:
scrapy startproject demo
以下介绍下主要文件的作用:
items
的模型存储到本地磁盘中。scrapy genspider qsbk "qiushibaike.com"
创建了一个名字叫做qsbk
的爬虫,并且能爬取的网页只会限制在qiushibaike.com
这个域名下。
该命令会自动在项目的spiders目录下创建qsbk.py文件,并自动写入下面代码.
import scrapy class QsbkSpider(scrapy.Spider): name = ‘qsbk‘ allowed_domains = [‘qiushibaike.com‘] start_urls = [‘http://qiushibaike.com/‘] def parse(self, response): pass
其实这些代码我们完全可以自己手动去写,而不用命令。只不过是不用命令,自己写这些代码比较麻烦。
要创建一个Spider,那么必须自定义一个类,继承自scrapy.Spider
,然后在这个类中定义三个属性和一个方法。
parse
方法。这个是个固定的写法。这个方法的作用有两个,第一个是提取想要的数据。第二个是生成下一个请求的url。settings.py
代码:在做一个爬虫之前,一定要记得修改setttings.py
中的设置。两个地方是强烈建议设置的。
ROBOTSTXT_OBEY
设置为False。默认是True。即遵守机器协议,那么在爬虫的时候,scrapy首先去找robots.txt文件,如果没有找到。则直接停止爬取。DEFAULT_REQUEST_HEADERS
添加User-Agent
。这个也是告诉服务器,我这个请求是一个正常的请求,不是一个爬虫。qsbk.py文件代码
1 # -*- coding: utf-8 -*- 2 import scrapy 3 from demo.items import DemoItem 4 5 6 class QsbkSpider(scrapy.Spider): 7 name = ‘qsbk‘ 8 allowed_domains = [‘qiushibaike.com‘] 9 start_urls = [‘https://www.qiushibaike.com/hot/page/1/‘] 10 11 def parse(self, response):
# selectorlist 12 divs = response.xpath("//div[@id=‘content-left‘]/div") 13 for div in divs:
selector 14 author = div.xpath(".//h2/text()").get().strip() 15 content = div.xpath(".//div[@class=‘content‘]//text()").getall() # get和getall方法都具有将xpath提取到的数据从selector转换为unicode的作用,只不过get()返回字符串,getall()返回的是一个列表 16 content = "".join(content).strip() 17 item = DemoItem(author=author, content=content) 18 yield item
items.py代码
1 import scrapy 2 3 4 class DemoItem(scrapy.Item): 5 author = scrapy.Field() 6 content = scrapy.Field()
pipelines代码
import json class DemoPipeline(object): def __init__(self): self.fp = open("duanzi.json", "w", encoding="utf-8") def open_spider(self, spider): pass def process_item(self, item, spider): item_json = json.dumps(dict(item), ensure_ascii=False) self.fp.write(item_json+‘\n‘, ) return item def close_spider(self, spider): self.fp.close()
记得要将settings.py里的pipelines设置注释取消掉
# Configure item pipelines # See https://doc.scrapy.org/en/latest/topics/item-pipeline.html ITEM_PIPELINES = { ‘demo.pipelines.DemoPipeline‘: 300, }
运行scrapy项目。需要在终端,进入项目所在的路径,然后scrapy crawl [爬虫名字]
即可运行指定的爬虫。如果不想每次都在命令行中运行,那么可以把这个命令写在一个文件中。以后就在pycharm中执行运行这个文件就可以了。比如现在新创建一个文件叫做start.py
,然后在这个文件中填入以下代码:
from scrapy import cmdline cmdline.execute("scrapy crawl qsbk".split())
1、response是一个scrapy.http.response.html.HtmlResponse对象,可以使用xpath和css语法来提取数据。
2、提取出来的数据是Selector或者是SelectorList对象,获取其中字符串应该使用get()或getall()方法。
3、getall方法:获取所有文本,返回的是一个列表。
4、get方法:获取的是第一个文本,返回的是一个str类型。
5、如果数据解析回来,要传给pipeline处理,那么使用yield来返回。或者在收集所有item,最后统一使用return返回。
6、item:建议在items.py中定义好模型,不要 使用字典返回。
7、pipelines中的四个常用方法。
怎么样使爬虫自动爬取下一页呢?修改qsbk.py文件如下:
1 # -*- coding: utf-8 -*- 2 import scrapy 3 from demo.items import DemoItem 4 5 6 class QsbkSpider(scrapy.Spider): 7 name = ‘qsbk‘ 8 allowed_domains = [‘qiushibaike.com‘] 9 start_urls = [‘https://www.qiushibaike.com/hot/page/1/‘] 10 11 def parse(self, response): 12 13 divs = response.xpath("//div[@id=‘content-left‘]/div") 14 for div in divs: 15 author = div.xpath(".//h2/text()").get().strip() 16 content = div.xpath(".//div[@class=‘content‘]//text()").getall() 17 content = "".join(content).strip() 18 item = DemoItem(author=author, content=content) 19 yield item 20 #url跟进开始 21 #获取下一页的url信息, ..是前一个节点的父节点. 22 url = response.xpath("//span[contains(text(),‘下一页‘)]/../@href").extract() 23 print(url) 24 if url: 25 #将信息组合成下一页的url 26 page = ‘https://www.qiushibaike.com‘ + url[0] 27 #返回url 28 yield scrapy.Request(page, callback=self.parse) 29 #url跟进结束
提取下一页的链接的时候,使用xpath的"//span[contains(text(),‘下一页‘)]/../@href"先定位到span节点,在定位到父节点a,获取链接.
标签:http pipeline 结构 top import 节点 没有 win32 提取数据
原文地址:https://www.cnblogs.com/baoshilin/p/12425028.html