作者:俊欣
来源:关于数据分析与可视化
今天我们来聊一下如何用协程来进行数据的抓取,协程又称为是微线程,也被称为是用户级线程,在单线程的情况下完成多任务,多个任务按照一定顺序交替执行。
那么aiohttp模块在Python中作为异步的HTTP客户端/服务端框架,是基于asyncio的异步模块,可以用于实现异步爬虫,更快于requests的同步爬虫。下面我们就通过一个具体的案例来看一下该模块到底是如何实现异步爬虫的。
发起请求我们先来看一下发起请求的部分,代码如下
要是返回的状态码是200或者是201,则获取响应内容,下一步我们便是对响应内容的解析
响应内容解析这里用到的是PyQuery模块来对响应的内容进行解析,代码如下
def extract_elements(source): try: dom = etree.HTML(source) id = dom.xpath('......')[0] title = dom.xpath('......')[0] price = dom.xpath('.......')[0] information = dict(re.compile('.......').findall(source)) information.update(title=title, price=price, url=id) print(information) asyncio.ensure_future(save_to_database(information, pool=pool)) except Exception as e: print('解析详情页出错!') logger.warning('解析详情页出错!') pass 最后则是将解析出来的内容存入至数据库当中
数据存储这里用到的是aiomysql模块,使用异步IO的方式保存数据到Mysql当中,要是不存在对应的数据表,我们则创建对应的表格,代码如下
项目的启动最后我们来看一下项目启动的代码,如下
我们通过调用ensure_future方法来安排协程的进行
数据分析与可视化下面我们针对抓取到的数据进行进一步的分析与可视化,数据源是关于上海的二手房的相关信息,我们先来看一下房屋户型的分布,代码如下
我们可以看到占到大多数的都是“2室1厅1厨1卫”的户型,其次便是“1室1厅1厨1卫”的户型,可见上海二手房交易的市场卖的小户型为主。而他们的所在楼层,大多也是在高楼层(共6层)的为主,如下图所示
我们再来看一下房屋的装修情况,市场上的二手房大多都是以“简装”或者是“精装”为主,很少会看到“毛坯”的存在,具体如下图所示
至此,我们就暂时先说到这里,本篇文章主要是通过异步协程的方式来进行数据的抓取,相比较于常规的requests数据抓取而言,速度会更快一些。