当前位置:首页 » 《休闲阅读》 » 正文

Python爬虫--高性能的异步爬虫(五)_HG0724的博客

4 人参与  2022年02月08日 13:59  分类 : 《休闲阅读》  评论

点击全文阅读


文章目录

  • 文章知识点
  • 一、异步爬虫概述
  • 二、线程池的基本使用
  • 三、异步爬取线程池案例使用⭐⭐
    • 3.1 代码
    • 3.2 代码讲解
  • 四、协程概念
    • 4.1 单线程+异步协程(推荐)
    • 4.2 单任务协程
    • 4.3 多任务协程
      • 测试代码
      • 应用案例
      • aiohttp模块
  • 总结

文章知识点

  1. 单线程、多线程
  2. 线程池
  3. 单协程、多协程
  4. headers中Refere的作用
  5. 异步模块aiohttp使用

一、异步爬虫概述

高性能异步爬虫 :在爬虫中使用异步实现高性能的数据爬取操作

传统爬取数据的操作是顺序操作,下面看一个实例

  • 代码
    在这里插入图片描述
    在这里插入图片描述

分析上述代码可知 for循环中的get方法会阻塞程序,只有请求到的数据获取后,才可以进行下一条url中对应的数据

上述可知,使用异步会提高爬虫程序的数据获取效率

  • 异步爬虫的方式
  • 多线程,多进程
    好处:可以为相关阻塞的操作单独开启线程或进程,阻塞操作就可以异步进行
    弊端:无法无限制的开启多线程或者多进程
  • 线程池、进程池(适当的使用)
    好处:我们可以降低系统对进程或者线程创建和销毁的一个频率,从而很好的降低系统的开销
    弊端:池中线程或进程的数量是有上限的。

二、线程池的基本使用

  • 单线程串行方式使用
import time
# 单线程串行方式运行

def get_page(str):
	print("正在下载:",str)
	time.sleep(2)
	print("下载成功:",str)
name_list = ['xiaozi','aa','bb','cc']

start_time = time.time()

for i in range(len(name_list)):
	get_page(name_list[i])

end_time = time.time()

print('%d second' % (end_time - start_time))

在这里插入图片描述

  • 线程池的使用
import time
# 导入线程池模块对应的类
from multiprocessing.dummy import Pool
# 使用线程池方式执行
# Pool一定是应用在阻塞操作中的  get_page

start_time = time.time()
def get_page(str):
	print("正在下载:",str)
	time.sleep(2)
	print("下载成功:",str)
name_list = ['xiaozi','aa','bb','cc']

# 实例化一个线程池对象
pool = Pool(4)  # 4个线程对象
# 将列表中每一个列表元素传递给get_page进行处理
# pool.map的返回值就是方法get_page()的返回值
pool.map(get_page,name_list)

end_time = time.time()
print(end_time-start_time)

在这里插入图片描述


三、异步爬取线程池案例使用⭐⭐

本例爬取梨视频网站:梨视频官网

在这里插入图片描述

以上视频是我们需要爬取的具体视频,键盘上F12查看并且分析相关的detail_url和name,

  • 信息分析
    在这里插入图片描述
    在这里插入图片描述

在这里插入图片描述

到此你可能认为使用xpath进行地址获取下载即可,但是这样就错了,你使用etree进行解析出来的是空值,因为这个页面的有些数据就是动态加载出来的,如下进行验证:

在这里插入图片描述

到此为止,我们发现数据是动态加载出来的,因此我们就需要找出真正要下载的地址链接在哪里?
在此感谢这两位博主提供的思路:

  1. python爬虫-线程池案例(梨视频短视频爬取)
  2. [python]梨视频生活板块最热视频爬取

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

  • 地址信息对比
  • 报错404:
    https://video.pearvideo.com/mp4/adshort/20210927/1632790695959-15774345_adpkg-ad_hd.mp4
  • 正确的路径:
    https://video.pearvideo.com/mp4/adshort/20210927/cont-1742572-15774345_adpkg-ad_hd.mp4

此外多次实验发现获取报错404地址的网址有一部分数字是随机产生的,

在这里插入图片描述

  • 真实信息地址
    在这里插入图片描述
    在这里插入图片描述
  • 宝藏老师|数学老师的浪漫:用函数讲述自己的爱情故事:
    https://www.pearvideo.com/videoStatus.jsp?contId=1742617&mrd=0.6446715186101781
  • 小伙肿瘤医院旁开共享厨房,宣传5元吃饱亏本运营:
    https://www.pearvideo.com/videoStatus.jsp?contId=1742572&mrd=0.5091336020577668

通过以上两个视频的地址不难发现它们网址都有共同的特点包含contId,我们再回到原始的视频网页数据查看:

在这里插入图片描述
在这里插入图片描述

后来由于个人水平问题这个属性值解析出错,因此换了思路:

在这里插入图片描述

  • 解析地址
    在这里插入图片描述
https://www.pearvideo.com/videoStatus.jsp?contId=1742572&mrd=0.8749545784196235
https://www.pearvideo.com/videoStatus.jsp?contId=1742572&mrd=0.5510063831062151
https://www.pearvideo.com/videoStatus.jsp?contId=1742572&mrd=0.5091336020577668

3.1 代码

  • 源代码
import requests
from lxml import etree
import random
import json
from multiprocessing.dummy import Pool

# 需求:安去梨视频的视频数据
headers = {
    'User-Agent':'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/90.0.4430.72 Safari/537.36'
}

# 原则:线程池处理的是阻塞且耗时的操作

# 对下述url发起请求解析出视频详情页的url和视频的名称
url = "https://www.pearvideo.com/"

page_text = requests.get(url=url, headers=headers).text

tree = etree.HTML(page_text)
# xpath返回的是列表  ['video_1742557']

all_addresses = tree.xpath("//div[@id='vervideoTlist']//a[@class='vervideo-lilink actplay']/@href")
# print(all_addresses)
# ['video_1742557', 'video_1742534', 'video_1742545', 'video_1733739', 'video_1718659']
all_names = tree.xpath('//div[@id="vervideoTlist"]//div[@class="vervideo-name"]/text()')
# print(all_names)

urls = []
for i in range(len(all_addresses)):
    
    video_url = 'https://www.pearvideo.com/' + all_addresses[i]
    mp4_name = all_names[i] + '.mp4'
    
    video_page_text = requests.get(url=video_url,headers=headers).text
    video_tree = etree.HTML(video_page_text)
    
    # https://www.pearvideo.com/videoStatus.jsp?contId=1742572&mrd=0.8749545784196235
    contId = video_tree.xpath('//div[@class="fav"]/@data-id')[0]
    # print(contId)
    mrd = random.random()  #  random.random()  0.5330239801324711
    new_headers={
        'Referer':video_url,
        'User-Agent':'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/90.0.4430.72 Safari/537.36'
    }

    ajax_url = 'https://www.pearvideo.com/videoStatus.jsp?contId='+str(contId)+'&mrd='+str(mrd)

    real_video_content = requests.get(url=ajax_url,headers=new_headers).text # 返回的是json字符串
    
    # 获取伪地址
    false_video_url = eval(real_video_content)['videoInfo']['videos']['srcUrl'] 
    # 获取真地址
    old=false_video_url.split('/')[-1].split('-')[0]    
    new='cont-'+str(contId)
    true_video_url=false_video_url.replace(old,new)

    dic = {
        'name':mp4_name,
        'video_url':true_video_url
    }
    urls.append(dic)

#使用线程池对数据视频进行请求
def get_video_data(dic):
    print(dic['name']+'开始下载.....')
    data_url=dic['video_url']

    data=requests.get(url=data_url,headers=headers).content
    with open(dic['name'],'wb') as f:
        f.write(data)
        print(dic['name']+'下载成功')

pool=Pool(4)
pool.map(get_video_data,urls)
 
pool.close()# 关闭pool,使其不在接受新的(主进程)任务
pool.join() # 主进程阻塞后,让子进程继续运行完成,子进程运行完后,再把主进程全部关掉

# print(video_url,mp4_name):
# https://www.pearvideo.com/video_1742572 小伙肿瘤医院旁开共享厨房,宣传5元吃饱亏本运营.mp4
# https://www.pearvideo.com/video_1742617 宝藏老师|数学老师的浪漫:用函数讲述自己的爱情故事.mp4
# https://www.pearvideo.com/video_1742606 每一帧都如梦境!航拍神农架绝美秋季,云雾浩渺红架绝美秋季,云雾浩渺红叶争艳.mp4
# https://www.pearvideo.com/video_1740575 89岁浙大教师拾破烂9年,  金全部捐助贫困生.mp4  资金全部捐助贫困生.mp4                                          丘菜刀吗?18道工序,手 
# https://www.pearvideo.com/video_1727677 听说过章丘铁锅,听说过章丘菜刀吗?18道工序,手工锻打.mp4
  • 运行结果
    在这里插入图片描述
    在这里插入图片描述

3.2 代码讲解

  • 随机数

返回随机生成的一个实数,它在[0,1)范围内

>>> import random
>>> random.random()
0.5330239801324711
  • Referer的含义

Referer是HTTP请求Header的一部分,当浏览器向Web服务器发送请求的时候,请求头信息一般需要包含Referer。
该Referer会告诉服务器我是从哪个页面链接过来的,服务器基此可以获得一些信息用于处理。

Referer作用是什么?

  1. 防盗链
    比如办事通服务器只允许网站访问自己的静态资源,那服务器每次都需要判断Referer的值是否是>zwfw.yn.gov.cn,如果是就继续访问,不是就拦截。
  2. 防止恶意请求
    比如静态请求是.html结尾的,动态请求是.shtml,那么所有的*.shtml请求,必须 Referer为我自己的>网站才可以访问,这就是Referer的作用。

参考链接

  1. 关于Http请求header之Referer
  2. Headers之Referer设置⭐⭐
  • 获取真正的地址

切片目的:获取地址中需要替换的内容

报错404:https://video.pearvideo.com/mp4/adshort/20210927/1632790695959-15774345_adpkg-ad_hd.mp4
正确的路径:https://video.pearvideo.com/mp4/adshort/20210927/cont-1742572-15774345_adpkg-ad_hd.mp4
# 获取真地址
old=false_video_url.split('/')[-1].split('-')[0]    
new='cont-'+str(contId)
true_video_url=false_video_url.replace(old,new)
>>> url = "https://video.pearvideo.com/mp4/adshort/20210927/1632790695959-15774345_adpkg-ad_hd.mp4"
>>> url.split('/')
['https:', '', 'video.pearvideo.com', 'mp4', 'adshort', '20210927', '1632790695959-15774345_adpkg-ad_hd.mp4']
>>> str = url.split('/')[-1]
>>> str
'1632790695959-15774345_adpkg-ad_hd.mp4'
>>> str.split('-')
['1632790695959', '15774345_adpkg', 'ad_hd.mp4']
>>> str.split('-')[0]
'1632790695959'
>>>
  • 处理json字符串
print('-----eval-----')
print(eval(real_video_content))
print('-----json.loads()-----')
print(json.loads(real_video_content))
-----eval-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': 'c44f6eb1-971a-410a-9959-a92d2afeb05f', 'systemTime': '1632799446578', 'videoInfo': {'playSta': '1', 'video_image': 'https://image2.pearvideo.com/cont/20210927/cont-1742572-12624944.jpg', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210927/1632799446578-15774345_adpkg-ad_hd.mp4'}}}
-----json.loads()-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': 'c44f6eb1-971a-410a-9959-a92d2afeb05f', 'systemTime': '1632799446578', 'videoInfo': {'playSta': '1', 'video_image': 'https://image2.pearvideo.com/cont/20210927/cont-1742572-12624944.jpg', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210927/1632799446578-15774345_adpkg-ad_hd.mp4'}}}
-----eval-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': 'e488637c-0200-41f0-a259-9493913f1d11', 'systemTime': '1632799446898', 'videoInfo': {'playSta': '1', 'video_image': 'https://image1.pearvideo.com/cont/20210927/cont-1742617-12625072.jpg', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210927/1632799446898-15774709_adpkg-ad_hd.mp4'}}}
-----json.loads()-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': 'e488637c-0200-41f0-a259-9493913f1d11', 'systemTime': '1632799446898', 'videoInfo': {'playSta': '1', 'video_image': 'https://image1.pearvideo.com/cont/20210927/cont-1742617-12625072.jpg', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210927/1632799446898-15774709_adpkg-ad_hd.mp4'}}}
-----eval-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': 'b2b607e8-9685-4f3f-8c16-e10aedad97d0', 'systemTime': '1632799447261', 'videoInfo': {'playSta': '1', 'video_image': 'https://image2.pearvideo.com/cont/20210927/cont-1742606-12625013.png', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210927/1632799447261-15774653_adpkg-ad_hd.mp4'}}}
-----json.loads()-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': 'b2b607e8-9685-4f3f-8c16-e10aedad97d0', 'systemTime': '1632799447261', 'videoInfo': {'playSta': '1', 'video_image': 'https://image2.pearvideo.com/cont/20210927/cont-1742606-12625013.png', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210927/1632799447261-15774653_adpkg-ad_hd.mp4'}}}
-----eval-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': '16929bb3-257e-4c01-94df-4343a42b99d9', 'systemTime': '1632799447584', 'videoInfo': {'playSta': '1', 'video_image': 'https://image1.pearvideo.com/cont/20210227/cont-1721628-12558949.png', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210227/1632799447584-15618162_adpkg-ad_hd.mp4'}}}
-----json.loads()-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': '16929bb3-257e-4c01-94df-4343a42b99d9', 'systemTime': '1632799447584', 'videoInfo': {'playSta': '1', 'video_image': 'https://image1.pearvideo.com/cont/20210227/cont-1721628-12558949.png', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210227/1632799447584-15618162_adpkg-ad_hd.mp4'}}}
-----eval-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': '34db5053-02f9-40c1-98c8-4d83a0e7d50f', 'systemTime': '1632799447961', 'videoInfo': {'playSta': '1', 'video_image': 'https://image.pearvideo.com/cont/20210521/cont-1729993-12587145.png', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210521/1632799447961-15678629_adpkg-ad_hd.mp4'}}}
-----json.loads()-----
{'resultCode': '1', 'resultMsg': 'success', 'reqId': '34db5053-02f9-40c1-98c8-4d83a0e7d50f', 'systemTime': '1632799447961', 'videoInfo': {'playSta': '1', 'video_image': 'https://image.pearvideo.com/cont/20210521/cont-1729993-12587145.png', 'videos': {'hdUrl': '', 'hdflvUrl': '', 'sdUrl': '', 'sdflvUrl': '', 'srcUrl': 'https://video.pearvideo.com/mp4/adshort/20210521/1632799447961-15678629_adpkg-ad_hd.mp4'}}}

通过以上测试不难发现json.loads()方式和eval方式都可以将json处理为相同的结果,但是既然是不同的方法,终究会有区别

  1. python处理json字符串(使用json.loads而不是eval())
  2. Python 中的json字符串以及使用
  3. 使用python解析Json字符串-获取Json字符串关键字⭐

四、协程概念

4.1 单线程+异步协程(推荐)

event_loop:事件循环,相当于一个无限循环,我们可以把一些函数注册到这个事件循环上,当满足某些条件的时候,函数就会被循环执行
coroutine:协程对象,我们可以将协程对象注册到事件循环中,它会被事件循环调用。我们可以使用async关键字来定义一个方法,这个方法在调用时不会立即被执行,而是返回一个协程对象。
task:任务,它是对协程对象的进一步封装,包含了任务的各个状态。
future:代表将来执行或还没有执行的任务,实际上和task没有本质区别。
async:定义一个协程
await:用来挂起阻塞方法的执行。

4.2 单任务协程

  • async的使用
import asyncio # 提供async、await关键字

async   def request(url):
    print('正在请求的url是',url)
    print('请求成功,',url)

# async修饰的函数,调用之后返回一个协程对象
c = request('www.baidu.com')

# 创建一个事件循环对象
loop  = asyncio.get_event_loop()

# 将协程对象注册到loop中,然后启动loop
loop.run_until_complete(c) # run_until_complete即可以实现注册又可以启动
正在请求的url是 www.baidu.com
请求成功, www.baidu.com
  • task的使用
import asyncio # 提供async、await关键字

async   def request(url):
    print('正在请求的url是',url)
    print('请求成功,',url)

# async修饰的函数,调用之后返回一个协程对象
c = request('www.baidu.com')

loop = asyncio.get_event_loop()
# 基于loop创建了一个task对象
task = loop.create_task(c)  # 需要封装协程对象
print(task) # 协程状态还未被执行
loop.run_until_complete(task)
print(task) # 协程状态已经被执行
<Task pending coro=<request() running at f:/python/python2021/python_spider/第三章:异步爬虫/2.协程应用.py:3>>
正在请求的url是 www.baidu.com
请求成功, www.baidu.com
<Task finished coro=<request() done, defined at f:/python/python2021/python_spider/第三章 :异步爬虫/2.协程应用.py:3> result=None>
  • future的使用
import asyncio # 提供async、await关键字

async   def request(url):
    print('正在请求的url是',url)
    print('请求成功,',url)

# async修饰的函数,调用之后返回一个协程对象
c = request('www.baidu.com')

loop = asyncio.get_event_loop()
task = asyncio.ensure_future(c) # 需要封装协程对象
print(task)
loop.run_until_complete(task)
print(task)
<Task pending coro=<request() running at f:/python/python2021/python_spider/第三章:异步爬虫/2.协程应 
用.py:3>>
正在请求的url是 www.baidu.com
请求成功, www.baidu.com
<Task finished coro=<request() done, defined at f:/python/python2021/python_spider/第三章:异步爬虫/2.协程应用.py:3> result=None>
  • 回调函数
import asyncio # 提供async、await关键字

async   def request(url):
    print('正在请求的url是',url)
    print('请求成功,',url)
    return url

# async修饰的函数,调用之后返回一个协程对象
c = request('www.baidu.com')


def callback_func(task):
    # result返回的就是任务对象中所封装的协程对象对应函数的返回值
    print(task.result())
    
# 绑定回调
loop = asyncio.get_event_loop()
task = asyncio.ensure_future(c)
# 将回调函数被绑定到任务对象中
task.add_done_callback(callback_func)
loop.run_until_complete(task)
# 正在请求的url是 www.baidu.com
# 请求成功, www.baidu.com
# www.baidu.com

4.3 多任务协程

测试代码

协程应用中的案例是单任务的,只是创建了一个协程对象,将该协程对象封装到了一个任务之中,将这一个任务对象注册到了一个事件循环当中

  • 多任务协程
import asyncio
import time

async def request(url):
    print('正在下载',url)
    time.sleep(2) # 这是一个同步模块代码
    print('下载完毕',url)

start = time.time()
urls = {
    'www.baidu.com',
    'www.sogou.com',
    'www.goubanjia.com'
}
# 任务列表:存放多个任务对象
stasks = []
for url in urls:
    c = request(url)
    task = asyncio.ensure_future(c)
    stasks.append(task)
# 创建一个事件循环对象
loop = asyncio.get_event_loop()
# 需要将任务列表封装到wait中
loop.run_until_complete(asyncio.wait(stasks))

print(time.time() - start)
正在下载 www.goubanjia.com
下载完毕 www.goubanjia.com
正在下载 www.sogou.com
下载完毕 www.sogou.com
正在下载 www.baidu.com
下载完毕 www.baidu.com
6.008122205734253
  • 记过发现程序是同步执行,这是为什么?
    原因出现在time.sleep(2), 在异步协程中如果出现了同步模块相关的代码,那么无法实现异步
  • 使用异步模块阻塞挂起
import asyncio
import time

async def request(url):
    print('正在下载',url)
    # 在异步协程中如果出现了同步模块相关的代码,那么无法实现异步
    # time.sleep(2) # 这是一个同步模块代码

    # 当在asyncio中遇到阻塞操作必须进行手动挂起
    await asyncio.sleep(2) # 这是一个异步模块代码
    print('下载完毕',url)

start = time.time()
urls = {
    'www.baidu.com',
    'www.sogou.com',
    'www.goubanjia.com'
}
# 任务列表:存放多个任务对象
stasks = []
for url in urls:
    c = request(url)
    task = asyncio.ensure_future(c)
    stasks.append(task)
# 创建一个事件循环对象
loop = asyncio.get_event_loop()
# 需要将任务列表封装到wait中
loop.run_until_complete(asyncio.wait(stasks))

print(time.time() - start)
正在下载 www.baidu.com
正在下载 www.goubanjia.com
正在下载 www.sogou.com
下载完毕 www.baidu.com
下载完毕 www.goubanjia.com
下载完毕 www.sogou.com
2.0053040981292725

应用案例

  • 搭建Flask服务
    在这里插入图片描述
  1. 多任务异步协程爬虫
import requests
import asynico
import time

start = time.time()
urls = [
	'http://127.0.0.1:5000/bobo',
	'http://127.0.0.1:5000/jay',
	'http://127.0.0.1:5000/tom'
]

async def get_page(url):
	print('正在下载',url)
	# requests是基于同步的,必须使用基于异步的网络请求模块进行指定url的请求发送
	# aiohttp:基于异步网络请求的模块
	response = requests.get(url=url) # 这是基于同步模块的代码
	print('下载完毕',response.text)
# 使用async修饰,调用get_page会返回协程对象	
tasks = []

for url in urls:
	c = get_page(url)
	task = asyncio.ensure_future(c) # 将协程对象封装到任务对象当中
	tasks.append(task)

loop = asyncio.get_event_loop() # 创建循环事件
loop.run_until_complete(asyncio.wait(tasks))

end = time.time()

print('总耗时:',end-start)

分析耗时时常:查看Flask服务文件可以发起请求2秒即可,一共发起三个,若是串行应该是6秒,异步2秒。

在这里插入图片描述

为什么没有实现异步?
是由于出现了同步模块的使用:requsets.get()方法。
aiohttp:基于异步网络请求的模块

在异步协程中如果出现了同步模块相关的代码,那么无法实现异步!

aiohttp模块

  1. 环境安装

pip install aiohttp
使用该模块中的ClientSession

  1. 主要代码
# get()、post():
# headers,params[get] / data[post],proxy='http://ip:port'

async def get_page(url):
	async with aiohttp.ClientSession() as session:
	async with await session.get(url) as response:#response响应对象
	# text()返回字符串形式的响应数据
	# read()返回的是二进制形式响应数据
	# json()饭hi的是json对象
	# 注意:获取响应数据操作之前一定要使用await进行手动挂起
	page_text = await response.text()
	print(page_text)
  • 结果
  1. page_text = response.text()
  2. page_text = await response.text()
    在这里插入图片描述

总结

  1. xpath获取不到想要的属性数据

有小伙伴知道的,留言告诉我,谢谢大家!

在这里插入图片描述
在这里插入图片描述
2. Refere的作用
在这里插入图片描述


点击全文阅读


本文链接:http://zhangshiyu.com/post/34424.html

请求  对象  线程  
<< 上一篇 下一篇 >>

  • 评论(0)
  • 赞助本站

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。

关于我们 | 我要投稿 | 免责申明

Copyright © 2020-2022 ZhangShiYu.com Rights Reserved.豫ICP备2022013469号-1