爬虫之scrapy框架enjoyzier

在Scrapy的数据流是由执行引擎控制,具体流程如下:

要使用Scrapy框架创建项目,需要通过命令来创建。首先进入到你想把这个项目存放的目录。然后使用以下命令创建:

scrapystartproject[项目名称]2.2.2创建爬虫

创建爬虫:进入到项目所在的路径,执行命令“scrapygenspider[爬虫名][爬虫域名]”

注意:爬虫名不能和创建的项目名一致

创建完项目和爬虫后,目录结构如下图:

项目中主要文件的作用:

scrapygensipderqsbk_spider"qiushibaike.com"创建了一个名字叫做qsbk_spider的爬虫,并且能爬取的网页只会限制在qiushibaike.com这个域名下。

在做一个爬虫之前,一定要记得修改setttings.py中的设置。两个地方是强烈建议设置的。

运行scrapy项目。需要在终端,进入项目所在的路径,然后scrapycrawl[爬虫名字]即可运行指定的爬虫。如果不想每次都在命令行中运行,那么可以把这个命令写在一个文件中。以后就在pycharm中执行运行这个文件就可以了。比如现在新创建一个文件叫做start.py,然后在这个文件中填入以下代码:

fromscrapyimportcmdlinecmdline.execute(["scrapy","crawl","qsbk_spider"])#cmdline.execute("scrapycrawlqsbk_spider".split())2.4.6糗事百科scrapy爬虫笔记

2.提出出来的数据是一个'Selector'或者'Selectorlist'对象,如果想要获取其中的字符串,可以通过getall()或者get()方法。

3.getall()方法获取‘Selector’中的所有文本,返回的是一个列表。get()方法获取的是‘Selector’中的第一个文本,返回的是一个str类型。

4.如果数据解析完成后,要传给pipline处理,可以使用'yield'来返回,或者是收取所有的item,组合成一个列表,最后统一使用return返回。

5.item:建议在'items.py'中定义好要传递的数据。

6.pipeline:这个是专门用来保存数据的,其中有三个方法经常会用到。

*"open_spider(self,spider)":当爬虫被打开时执行。

*"process_item(self,item,spider)":当爬虫有item传过来时被调用。

*"close_spider(self,spider)":当爬虫关闭的时候被调用。

要激活pipeline,需要在'settings.py中设置"ITEM_PIPELINES"。示例如下:

ITEM_PIPELINES={'qsbk.pipelines.QsbkPipeline':300,}7.保存json数据的时候,可以使用JsonItemExporter和JsonLinesItemExporter类,优化数据存储方式

*JsonItemExporter:每次把数据添加到内存中,最后统一写入到磁盘。优点:存储的数据是一个满足json规则的数据。缺点:当数据量很大的时候比较耗内存。示例代码如下:

fromscrapy.exportersimportJsonItemExporterclassQsbkPipeline(object):def__init__(self):self.fp=open('duanzi.json','wb')self.exporter=JsonItemExporter(self.fp,ensure_ascii=False,encoding='utf-8')self.exporter.start_exporting()defopen_spider(self,spider):print('爬虫开始了...')defprocess_item(self,item,spider):self.exporter.export_item(item)returnitemdefclose_spider(self,spider):self.exporter.finish_exporting()self.fp.close()print('爬虫结束')ViewCode*JsonLinesItemExporter:这个是每次调用export_item的时候就把这个item存储到硬盘中,缺点:每个字典是一行,整个文件不是一个满足json格式的文件。优点:每次处理数据的时候就直接存储到硬盘中,这样不会耗内存,数据也比较安全。示例代码如下:

fromscrapy.exportersimportJsonLinesItemExporterclassQsbkPipeline(object):def__init__(self):self.fp=open('duanzi.json','wb')self.exporter=JsonLinesItemExporter(self.fp,ensure_ascii=False,encoding='utf-8')defopen_spider(self,spider):print('爬虫开始了...')defprocess_item(self,item,spider):self.exporter.export_item(item)returnitemdefclose_spider(self,spider):self.fp.close()print('爬虫结束')ViewCode3.CrawlSpider在上一个糗事百科的爬虫案例中。我们是自己在解析完整个页面后获取下一页的url,然后重新发送一个请求。有时候我们想要这样做,只要满足某个条件的url,都给我进行爬取。那么这时候我们就可以通过CrawlSpider来帮我们完成了。CrawlSpider继承自Spider,只不过是在之前的基础之上增加了新的功能,可以定义爬取的url的规则,以后scrapy碰到满足条件的url都进行爬取,而不用手动的yieldRequest。

3.1.1创建CrawlSpider爬虫

之前创建爬虫的方式是通过scrapygenspider[爬虫名字][域名]的方式创建的。如果想要创建CrawlSpider爬虫,那么应该通过以下命令创建:

scrapygenspider-tcrawl[爬虫名字][域名]3.1.2LinkExtractors链接提取器

使用LinkExtractors可以不用程序员自己提取想要的url,然后发送请求。这些工作都可以交给LinkExtractors,他会在所有爬的页面中找到满足规则的url,实现自动的爬取。以下对LinkExtractors类做一个简单的介绍:

3.1.3Rule规则类

定义爬虫的规则类。以下对这个类做一个简单的介绍:

classscrapy.spiders.Rule(link_extractor,callback=None,cb_kwargs=None,follow=None,process_links=None,process_request=None)主要参数讲解:

爬虫部分代码:

importscrapyclassWxappItem(scrapy.Item):#definethefieldsforyouritemherelike:#name=scrapy.Field()title=scrapy.Field()author=scrapy.Field()pub_time=scrapy.Field()content=scrapy.Field()items.pypipeline部分代码:

1.CrawlSpider使用"LinkExtractor"和Rule决定爬虫的具体走向。

2.LinkExtractor参数allow设置规则:设置的url正则表达式要能够限制在我们想要的url上

3.Rule参数follow的设置:如果在爬取页面的时候,需要将满足当前条件的url再进行跟进,那么设置为Ture,否则设置为False。

4.什么时候指定callback:如果这个url对应的页面,只是为了获取更多的url,并不需要里面的数据,那么可以不指定callback,如果想要获取url对应页面中的数据,那么就需要指定一个callback。

1.url:这个是request对象发送请求的url

2.callback:在下载器下载完成相应的数据后执行回调函数

3.method:请求的方法,默认为GET方法,可以设置为其他方法

4.headers:请求头,对于一些固定的设置,放在settings.py中指定就可以,对于非固定的请求头,可以在发送请求的时候指定。

6.meta:比较常用,用于在不同的请求之间传递数据

7.encoding:编码,默认为utf-8

8.dot_filter:表示不由调度器过滤,在执行多次重复的请求的时候用的较多,设置为True,可避免重复发送相同的请求

9.errback:在发送错误的时候执行的函数

发送Post请求:

有时候我们想要在请求数据的时候发送post请求,那么这时候需要使用Request的子类FormRequest来实现。如果想要在爬虫一开始的时候就发送Post请求,那么需要在爬虫类中重写start_requests(self)方法,并且不再调用start_urls里的url.

Response对象一般由Scrapy自动构建,因此开发者不需要关心如何创建Response对象。Response对象有很多属性,常用属性如下:

1.meta:从其他请求传过来的meta属性,可以用来保持多个请求之间的数据连接

2.encoding:返回当前字符串编码和解码格式

3.text:将返回的数据作为unicode字符串返回

4.body:将返回的数据作为bytes字符串返回

5.xpath:xpath选择器

6.css:css选择器

importscrapyclassBm5XItem(scrapy.Item):#definethefieldsforyouritemherelike:#name=scrapy.Field()category=scrapy.Field()urls=scrapy.Field()items.pypipeline部分代码:

importosfromurllibimportrequestclassBm5XPipeline(object):def__init__(self):BATH=os.path.dirname(os.path.dirname(__file__))self.path=os.path.join(BATH,'images')ifnotos.path.exists(self.path):os.makedirs(self.path)defprocess_item(self,item,spider):category=item['category']urls=item['urls']category_path=os.path.join(self.path,category)ifnotos.path.exists(category_path):os.makedirs(category_path)forurlinurls:image_name=url.split('_')[-1]request.urlretrieve(url,os.path.join(category_path,image_name))returnitempipelines.py2)使用scrapy内置下载文件方法下载汽车之家宝马5系图片,示例如下:

Scrapy为下载item中包含的文件(比如在爬取到产品时,同时也想保存对应的图片)提供了一个可重用的itempipelines。这些pipelines有些共同的方法和结构(我们称之为mediapipeline)。一般来说你会使用Filespipline或者Imagespipline。

为什么要选择使用scrapy内置的下载文件的方法:

1)避免重新下载最近已经下载过的数据

2)可以方便的指定文件存储的路径

3)可以将下载的图片转换为通用的格式,比如png或jpg

4)可以方便的生成缩略图

5)可以方便的检测图片的宽和高,确保他们满足最小的限制

6)异步下载,效率非常高

下载文件的FilesPipeline:

当使用FilesPipline下载文件的时候,按照以下步骤来完成:

1)定义好一个Item,然后在这个item中定义两个属性,分别为file_urls以及files。file_urls是用来存储需要下载的文件的url链接,需要给一个列表。

3)在配置文件setting.py中配置FILES_STORE,这个配置是用来设置文件下载下来的路径。

4)启动pipline,在ITEM_PIPELINES中设置

ITEM_PIPELINES={#'BM5X.pipelines.Bm5XPipeline':300,'scrapy.pipelines.files.FilesPipeline':1}下载图片的ImagesPipeline:

当使用ImagesPipline下载文件的时候,按照以下步骤来完成:

1)定义好一个Item,然后在这个item中定义两个属性,分别为image_urls以及images。image_urls是用来存储需要下载的图片的url链接,需要给一个列表。

3)在配置文件settings.py中配置IMAGES_STORE,这个配置是用来设置图片下载下来的路径。

ITEM_PIPELINES={#'BM5X.pipelines.Bm5XPipeline':300,'scrapy.pipelines.images.ImagesPipeline':1}爬虫部分代码:

importscrapyclassBm5XItem(scrapy.Item):#definethefieldsforyouritemherelike:#name=scrapy.Field()category=scrapy.Field()image_urls=scrapy.Field()images=scrapy.Field()items.pypipeline部分代码:

importosfromscrapy.pipelines.imagesimportImagesPipelinefromBM5XimportsettingsclassBM5XImagesPipeline(ImagesPipeline):defget_media_requests(self,item,info):#这个方法是在发送下载请求之前调用#其实这个方法本身就是去发送下载请求的request_objs=super(BM5XImagesPipeline,self).get_media_requests(item,info)forrequest_objinrequest_objs:request_obj.item=itemreturnrequest_objsdeffile_path(self,request,response=None,info=None):#这个方法是在图片将要被保存的时候调用,来获取这个图片存储的路径path=super(BM5XImagesPipeline,self).file_path(request,response,info)category=request.item.get('category')images_store=settings.IMAGES_STOREcategory_path=os.path.join(images_store,category)ifnotos.path.exists(category_path):os.makedirs(category_path)image_name=path.replace('full/','')image_path=os.path.join(category_path,image_name)returnimage_pathViewCodesetting部分代码:

process_request(self,request,spider):

这个方法是下载器在发送请求之前执行,一般可以在这个里面设置随机代理ip等。

1)参数:

request:发送请求的request对象。

spider:发送请求的spider对象。

2)返回值:

返回None:如果返回None,Scrapy将继续处理该request,执行其他中间件中的相应方法,直到合适的下载器处理函数被调用

返回Response对象:Scrapy将不会调用任何其他的process_request方法,将直接返回这个response对象。已经激活的中间件process_response()方法则会在每个response返回时被调用

返回Request对象:不再使用之前的request对象去下载数据,而是根据现在返回的request对象返回数据。

如果这个方法中出现了异常,则会调用process_exception方法

process_response(self,request,response,spider):

这个是下载器下载数据到引擎过程中执行的方法

request:request对象

response:被处理的response对象

spider:spider对象

返回Response对象:会将这个新的response对象传给其他中间件,最终传给爬虫

返回Request对象:下载器链被切断,返回的request会重新被下载器调度下载

如果抛出一个异常,那么调用request的errback方法,如果没有指定这个方法,那么会抛出一个异常

THE END
1.汽车之家汽车之家为您提供最新汽车报价,汽车图片,汽车价格大全,最精彩的汽车新闻、行情、评测、导购内容,是提供信息最快最全的中国汽车网站https://www.autohome.com.cn/
2.寻找IT价值走进明星企业——汽车之家共话轻盈IT之道决大份额的会出现在我们的网站上,所以我们天然比别人有更多的数据,我们挖掘的层次比别人多,前几类都可以挖掘出来,做用户的属性,关注的产品我不太确定,因为很多广告公司在汽车行业所谓的精准是来过汽车之家我就不是很确定了,我们的精准关注产品可以做得比别人更细,因为有全量的用户的访问轨迹,你老看宝马不可能是https://topic.it168.com/game/dell1310/index.html
3.汽车之家新车试驾「汽车试驾」车生活为您提供最新汽车之家新车试驾,汽车评测,静态体验,动态体验等方面的内容,是服务于购车,试驾体验人群的版块 -【车生活】-http://www.andapei.com/article/zt_7.html
4.汽车之家的微博汽车之家官方微博 3 公司 汽车之家 ü 简介: 汽车之家以科技驱动持续降低汽车行业决策和交易成本,秉持着专业、好玩的态度,为消费者提供“省心、省时、 T 友情链接 汽车之家论坛频道 汽车之家新闻频道 汽车之家导购频道 汽车之家评测频道 汽车之家用车频道 汽车之家视频频道 更多a 微关系 他的关https://weibo.com/qichezhijia
5.承受之重”:这家公司正让超跑用的碳纤维走向大众在这一方面,上市公司康得新集团担当了一个前哨的角色,其与慕尼黑工业大学碳纤维复材中心合作成立了KDX欧洲复合材料研发中心,总投资3000万欧元,专注于汽车碳纤维复合材料领域技术、材料和工艺的开发,并且已经成为宝马、奥迪和空中客车的技术合作单位。 在碳纤维复合材料生产和研发之外,康得集团针也对碳纤维从材料走向汽车https://www.tmtpost.com/2608838.html
6.入口app安卓官方地址福建省消费者权益保护委员会消息,近日,福建省消委会关注到福州中宝、福建星德宝等多家宝马4S店突然关门,人去楼空,导致众多车主面临下订后无车可提、汽车配件无法取回、售后服务无法进行等困境。这一事件引发了广泛的社会关注和车主们的强烈不满。针对此事,福建省消委会发布消费提醒:警惕“4S店”突然闭店下的消费http://s.hebingwang.com/cfueefv.html
7.年亏超1400万险破产!全国多家宝马4S店暴雷,一线豪车尊严稀碎遭人全国多家宝马4S店暴雷,一线豪车尊严稀碎遭人唾弃? 在汽车圈率先退出价格战的宝马,终究是扛不住了。 7月份,宝马高调宣传退出价格战,不搞内卷,降量保价。当时在短时间内获得不少人的支持,店内看车的消费者络绎不绝,但好景不长,销量还是没达到预期。https://news.qq.com/rain/a/20241019A07DDG00
8.汽车之家汽车之家,隶属北京车之家信息技术有限公司,是一家提供汽车消费和汽车生活服务的汽车互联网平台[1],联合创始人为李想、樊铮[2]。该网站于2005年6月1日正式上线[3],2010年10月发布iOS与Android版,2013年在纽约证券交易所上市,代号ATHM[4]。 汽车之家的主要业务是围绕看车、买车、用车、换车等场景,提供汽车消费https://baike.sogou.com/v17436.htm
9.你留在汽车之家的电话号码,5年被“卖”了96亿打开汽车之家,选择一款喜欢的车型,点击获取底价,在弹出的页面输入“姓名”、“手机号”等信息,这样的“询价”操作,意味着你正在将自己的信息无偿交给平台,而平台会把这些信息有偿提供给第三方、每年获得数十亿的收入。 你的信息很值钱,甚至可以为上市公司汽车之家带来近百亿的收入。 https://www.iyiou.com/p/94819.html
10.汽车之家(ATHM)股吧汽车之家怎么样汽车之家(ATHM)股吧,股民朋友可以在这里畅所欲言,分析讨论股票名的最新动态。东方财富股吧,专业的股票论坛社区。https://guba.eastmoney.com/list,usathm.html
11.哈弗m2汽车之家(盘点汽车的另类设计:小众不等于差)写在开头:本文所有内容均转自汽车之家车市资讯新闻,仅对汽车之家全天车市重点新闻进行梳理及汇总。 丰评新闻目录 一:更多马力,更多乐趣,86的魔力即将延续 或搭载2.4L发动机 全新丰田86谍照首曝 二:杀气尽显,跟战斗的2系你喜欢吗?更多细节曝光 新宝马2系Coupe无伪谍照 https://www.sdtfbj.com/post/98072.html
12.平行进口车专业平行进口车网站,为您详解平行进口车和4s店区别,平行进口车有什么弊端,天津平行进口车新骗局等,买平行进口车,就来汽车江湖自贸区平行进口车官方旗舰店http://www.qc188.com/
13.小宝马载货车2018新款小宝马载货车图片唐骏汽车(1)北京卡车之家信息技术股份有限公司尊重您的隐私。卡车之家将按照本声明及《隐私政策》(链接地址:http://www.360che.com/help/privacy/)的规定收集、使用、储存和分享您的个人信息。本协议对个人信息保护规定的内容与上述《隐私政策》有相冲突的,及本协议对个人信息保护相关内容未作明确规定的,以《隐私政策》的https://product.m.360che.com/s15/3830_64_Pic.html