Discord斜杠命令长时间任务处理：避免“应用程序未响应”错误

import time
import discord
from discord.ext import commands

# 假设 tree 是一个 commands.Bot 或 app_commands.CommandTree 实例

def test_function():
    """一个模拟耗时同步操作的函数"""
    print("test_function 开始执行 (同步阻塞)...")
    time.sleep(5) # 模拟一个耗时5秒的阻塞操作
    print("test_function 执行完毕 (同步阻塞).")
    return 'nba_ev.png'

@tree.command(name = "example_command", description = "示例命令")
async def example_command(interaction: discord.Interaction):
    # 理想情况下，我们希望在这里立即 defer
    await interaction.response.defer() # 尝试延迟响应

    try:
        # 在这里调用了同步的 test_function
        # 如果在 defer 之前执行，或者 defer 后立即执行且 test_function 阻塞，
        # 则可能导致问题。
        # 实际问题是 test_function 阻塞了事件循环，导致 defer 无法及时完成。
        file_path = test_function() # 耗时操作，会阻塞事件循环
        d_file = discord.File(file_path)
        await interaction.followup.send(file=d_file)
    except Exception as e:
        print(f"发生错误: {e}")
        error_message = "处理请求时发生错误，请稍后再试。"
        await interaction.followup.send(content=error_message, ephemeral=True)

import asyncio
import aiohttp # 假设用于异步网络请求
import discord
from discord.ext import commands
# 假设 tree 是一个 commands.Bot 或 app_commands.CommandTree 实例

async def async_test_function():
    """一个模拟耗时异步操作的函数"""
    print("async_test_function 开始执行 (异步)...")
    # 模拟一个异步的I/O密集型任务，例如：
    # await some_async_library_call()
    # 模拟网络请求:
    # async with aiohttp.ClientSession() as session:
    #     async with session.get('https://api.example.com/data') as resp:
    #         data = await resp.json()
    await asyncio.sleep(5) # 使用异步睡眠，不阻塞事件循环
    print("async_test_function 执行完毕 (异步).")
    return 'nba_ev.png' # 返回文件路径或其他结果

@tree.command(name = "example_command_async", description = "使用异步任务的示例命令")
async def example_command_async(interaction: discord.Interaction):
    await interaction.response.defer() # 立即延迟响应

    try:
        # await 异步函数，它会在等待时释放事件循环
        file_path = await async_test_function()
        d_file = discord.File(file_path)
        await interaction.followup.send(file=d_file)
    except Exception as e:
        print(f"发生错误: {e}")
        error_message = "处理请求时发生错误，请稍后再试。"
        await interaction.followup.send(content=error_message, ephemeral=True)

import asyncio
import time
import discord
from discord.ext import commands
# 假设 tree 是一个 commands.Bot 或 app_commands.CommandTree 实例

def sync_test_function_blocking():
    """原始的、模拟耗时同步操作的函数"""
    print("sync_test_function_blocking 开始执行 (同步阻塞)...")
    time.sleep(5) # 模拟一个耗时5秒的阻塞操作
    print("sync_test_function_blocking 执行完毕 (同步阻塞).")
    return 'nba_ev.png'

@tree.command(name = "example_command_threaded", description = "使用线程执行阻塞任务的示例命令")
async def example_command_threaded(interaction: discord.Interaction):
    await interaction.response.defer() # 立即延迟响应

    try:
        # 使用 asyncio.to_thread (Python 3.9+) 在单独线程中运行同步函数
        # 对于 Python 3.9 以下版本，可以使用：
        # loop = asyncio.get_running_loop()
        # file_path = await loop.run_in_executor(None, sync_test_function_blocking)
        file_path = await asyncio.to_thread(sync_test_function_blocking)

        d_file = discord.File(file_path)
        await interaction.followup.send(file=d_file)
    except Exception as e:
        print(f"发生错误: {e}")
        error_message = "处理请求时发生错误，请稍后再试。"
        await interaction.followup.send(content=error_message, ephemeral=True)