HTML5技术

python编写知乎爬虫实践 - cpselvis

字号+ 作者:H5之家 来源:H5之家 2017-06-14 15:00 我要评论( )

爬虫的基本流程 网络爬虫的基本工作流程如下: 爬虫的抓取策略 在爬虫系统中,待抓取URL队列是很重要的一部分。待抓取URL队列中的URL以什么样的顺序排列也是一个很重要的问题,因为这涉及到先抓取那个页面,后抓取哪个页面。而决定这些URL排列顺序的方法,叫

爬虫的基本流程

网络爬虫的基本工作流程如下:

爬虫的抓取策略

在爬虫系统中,待抓取URL队列是很重要的一部分。待抓取URL队列中的URL以什么样的顺序排列也是一个很重要的问题,因为这涉及到先抓取那个页面,后抓取哪个页面。而决定这些URL排列顺序的方法,叫做抓取策略。下面重点介绍几种常见的抓取策略:

  • 深度优先策略(DFS)
    深度优先策略是指爬虫从某个URL开始,一个链接一个链接的爬取下去,直到处理完了某个链接所在的所有线路,才切换到其它的线路。
    此时抓取顺序为:A -> B -> C -> D -> E -> F -> G -> H -> I -> J
  • 广度优先策略(BFS)
    宽度优先遍历策略的基本思路是,将新下载网页中发现的链接直接插入待抓取URL队列的末尾。也就是指网络爬虫会先抓取起始网页中链接的所有网页,然后再选择其中的一个链接网页,继续抓取在此网页中链接的所有网页。
    此时抓取顺序为:A -> B -> E -> G -> H -> I -> C -> F -> J -> D
  • 了解了爬虫的工作流程和爬取策略后,就可以动手实现一个爬虫了!那么在python里怎么实现呢?

    技术栈 基本实现

    下面是一个伪代码

    import Queue initial_page = "https://www.zhihu.com/people/gaoming623" url_queue = Queue.Queue() seen = set() seen.insert(initial_page) url_queue.put(initial_page) : current_url = url_queue.get() #拿出队例中第一个的url store(current_url) next_url not in seen: seen.put(next_url) url_queue.put(next_url) else: break

    如果你直接加工一下上面的代码直接运行的话,你需要很长的时间才能爬下整个知乎用户的信息,毕竟知乎有6000万月活跃用户。更别说Google这样的搜索引擎需要爬下全网的内容了。那么问题出现在哪里?

    布隆过滤器

    需要爬的网页实在太多太多了,而上面的代码太慢太慢了。设想全网有N个网站,那么分析一下判重的复杂度就是N*log(N),因为所有网页要遍历一次,而每次判重用set的话需要log(N)的复杂度。OK,我知道python的set实现是hash——不过这样还是太慢了,至少内存使用效率不高。

    通常的判重做法是怎样呢?Bloom Filter. 简单讲它仍然是一种hash的方法,但是它的特点是,它可以使用固定的内存(不随url的数量而增长)以O(1)的效率判定url是否已经在set中。可惜天下没有白吃的午餐,它的唯一问题在于,如果这个url不在set中,BF可以100%确定这个url没有看过。但是如果这个url在set中,它会告诉你:这个url应该已经出现过,不过我有2%的不确定性。注意这里的不确定性在你分配的内存足够大的时候,可以变得很小很少。

    # bloom_filter.py BIT_SIZE BloomFilter: def __init__(self): # Initialize bloom filter, set size and all bits to 0 bit_array = bitarray(BIT_SIZE) bit_array.setall(0) self.bit_array = bit_array def add(self, url): # Add a url, and set points in bitarray to 1 (Points count is equal to hash funcs count.) # Here use 7 hash functions. point_list = self.get_postions(url) for b in point_list: contains(self, url): # Check if a url is in a collection point_list = self.get_postions(url) result b in point_list: result = result and self.bit_array[b] return result def get_postions(self, url): # Get points positions in bit vector. point1 = mmh3.hash(url, 41) % BIT_SIZE point2 = mmh3.hash(url, 42) % BIT_SIZE point3 = mmh3.hash(url, 43) % BIT_SIZE point4 = mmh3.hash(url, 44) % BIT_SIZE point5 = mmh3.hash(url, 45) % BIT_SIZE point6 = mmh3.hash(url, 46) % BIT_SIZE point7 = mmh3.hash(url, 47) % BIT_SIZE return [point1, point2, point3, point4, point5, point6, point7]

    BF详细的原理参考我之前写的文章:布隆过滤器(Bloom Filter)的原理和实现

    建表

    用户有价值的信息包括用户名、简介、行业、院校、专业及在平台上活动的数据比如回答数、文章数、提问数、粉丝数等等。

    用户信息存储的表结构如下:

    CREATE DATABASE `zhihu_user` /*!40100 DEFAULT CHARACTER SET utf8 */; `t_user` ( `uid` bigint(20) unsigned NOT NULL AUTO_INCREMENT, `username` , `brief_info` varchar(400) COMMENT '个人简介', `industry` varchar(50) COMMENT '所处行业', `education` varchar(50) COMMENT '毕业院校', `major` varchar(50) COMMENT '主修专业', `answer_count` , `article_count` , `ask_question_count` , `collection_count` , `follower_count` , `followed_count` , `follow_live_count` , `follow_topic_count` , `follow_column_count` , `follow_question_count` , `follow_collection_count` , `gmt_create` datetime , `gmt_modify` , PRIMARY KEY (`uid`) ) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='用户基本信息表';

    网页下载后通过XPath进行解析,提取用户各个维度的数据,最后保存到数据库中。

    反爬虫策略应对-Headers

     

    1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。

    相关文章
    • C#码农的大数据之路 - 使用C#编写MR作业 - hystar

      C#码农的大数据之路 - 使用C#编写MR作业 - hystar

      2017-06-08 08:00

    • TensorFlowSharp入门使用C#编写TensorFlow人工智能应用 - LineZero

      TensorFlowSharp入门使用C#编写TensorFlow人工智能应用 - LineZero

      2017-05-24 08:00

    • Omi树组件omi-tree编写指南 - 【当耐特】

      Omi树组件omi-tree编写指南 - 【当耐特】

      2017-05-02 15:04

    • Python爬虫基础 - VoidKing

      Python爬虫基础 - VoidKing

      2017-01-23 11:00

    网友点评
    t