Aiogram中如何通过其他按钮数据终止运行中的while循环

问题本质 #

你当前的写法存在三个核心错误：

• while True直接写在消息处理协程内部，一旦进入循环就会持续占用协程资源，后续用户发送的"Change data 📆"消息根本无法被处理，自然不可能触发循环终止逻辑
• 循环内无任何等待、让出控制权的逻辑，会直接阻塞整个机器人的异步事件循环，不仅当前用户收不到正常响应，还可能导致所有用户的请求卡死
• 代码中冗余调用了两次August()，第一次调用的返回值没有被使用，属于无效执行

正确实现方式 #

Telegram机器人是事件驱动模型，不要在单个消息处理逻辑中写阻塞式死循环，改用独立异步任务+任务句柄存储的方式实现循环发送，同时支持随时终止：

1. 先定义存储结构，保存每个用户对应的循环任务对象，方便后续精准取消
2. 触发"August 27"逻辑时，创建独立的异步协程任务运行循环，不阻塞主消息处理流程
3. 触发"Change data 📆"逻辑时，直接取出对应用户的循环任务执行取消操作即可

完整参考代码：

import asyncio
from aiogram import types

# 存储用户ID与对应August循环任务的映射关系
user_august_tasks = {}

@dp.message_handler()
async def starting(message: types.Message):
    user_id = message.from_user.id
    
    if message.text == "August 27":
        # 先清理该用户已存在的同类型任务，避免重复启动多个循环
        if user_id in user_august_tasks and not user_august_tasks[user_id].done():
            user_august_tasks[user_id].cancel()
        
        # 定义循环发送逻辑
        async def august_send_loop():
            try:
                while True:
                    content = August()
                    await message.answer(content, reply_markup=data_change_markup)
                    # 配置发送间隔，单位秒，避免触发Telegram接口限流，同时让出协程控制权
                    await asyncio.sleep(3600) # 示例为1小时发送一次，按实际业务需求修改
            except asyncio.CancelledError:
                # 任务被取消时的清理逻辑，无特殊需求可直接留空
                return
        
        # 创建独立异步任务运行循环，不阻塞当前消息处理
        loop_task = asyncio.create_task(august_send_loop())
        user_august_tasks[user_id] = loop_task

    if message.text == "Change data 📆":
        # 取消对应用户正在运行的August循环任务
        if user_id in user_august_tasks and not user_august_tasks[user_id].done():
            user_august_tasks[user_id].cancel()
            del user_august_tasks[user_id]
        await message.answer('Alright, we will change the data', reply_markup=data_markup)

注意事项 #

• 循环内必须保留await asyncio.sleep()调用，否则异步事件循环会被持续占用，机器人整体会失去响应
• 如果是多实例部署的生产环境，内存字典存储任务的方式不适用，需要替换为Redis等外部存储维护用户状态，配合分布式任务调度实现
• 任务取消后建议增加异常捕获，避免无效报错日志输出

内容的提问来源于stack exchange，提问作者user19349257