zoukankan      html  css  js  c++  java
  • 协程-爬虫示例

    from gevent import monkey;monkey.patch_all()#打补丁,使gevent识别I/O阻塞进而实现协程
    import requests,re,gevent,time
    
    
    def get_info(url):#爬网页函数
        res = requests.get(url)
        print(len(res.text))
        return res.text
    
    
    def prase(res):#解析网页数据函数
        res_name = re.findall(r'title="(?P<name>S+s?S*?)"', res)
        move_name = []
        for i in res_name[::2]:
            move_name.append(i.split('"')[0])
        move_actor = re.findall(r'主演:S+', res)#(?P<name>主演:S+)/?
    {0,1}
        for i in range(len(move_name)):
            with open('movie_info.txt','a') as f:
                f.write('电影名:%s , %s'%(move_name[i],move_actor[i].split('<')[0]))
                f.write('
    ')
    
    urls = [
        'http://maoyan.com/board/7',
        'http://maoyan.com/board/6',
        'http://maoyan.com/board/1',
        'http://maoyan.com/board/2',
        'http://maoyan.com/board/4',
    ]
    
    if __name__ == '__main__':
        start = time.time()
        # g_l = []
        for url in urls:
            # print(url)
            g = gevent.spawn(prase,get_info(url))
            # g_l.append(g)
        # gevent.joinall(g_l)
        g.join()#之所以只加一个join而不用joinall是因为主进程会等get_info(url)作为参数执行完了,主进程不会等prase执行完所以让主进程等最后一个prase即可
        print('解析结束',time.time()-start)
    没啥好解释的直接看脚本

    协程确实运行很快,轻量化,节约cpu与内存使用,可以实现高并发量(伪)

  • 相关阅读:
    CentOS6.4 安装 codeblocks-12.11
    SpringCloud 进阶之Hystrix(断路器)
    SpringCloud 进阶之Ribbon和Feign(负载均衡)
    SpringCloud 进阶之Eureka(服务注册和发现)
    SpringCloud 入门
    SpringBoot与消息(RabbitMQ)
    SpringBoot 与缓存
    SpringBoot 之数据访问
    Spring Data 之 Repository 接口
    Spring Data之Hello World
  • 原文地址:https://www.cnblogs.com/fenglin0826/p/7458689.html
Copyright © 2011-2022 走看看