【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

相关文章

Python中Json和其他类型相互转换的实现示例

《Python中Json和其他类型相互转换的实现示例》本文介绍了在Python中使用json模块实现json数据与dict、object之间的高效转换,包括loads(),load(),dumps()... 项目中经常会用到json格式转为object对象、dict字典格式等。在此做个记录,方便后续用到该方

从基础到高级详解Python数值格式化输出的完全指南

《从基础到高级详解Python数值格式化输出的完全指南》在数据分析、金融计算和科学报告领域,数值格式化是提升可读性和专业性的关键技术,本文将深入解析Python中数值格式化输出的相关方法,感兴趣的小伙... 目录引言:数值格式化的核心价值一、基础格式化方法1.1 三种核心格式化方式对比1.2 基础格式化示例

Python与MySQL实现数据库实时同步的详细步骤

《Python与MySQL实现数据库实时同步的详细步骤》在日常开发中,数据同步是一项常见的需求,本篇文章将使用Python和MySQL来实现数据库实时同步,我们将围绕数据变更捕获、数据处理和数据写入这... 目录前言摘要概述:数据同步方案1. 基本思路2. mysql Binlog 简介实现步骤与代码示例1

Python ORM神器之SQLAlchemy基本使用完全指南

《PythonORM神器之SQLAlchemy基本使用完全指南》SQLAlchemy是Python主流ORM框架,通过对象化方式简化数据库操作,支持多数据库,提供引擎、会话、模型等核心组件,实现事务... 目录一、什么是SQLAlchemy?二、安装SQLAlchemy三、核心概念1. Engine(引擎)

Ubuntu如何升级Python版本

《Ubuntu如何升级Python版本》Ubuntu22.04Docker中,安装Python3.11后,使用update-alternatives设置为默认版本,最后用python3-V验证... 目China编程录问题描述前提环境解决方法总结问题描述Ubuntu22.04系统自带python3.10,想升级

基于C#实现PDF转图片的详细教程

《基于C#实现PDF转图片的详细教程》在数字化办公场景中,PDF文件的可视化处理需求日益增长,本文将围绕Spire.PDFfor.NET这一工具,详解如何通过C#将PDF转换为JPG、PNG等主流图片... 目录引言一、组件部署二、快速入门:PDF 转图片的核心 C# 代码三、分辨率设置 - 清晰度的决定因

Python自动化处理PDF文档的操作完整指南

《Python自动化处理PDF文档的操作完整指南》在办公自动化中,PDF文档处理是一项常见需求,本文将介绍如何使用Python实现PDF文档的自动化处理,感兴趣的小伙伴可以跟随小编一起学习一下... 目录使用pymupdf读写PDF文件基本概念安装pymupdf提取文本内容提取图像添加水印使用pdfplum

Python 基于http.server模块实现简单http服务的代码举例

《Python基于http.server模块实现简单http服务的代码举例》Pythonhttp.server模块通过继承BaseHTTPRequestHandler处理HTTP请求,使用Threa... 目录测试环境代码实现相关介绍模块简介类及相关函数简介参考链接测试环境win11专业版python

Python从Word文档中提取图片并生成PPT的操作代码

《Python从Word文档中提取图片并生成PPT的操作代码》在日常办公场景中,我们经常需要从Word文档中提取图片,并将这些图片整理到PowerPoint幻灯片中,手动完成这一任务既耗时又容易出错,... 目录引言背景与需求解决方案概述代码解析代码核心逻辑说明总结引言在日常办公场景中,我们经常需要从 W

基于Python实现自动化邮件发送系统的完整指南

《基于Python实现自动化邮件发送系统的完整指南》在现代软件开发和自动化流程中,邮件通知是一个常见且实用的功能,无论是用于发送报告、告警信息还是用户提醒,通过Python实现自动化的邮件发送功能都能... 目录一、前言:二、项目概述三、配置文件 `.env` 解析四、代码结构解析1. 导入模块2. 加载环