Python开发从入门到精通：异步编程与协程

Ne0inhk

— 7 min read
Python开发从入门到精通：异步编程与协程

《Python开发从入门到精通》设计指南第二十一篇：异步编程与协程

在这里插入图片描述

一、学习目标与重点

💡 学习目标：掌握Python异步编程的基本概念和方法，包括协程、任务调度、事件循环等；学习asyncio、aiohttp等核心库的使用；通过实战案例开发异步应用程序。
⚠️ 学习重点：协程的定义与使用、任务调度、事件循环、asyncio库、aiohttp库、异步编程实战。

21.1 异步编程概述

21.1.1 什么是异步编程

异步编程是一种并发编程方式，通过非阻塞的操作提高程序的执行效率。在异步编程中，程序可以在等待I/O操作完成时继续执行其他任务，而不需要阻塞等待。

21.1.2 异步编程的优势

  • 提高执行效率：在等待I/O操作完成时，程序可以继续执行其他任务。
  • 降低资源消耗：减少了线程切换的开销。
  • 简化代码结构：通过协程和任务调度，代码结构更加简洁。

21.1.3 异步编程的应用场景

  • 网络通信：如HTTP请求、Web服务器、WebSocket通信等。
  • 文件操作：如大文件的读取和写入。
  • 数据库操作：如异步数据库查询。

21.2 协程的定义与使用

21.2.1 协程的定义

协程（Coroutine）是一种轻量级的线程，可以在程序中进行暂停和恢复。在Python中，协程可以通过async def关键字定义。

21.2.2 协程的使用

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 运行协程 asyncio.run(hello())

21.2.3 协程的暂停与恢复

import asyncio # 定义协程asyncdefcount():print('Counting...')await asyncio.sleep(1)print('Counted!')# 运行多个协程asyncdefmain():await asyncio.gather(count(), count(), count()) asyncio.run(main())

21.3 任务调度

21.3.1 创建任务

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 创建任务asyncdefmain(): task1 = asyncio.create_task(hello()) task2 = asyncio.create_task(hello())await task1 await task2 asyncio.run(main())

21.3.2 任务的取消

import asyncio # 定义协程asyncdefhello():try:print('Hello, World!')await asyncio.sleep(1)print('Hello again!')except asyncio.CancelledError:print('Task cancelled!')# 创建任务并取消asyncdefmain(): task = asyncio.create_task(hello())await asyncio.sleep(0.5) task.cancel()try:await task except asyncio.CancelledError:print('Main: Task cancelled!') asyncio.run(main())

21.3.3 任务的超时

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(2)print('Hello again!')# 任务超时asyncdefmain():try:await asyncio.wait_for(hello(), timeout=1)except asyncio.TimeoutError:print('Task timed out!') asyncio.run(main())

21.4 事件循环

21.4.1 事件循环的概述

事件循环是异步编程的核心组件，负责调度任务的执行。事件循环会不断地从任务队列中取出任务并执行，直到任务队列为空。

21.4.2 获取事件循环

import asyncio # 获取事件循环 loop = asyncio.get_event_loop()# 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 运行协程 loop.run_until_complete(hello())

21.4.3 事件循环的运行

import asyncio # 获取事件循环 loop = asyncio.get_event_loop()# 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 运行多个协程 loop.run_until_complete(asyncio.gather(hello(), hello(), hello()))

21.5 asyncio库

21.5.1 asyncio的基本用法

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 运行协程 asyncio.run(hello())

21.5.2 asyncio的常用函数

  • asyncio.run()：运行协程。
  • asyncio.create_task()：创建任务。
  • asyncio.gather()：收集多个协程的结果。
  • asyncio.wait_for()：等待协程完成，设置超时。
  • asyncio.sleep()：暂停协程。

21.5.3 asyncio的高级用法

import asyncio # 定义协程asyncdefhello():print('Hello, World!')await asyncio.sleep(1)print('Hello again!')# 使用Future对象asyncdefmain(): future = asyncio.Future() task = asyncio.create_task(hello()) task.add_done_callback(lambda t: future.set_result(t.result()))await future asyncio.run(main())

21.6 aiohttp库

21.6.1 安装aiohttp

pip install aiohttp

21.6.2 发送HTTP请求

import aiohttp import asyncio # 发送GET请求asyncdeffetch(session, url):asyncwith session.get(url)as response:returnawait response.text()asyncdefmain():asyncwith aiohttp.ClientSession()as session: html =await fetch(session,'https://www.example.com')print(html) asyncio.run(main())

21.6.3 发送POST请求

import aiohttp import asyncio import json # 发送POST请求asyncdefpost_data(session, url, data):asyncwith session.post(url, data=data)as response:returnawait response.text()asyncdefmain():asyncwith aiohttp.ClientSession()as session: data ={'name':'张三','age':25} response =await post_data(session,'https://httpbin.org/post', data)print(response) asyncio.run(main())

21.6.4 发送JSON请求

import aiohttp import asyncio import json # 发送JSON请求asyncdefpost_json(session, url, data):asyncwith session.post(url, json=data)as response:returnawait response.text()asyncdefmain():asyncwith aiohttp.ClientSession()as session: data ={'name':'张三','age':25} response =await post_json(session,'https://httpbin.org/post', data)print(response) asyncio.run(main())

21.7 实战案例：异步HTTP客户端

21.7.1 需求分析

开发一个异步HTTP客户端，支持以下功能：

  • 发送HTTP请求。
  • 并发发送多个HTTP请求。
  • 处理响应数据。

21.7.2 代码实现

import aiohttp import asyncio import time # 发送HTTP请求asyncdeffetch(session, url): start_time = time.time()asyncwith session.get(url)as response: text =await response.text() elapsed_time = time.time()- start_time return url,len(text), elapsed_time # 并发发送HTTP请求asyncdefmain(): urls =['https://www.example.com','https://www.google.com','https://www.github.com','https://www.python.org','https://www.djangoproject.com']asyncwith aiohttp.ClientSession()as session: tasks =[asyncio.create_task(fetch(session, url))for url in urls] results =await asyncio.gather(*tasks)for url, length, elapsed_time in results:print(f'URL: {url}, 响应长度: {length}, 耗时: {elapsed_time:.2f}秒')# 运行程序if __name__ =='__main__': start_time = time.time() asyncio.run(main()) elapsed_time = time.time()- start_time print(f'总耗时: {elapsed_time:.2f}秒')

21.7.3 实施过程

  1. 安装aiohttp库。
  2. 定义发送HTTP请求的协程函数。
  3. 定义并发发送HTTP请求的协程函数。
  4. 运行程序。

21.7.4 最终效果

通过异步HTTP客户端，我们可以实现以下功能：

  • 发送HTTP请求。
  • 并发发送多个HTTP请求。
  • 处理响应数据。

21.8 实战案例：异步Web服务器

21.8.1 需求分析

开发一个异步Web服务器，支持以下功能：

  • 处理HTTP请求。
  • 提供静态文件服务。
  • 实现简单的API接口。

21.8.2 代码实现

from aiohttp import web import asyncio # 处理根路径请求asyncdefhandle_root(request):return web.Response(text='Hello, World!')# 处理API接口请求asyncdefhandle_api(request): data ={'name':'张三','age':25}return web.json_response(data)# 提供静态文件服务asyncdefhandle_static(request):return web.FileResponse('static/index.html')# 创建Web应用asyncdefcreate_app(): app = web.Application()# 添加路由 app.add_routes([ web.get('/', handle_root), web.get('/api', handle_api), web.get('/static/{name}', handle_static)])return app # 运行Web服务器if __name__ =='__main__': asyncio.run(web.run_app(create_app(), host='localhost', port=8080))

21.8.3 实施过程

  1. 安装aiohttp库。
  2. 定义处理HTTP请求的协程函数。
  3. 创建Web应用。
  4. 添加路由。
  5. 运行Web服务器。

21.8.4 最终效果

通过异步Web服务器，我们可以实现以下功能：

  • 处理HTTP请求。
  • 提供静态文件服务。
  • 实现简单的API接口。

总结

✅ 本文详细介绍了Python异步编程的基本概念和方法，包括协程、任务调度、事件循环等；学习了asyncio、aiohttp等核心库的使用；通过实战案例开发了异步HTTP客户端和异步Web服务器。
✅ 建议读者在学习过程中多练习，通过编写代码加深对知识点的理解。

Read more

【工具】Git 和小乌龟安装与使用

一、安装         Git 是命令行的方式使用，小乌龟是 Git 的可视化工具，点点点就能执行命令行操作。因此，先安装 Git，再安装小乌龟，小乌龟安装的时候需要配置 Git 的 .exe 文件路径。 1、安装 Git         一路默认，安装路径可以改到 D 盘。         取消勾选，完成。         安装好后，点击鼠标右键可以看到： 2、安装小乌龟         一路默认，可以改小乌龟安装路径。         检查一下配置的 git.exe 路径对不对。 二、使用 1、配置 git 操作身份         配置远程仓库账号的用户名、邮箱，多人协作操作仓库时能识别操作人的身份。 2、SSH协议传输配置         git 有两种传输协议，HTTPS

Huobao Drama 开源短剧生成平台：从剧本到视频

Huobao Drama 开源短剧生成平台：从剧本到视频 Huobao Drama 一句话简介：一个基于 Go + Vue3 的全栈 AI 短剧自动化生产平台，覆盖“剧本解析 → 角色/分镜生成 → 视频合成”的一站式流程。 适用场景： * 想快速验证“短剧生成工作流”的产品/技术原型（偏全链路演示） * 需要一个可自建的 AI 素材/分镜/视频任务管理后台（本地存储 + SQLite） * 自己有模型/聚合 API（OpenAI 兼容/火山/本地 Ollama 等），希望接到可用的 Web 界面里跑通 二、开源协议 * CC BY-NC-SA 4.0（

谷歌开源翻译模型 TranslateGemma 深度解析与本地部署实践

引言 在全球化的商业环境中，跨语言沟通已成为企业数字化转型的核心挑战之一。 机器翻译技术作为打破语言壁垒的关键工具，其重要性日益凸显。 2026年1月16日，谷歌正式发布了名为 TranslateGemma 的开源翻译模型系列，这一基于最新 Gemma 3 架构构建的翻译模型家族，被官方称为"开放翻译领域的重要一步"。 TranslateGemma 的发布不仅标志着谷歌在开源翻译领域的重大突破，更为全球开发者提供了一个高性能、高效率的翻译解决方案。 本文将从技术架构、核心特性、训练方法、应用场景等多个维度深入剖析 TranslateGemma，并提供基于 Ollama 的本地部署工具类代码，帮助开发者快速上手这一革命性的翻译模型。通过本文的学习，读者将全面理解 TranslateGemma 的技术优势，并掌握在本地环境中高效运行该模型的方法。 TranslateGemma 概述与技术背景 什么是 TranslateGemma TranslateGemma 是谷歌基于 Gemma 3 构建的全新开源翻译模型系列。与传统的翻译模型不同，TranslateGemma 融合了
GitHub介绍指南

GitHub介绍指南

作为程序员，GitHub 绝对是日常开发、技术成长、团队协作的核心工具——它不只是“代码仓库”，更是全球1亿+开发者的技术生态枢纽，从个人项目管理到大型团队协作，从开源学习到职场背书，吃透它能大幅提升开发效率、拓宽技术视野，是程序员不可或缺的“刚需装备”。 一、先厘清关键：GitHub ≠ Git（避免踩坑）        很多开发者初期会混淆两者，用两个通俗比喻就能快速区分，核心关系一句话概括：Git 负责“本地记录”，GitHub 负责“云端共享”： * Git：你本地电脑的“代码版本管理工具”（软件），无需联网，核心作用是记录代码每一次修改、管理分支、一键回退版本，相当于你私人的“代码日记本”，解决“改崩代码回不去”“多个最终版文件夹混乱”的痛点。 * GitHub：基于 Git 搭建的在线平台（网站），需联网使用，核心是将本地