如何让aiogram机器人仅对特定用户执行延迟任务且不影响其他用户？

在aiogram中直接用sleep()会阻塞整个事件循环，导致机器人无法响应其他用户请求。正确做法是利用asyncio的异步能力，把延迟任务放到后台执行，不影响主流程：

核心实现思路 #

1. 用asyncio.sleep()替代同步sleep()，它不会阻塞事件循环
2. 通过asyncio.create_task()将延迟任务提交到后台，独立于主逻辑运行

完整代码示例 #

先导入必要模块：

import asyncio
from aiogram import Bot, Dispatcher, types
from aiogram.filters import Command
from aiogram.types import Message

# 替换为你的机器人Token
BOT_TOKEN = "YOUR_BOT_TOKEN"
bot = Bot(token=BOT_TOKEN)
dp = Dispatcher()

实现sleep_timer函数 #

这个异步函数负责延迟指定时间后给目标用户发通知：

async def sleep_timer(user_id: int, delay_time: int):
    # 异步等待，不会卡住整个机器人
    await asyncio.sleep(delay_time)
    try:
        # 发送恢复健康通知
        await bot.send_message(
            chat_id=user_id,
            text="你的健康值已经恢复啦！"
        )
    except Exception as e:
        # 捕获发送异常（比如用户屏蔽了机器人）
        print(f"发送消息失败: {e}")

触发延迟任务的命令逻辑 #

比如用户发送/restore命令后启动10秒延迟：

@dp.message(Command("restore"))
async def handle_restore(message: Message):
    user_id = message.from_user.id
    # 立即回复用户，告知等待开始
    await message.reply("正在恢复健康，请等待10秒...")
    # 创建后台任务执行延迟通知，不阻塞当前回复
    asyncio.create_task(sleep_timer(user_id, 10))

启动机器人 #

async def main():
    await dp.start_polling(bot)

if __name__ == "__main__":
    asyncio.run(main())

关键说明 #

• asyncio.sleep()只会暂停当前任务的执行，其他用户的请求依然能正常处理
• asyncio.create_task()把延迟任务加入事件循环队列，后台独立运行
• 异常处理能避免因发送失败导致任务崩溃，提升机器人稳定性

内容的提问来源于stack exchange，提问作者Матвей Васильев