Discord.py中如何将其他模块同步方法转为异步调用？含Python Twitch API需求

同步方法异步化实现方案 #

你不需要更换现有模块，仅通过asyncio自带的工具即可实现PyTwitchAPI的全异步调用，改造成本极低，具体方案如下：

• 不要直接在discord.py的异步协程中调用PyTwitchAPI的同步方法，会阻塞事件循环导致机器人整体无响应。
• Python 3.9+版本使用asyncio.to_thread()将同步方法调度到独立线程运行，异步等待返回结果，示例代码如下：

import asyncio
import discord
from discord.ext import commands
from twitchAPI.twitch import Twitch

# 初始化Twitch客户端（原有同步初始化逻辑不变）
twitch = Twitch("你的应用ID", "你的应用密钥")
twitch.authenticate_app([])

# 封装同步接口为异步调用
async def async_get_stream_info(user_login: str):
    # 将同步方法和参数传入to_thread即可
    return await asyncio.to_thread(twitch.get_streams, user_login=[user_login])

# 在discord.py指令中直接调用封装好的异步方法
bot = commands.Bot(command_prefix="!", intents=discord.Intents.all())
@bot.tree.command(name="check_stream", description="查询Twitch主播直播状态")
async def check_stream(interaction: discord.Interaction, username: str):
    stream_data = await async_get_stream_info(username)
    if stream_data["data"]:
        await interaction.response.send_message(f"主播{username}正在直播：{stream_data['data'][0]['title']}")
    else:
        await interaction.response.send_message(f"主播{username}当前未开播")

• Python 3.8及更早版本可以使用事件循环的run_in_executor方法实现同等效果，替换封装逻辑即可：

async def async_get_stream_info(user_login: str):
    loop = asyncio.get_running_loop()
    # 第一个参数传None使用默认线程池，后续依次传入同步方法、对应参数
    return await loop.run_in_executor(None, twitch.get_streams, [user_login])

• 所有PyTwitchAPI的同步方法都可以按上述规则封装，不需要修改原模块内部代码，即可完美适配discord.py的异步运行环境。

替代异步模块推荐 #

如果你希望直接使用原生异步的Twitch SDK，可以选择TwitchIO，该模块原生异步设计，完整覆盖Twitch开放平台所有API能力、直播事件订阅、聊天交互等功能，和discord.py的异步生态适配性更好。

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