【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

相关文章

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

python: 多模块(.py)中全局变量的导入

文章目录 global关键字可变类型和不可变类型数据的内存地址单模块(单个py文件)的全局变量示例总结 多模块(多个py文件)的全局变量from x import x导入全局变量示例 import x导入全局变量示例 总结 global关键字 global 的作用范围是模块(.py)级别: 当你在一个模块(文件)中使用 global 声明变量时,这个变量只在该模块的全局命名空

Makefile简明使用教程

文章目录 规则makefile文件的基本语法:加在命令前的特殊符号:.PHONY伪目标: Makefilev1 直观写法v2 加上中间过程v3 伪目标v4 变量 make 选项-f-n-C Make 是一种流行的构建工具,常用于将源代码转换成可执行文件或者其他形式的输出文件(如库文件、文档等)。Make 可以自动化地执行编译、链接等一系列操作。 规则 makefile文件

电脑桌面文件删除了怎么找回来?别急,快速恢复攻略在此

在日常使用电脑的过程中,我们经常会遇到这样的情况:一不小心,桌面上的某个重要文件被删除了。这时,大多数人可能会感到惊慌失措,不知所措。 其实,不必过于担心,因为有很多方法可以帮助我们找回被删除的桌面文件。下面,就让我们一起来了解一下这些恢复桌面文件的方法吧。 一、使用撤销操作 如果我们刚刚删除了桌面上的文件,并且还没有进行其他操作,那么可以尝试使用撤销操作来恢复文件。在键盘上同时按下“C

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码: 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口,https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如,在当前目录下创建一个名为 myenv 的虚拟环境: python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行: source myenv/bin/activate 3.与notebook连接 在虚拟环境中,使用 pip 安装 Jupyter 和 ipykernel: pip instal

【机器学习】高斯过程的基本概念和应用领域以及在python中的实例

引言 高斯过程(Gaussian Process,简称GP)是一种概率模型,用于描述一组随机变量的联合概率分布,其中任何一个有限维度的子集都具有高斯分布 文章目录 引言一、高斯过程1.1 基本定义1.1.1 随机过程1.1.2 高斯分布 1.2 高斯过程的特性1.2.1 联合高斯性1.2.2 均值函数1.2.3 协方差函数(或核函数) 1.3 核函数1.4 高斯过程回归(Gauss

数论入门整理(updating)

一、gcd lcm 基础中的基础,一般用来处理计算第一步什么的,分数化简之类。 LL gcd(LL a, LL b) { return b ? gcd(b, a % b) : a; } <pre name="code" class="cpp">LL lcm(LL a, LL b){LL c = gcd(a, b);return a / c * b;} 例题:

【学习笔记】 陈强-机器学习-Python-Ch15 人工神经网络(1)sklearn

系列文章目录 监督学习:参数方法 【学习笔记】 陈强-机器学习-Python-Ch4 线性回归 【学习笔记】 陈强-机器学习-Python-Ch5 逻辑回归 【课后题练习】 陈强-机器学习-Python-Ch5 逻辑回归(SAheart.csv) 【学习笔记】 陈强-机器学习-Python-Ch6 多项逻辑回归 【学习笔记 及 课后题练习】 陈强-机器学习-Python-Ch7 判别分析 【学

Java 创建图形用户界面(GUI)入门指南(Swing库 JFrame 类)概述

概述 基本概念 Java Swing 的架构 Java Swing 是一个为 Java 设计的 GUI 工具包,是 JAVA 基础类的一部分,基于 Java AWT 构建,提供了一系列轻量级、可定制的图形用户界面(GUI)组件。 与 AWT 相比,Swing 提供了许多比 AWT 更好的屏幕显示元素,更加灵活和可定制,具有更好的跨平台性能。 组件和容器 Java Swing 提供了许多