【python 异步编程】10分钟快速入门aiohttp教程

2024-09-07 06:08

本文主要是介绍【python 异步编程】10分钟快速入门aiohttp教程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

无意中发现了一个巨牛的人工智能教程,忍不住分享一下给大家。教程不仅是零基础,通俗易懂,而且非常风趣幽默,像看小说一样!觉得太牛了,所以分享给大家。点这里可以跳转到教程。人工智能教程

一、先搞清楚什么是同步编程和异步编程?

同步编程:接到上峰指令:有两件事当天要处理完成,越快越好。那么同步是怎么工作呢,第一时间接到指令后,先处理第一件事情,等第一件事情做完了,再做第二件事情,通俗讲就是有点类似工厂的流水线啦,比较鸡肋,得先处理第一件事,才能腾出时间处理第二件事情,分身乏术阿。
异步编程:接到上峰指令:有两件事当天要处理完成,越快越好。那么异步又是如何工作呢,第一时间接到指令后,第一件事情和第二件事同时并发处理,互不影响,哪件事情处理好了立马返回结果。可见异步的最慢速度,也就是耗时最长的那个任务。这么一看,异步优势很明显嘛。异步编程速度远远高于同步编程,简直堪称是编程处理的神器啊。由此可见,学习异步编程,可以加快代码处理速度。加快服务响应速度。分身有术哦。

二、什么是aiohttp?
平时大家用requests发起请求,获取响应结果,这是一个同步请求,同步编程的一种,用的flask也是同步编程一种。那么aiohttp这个异步编程又是什么东西呢?
aiohttp是一个为Python提供异步HTTP 客户端/服务端编程,基于asyncio(Python用于支持异步编程的标准库)的异步库。

核心功能:

  • 同时支持客户端使用和服务端使用。
  • 同时支持服务端WebSockets组件和客户端WebSockets组件,开箱即用呦。
  • web服务器具有中间件,信号组件和可插拔路由的功能。

三、如何安装aiohttp?

pip install aiohttp

四、快速开始吧!

python版本要求python3.5及以上版本哦。
客服端例子:

import aiohttp
import asyncio
import async_timeoutasync def fetch(session, url):with async_timeout.timeout(10):async with session.get(url) as response:return await response.text()async def main():async with aiohttp.ClientSession() as session:html = await fetch(session, 'http://python.org')print(html)loop = asyncio.get_event_loop()
loop.run_until_complete(main())

web服务端例子:


from aiohttp import webasync def handle(request):name = request.match_info.get('name', "Anonymous")text = "Hello, " + namereturn web.Response(text=text)app = web.Application()
app.router.add_get('/', handle)
app.router.add_get('/{name}', handle)web.run_app(app)

本地浏览器访问地址:http://127.0.0.1:8080/,即可得到返回结果:

Hello, Anonymous

想写一个异步服务的 hello,world 咋写呢,也简单:

from aiohttp import webasync def index(request):return web.Response(text="hello,world!")app = web.Application()
# 添加路由
app.router.add_get('/', index)web.run_app(app, host='127.0.0.1', port=8080)

aiohttp的服务端程序都是 aiohttp.web.Application实例对象。用于创建信号,连接路由等。

客服端访问,得到相应结果测试例子:


# -*- coding:utf-8 -*-
import asyncio
from aiohttp import ClientSessionasync def fetch(session, url):async with session.get(url) as response:return await response.text()async def get_html(url):async with ClientSession() as session:html = await fetch(session,url)print(html)url='http://127.0.0.1:8080/'
loop = asyncio.get_event_loop()
loop.run_until_complete(get_html(url))
loop.close()

运行结果:

hello,world!Process finished with exit code 0

get方式和post方式都采用的例子:


# -*- coding:utf-8 -*-
from aiohttp import web
import json# get请求
async def index(request):return web.Response(text="hello,world!")# post请求
async def post_handler(request):data = await request.post()print(data)name = data['name']age = data['age']print(name,age)result = {"name": "赖德发", "sex": "男", "wechat":"laidefa"}return web.Response(text=json.dumps(result,ensure_ascii=False))app = web.Application()app.router.add_get('/', index)
app.router.add_post('/post', post_handler)web.run_app(app, host='127.0.0.1', port=8080)

客户端获取响应结果:发起get请求和post请求:


# -*- coding:utf-8 -*-
import asyncio
from aiohttp import ClientSessionasync def get_fetch(session, url):async with session.get(url) as response:return await response.text()async def get_html(url):async with ClientSession() as session:html = await get_fetch(session,url)print(html)async def post_fetch(session, url):form_data = {"name": "张三", "age": "22"}async with session.post(url,data=form_data) as response:return await response.text()async def post_html(url):async with ClientSession() as session:html=await post_fetch(session,url)print(html)if __name__ == '__main__':get_url='http://127.0.0.1:8080'post_url='http://127.0.0.1:8080/post'loop = asyncio.get_event_loop()loop.run_until_complete(post_html(post_url))loop.run_until_complete(get_html(get_url))loop.close()# 第二种方式也可以
# if __name__ == '__main__':
#     get_url='http://127.0.0.1:8080'
#     post_url='http://127.0.0.1:8080/post'
#     loop = asyncio.get_event_loop()
# 
#     tasks=[]
# 
#     task1 = asyncio.ensure_future(get_html(get_url))
#     task2 = asyncio.ensure_future(post_html(post_url))
#     tasks.append(task1)
#     tasks.append(task2)
#     loop.run_until_complete(asyncio.wait(tasks))
#     loop.close()

运行结果:

{"wechat": "laidefa", "name": "赖德发", "sex": "男"}
hello,world!Process finished with exit code 0

这篇关于【python 异步编程】10分钟快速入门aiohttp教程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/1144268

相关文章

Conda与Python venv虚拟环境的区别与使用方法详解

《Conda与Pythonvenv虚拟环境的区别与使用方法详解》随着Python社区的成长,虚拟环境的概念和技术也在不断发展,:本文主要介绍Conda与Pythonvenv虚拟环境的区别与使用... 目录前言一、Conda 与 python venv 的核心区别1. Conda 的特点2. Python v

Python使用python-can实现合并BLF文件

《Python使用python-can实现合并BLF文件》python-can库是Python生态中专注于CAN总线通信与数据处理的强大工具,本文将使用python-can为BLF文件合并提供高效灵活... 目录一、python-can 库:CAN 数据处理的利器二、BLF 文件合并核心代码解析1. 基础合

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

Python中你不知道的gzip高级用法分享

《Python中你不知道的gzip高级用法分享》在当今大数据时代,数据存储和传输成本已成为每个开发者必须考虑的问题,Python内置的gzip模块提供了一种简单高效的解决方案,下面小编就来和大家详细讲... 目录前言:为什么数据压缩如此重要1. gzip 模块基础介绍2. 基本压缩与解压缩操作2.1 压缩文

Python设置Cookie永不超时的详细指南

《Python设置Cookie永不超时的详细指南》Cookie是一种存储在用户浏览器中的小型数据片段,用于记录用户的登录状态、偏好设置等信息,下面小编就来和大家详细讲讲Python如何设置Cookie... 目录一、Cookie的作用与重要性二、Cookie过期的原因三、实现Cookie永不超时的方法(一)

Python内置函数之classmethod函数使用详解

《Python内置函数之classmethod函数使用详解》:本文主要介绍Python内置函数之classmethod函数使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录1. 类方法定义与基本语法2. 类方法 vs 实例方法 vs 静态方法3. 核心特性与用法(1编程客

从入门到精通MySQL联合查询

《从入门到精通MySQL联合查询》:本文主要介绍从入门到精通MySQL联合查询,本文通过实例代码给大家介绍的非常详细,需要的朋友可以参考下... 目录摘要1. 多表联合查询时mysql内部原理2. 内连接3. 外连接4. 自连接5. 子查询6. 合并查询7. 插入查询结果摘要前面我们学习了数据库设计时要满

Python函数作用域示例详解

《Python函数作用域示例详解》本文介绍了Python中的LEGB作用域规则,详细解析了变量查找的四个层级,通过具体代码示例,展示了各层级的变量访问规则和特性,对python函数作用域相关知识感兴趣... 目录一、LEGB 规则二、作用域实例2.1 局部作用域(Local)2.2 闭包作用域(Enclos

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os

使用Python实现可恢复式多线程下载器

《使用Python实现可恢复式多线程下载器》在数字时代,大文件下载已成为日常操作,本文将手把手教你用Python打造专业级下载器,实现断点续传,多线程加速,速度限制等功能,感兴趣的小伙伴可以了解下... 目录一、智能续传:从崩溃边缘抢救进度二、多线程加速:榨干网络带宽三、速度控制:做网络的好邻居四、终端交互