QQ登录

只需要一步,快速开始

APP扫码登录

只需要一步,快速开始

手机号码,快捷登录

手机号码,快捷登录

查看: 2402|回复: 0

[Python] 三个Python爬虫版本,各种方式爬取校花网美图

[复制链接]

等级头衔

积分成就    金币 : 2851
   泡泡 : 1516
   精华 : 6
   在线时间 : 1305 小时
   最后登录 : 2024-12-7

丰功伟绩

优秀达人突出贡献荣誉管理论坛元老活跃会员

联系方式
发表于 2021-6-2 11:09:40 | 显示全部楼层 |阅读模式
一、爬虫是什么?# @, v$ i/ o0 p+ o" g  L
       如果我们把互联网比作一张大的蜘蛛网,数据便是存放于蜘蛛网的各个节点,而爬虫就是一只小蜘蛛,沿着网络抓取自己的猎物(数据)爬虫指的是:向网站发起请求,获取资源后分析并提取有用数据的程序;从技术层面来说就是 通过程序模拟浏览器请求站点的行为,把站点返回的HTML代码/JSON数据/二进制数据(图片、视频) 爬到本地,进而提取自己需要的数据,存放起来使用。8 _  R5 b) j! e2 Z0 |/ w
二、基本环境配置8 |; V* o* ?% F- t; C
  • 版本:Python3
  • 系统:Windows
  • IDE:Pycharm; D5 ]' _3 j- F5 |$ o; y
三、爬虫所需工具:
3 g* u, }* a% C6 H4 c; h7 U
  • 请求库:requests,selenium(可以驱动浏览器解析渲染CSS和JS,但有性能劣势(有用没用的网页都会加载);)
  • 解析库:正则,beautifulsoup,pyquery
  • 存储库:文件,MySQL,Mongodb,Redis
    9 a6 @/ K6 \; ^* S, U  l8 o
四、Python爬虫基本流程
2 _$ r2 p  S- K 1.jpg
3 k* Q. P' X0 V7 H, D基础版:
  S! C3 Z5 H" j
import re
import requests

respose = requests.get ('http://www.xiaohuar.com/v/')
# print(respose.status_code) #响应的状态码
# print(respose.content) #返回字节信息
# print(respose.text)  #返回文本内容
urls=re.findall(r'class="items".*?href="(.*?)"',respose.text,re.S) #re.s 把文本信息转换成1行匹配
url=urls[5]
result=requests.get(url)
mp4_url=re.findall(r'id="media".*?src="(.*?)"',result.text,re.s)[0]

video=requests.get(mp4_url)
with open('D:\\a.mp4,'wb') as f:
    f.write(video.content)
函数封装版:
, v! L5 Z7 I* o+ o6 Q8 ~
import re
import requests 
import hashlib
import time

def get_index(url):
    respose = requests.get(url)
    if respose.status_code==200:
        return respose . text

def parse_index(res):
    urls = re.findall(r'class="itens".*?href="(.*?)"',res,re.S) # re.S 把文本信息转换成1行匹配
    return urls

def get_detail(urls):
    For url in urls
        if not url.startswith('http'):
            url='http://www.xiaohuar.com%s' %url
        result = requests.get(url)
        if result.status_code = 200 :
            mp4_url_list = re.findall(r'id="media".*?src="(.*?)"',result.text,re.S)
            if mp4_url_list:
                mp4_url=mp4_url_list[0]
                print(mp4_url)
                # save mp4_url)
                
def save(url):
    video = requests.get(url)
    if video.status_code==200:
        m=hashlib.md5()
        m.updata(url.encode('utf-8'))
        m.updata(str(time.time()).encode('utf-8')
        filename=r'%s.mp4'% m.hexdigest()
        filepath=r'D:\\%s'%filename
        with open(filepath,'wb') as f:
            f.write(video.content)
            
def main():
    for i in range(5):
        res1 = get_index('http://www.xiaohuar.com/list-3-%s.html'% i )
        res2 = parse_index(res1)
        get_detail(res2)
if __name__ == '__main__':
    main()
并发版
7 Z1 J& N4 t# [& j5 b" Z; e% M(如果一共需要爬30个视频,开30个线程去做,花的时间就是其中最慢那份的耗时时间)' W  Q6 b4 _# O" g  [
import re
import requests
import hashlib
import time
from concurrent.futures import ThreadPoolExecutor
p=ThreadPoolExecutor(30)  #创建1个程池中,容纳线程个数为30个;

def get_index(url):
    respose = requests.get(url)
    if respose.status_code==200:
        respose.text

def parse_index(res):
    res=res.result() #进程执行完毕后,得到1个对象
    urls = re.findall(r'class="items".*?href="(.*?)"',res,re.S) #re.s 把文本信息转换成1行匹配 
    for url in urls:
        p.submit(get_detail(url)) #获取详情页 提交到线程池
        
def get_detail(url): #只下载1个视频
        if not url.startswith('http'): 
            url='http://www.xiaohuar.com%s' %url
        result = requests.get(url)
        if result.status_code==200 :
            mp4_url_.findall(r'id="media".*?src="(.*?)"',result.text,re.S)
            if mp4_url_list:
                mp4_url=mp4_url_list[0]
                print(mp4_url)
                # save(mp4_url)
                
def save(url):
    video = requests.get(url)
    if video.status_code==200:
        m=hashlib.md5()
        m.updata(url.encode('utf-8'))
        m.updata(str(time.time()).encode('utf-8'))
        filename=r'%s.mp4'% m.hexdigest()
        filepath=r'D:\\%s'%filename
        with open(filepath,'wb') as f:
            f.write(video.content)
            
def main():
    for i in range(5):
        p.submit(get_index,'http://www.xiaohuar.com/list-3-%s.html'% i ).add_done_callback(parse_index)
        #1、先把爬 大牧人任务(get_index)异步提交到线程池
        #2、get_index任务执行完后,会通过回调add_done_callback()通知主线程,任务完成
        #3、把get_index执行结果(注意线程执行结果是对象,调用res=res.result()方法,才能获取真正执行结果),当做参数传给parse_index
        #4、通过循环,再次把获取详情页get_detail()任务提交到线程池执行

if  __name__ == '__main__':
    main()
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

QQ|手机版|小黑屋|paopaomj.COM ( 渝ICP备18007172号|渝公网安备50010502503914号 )

GMT+8, 2024-12-7 03:21

Powered by paopaomj X3.5 © 2016-2025 sitemap

快速回复 返回顶部 返回列表