Web インターフェイスを介してコマンドを受信できる不和ボットを作成しようとしています。非同期タスクを処理する必要があり、Flask がそれらをサポートしていないため、discord.py を Discord API ラッパーとして、Quart を REST フレームワークとして使用しています。
現在、私は2つのファイルを持っています:
app.py
import discord
bot = discord.Client(intents=discord.Intents.all())
...
async def play_audio(audio_name, voiceChannel):
vc = await voiceChannel.connect()
print("test")
vc.play(discord.FFmpegPCMAudio(source="audio\{}".format(audio_name), executable=FFMPEG_PATH))
while vc.is_playing():
time.sleep(.1)
await vc.disconnect()
async def get_online_voice_members():
guild = bot.get_guild(NMC_GUILD_ID)
online_voice_users = {}
for voiceChannel in guild.voice_channels:
for user in voiceChannel.members:
online_voice_users[user] = voiceChannel
return online_voice_users
...
api.py
import asyncio
from quart import Quart
import app as discord
QUART_APP = Quart(__name__)
@QUART_APP.before_serving
async def before_serving():
loop = asyncio.get_event_loop()
await discord.bot.login("MY BOT TOKEN")
loop.create_task(discord.bot.connect())
...
@QUART_APP.route("/online_list", methods=["GET"])
async def get_online_members():
resp = {}
members = await discord.get_online_voice_members()
for user in members.keys():
resp[user.id] = {"nick" : user.nick, "channel" : members[user].id}
return resp
@QUART_APP.route("/goodnight", methods=["GET"])
async def send_goodnight():
members = await discord.get_online_voice_members()
for user in members.keys():
if user.id == 12345:
await discord.play_audio("goodnight.mp3", members[user])
break
return {"response":"OK"}
エンドポイント /online_list で GET リクエストを行うとすべて正常に動作しますが、/goodnight でリクエストを行うと、コードは命令await discord.play_audio("goodnight.mp3, members[user])に到達するまで正常に実行され、正しいパラメーターを受け取りますが、常に次の例外が発生します。
Traceback (most recent call last):
File "G:\Gunther\venv\lib\site-packages\quart\app.py", line 1814, in handle_request
return await self.full_dispatch_request(request_context)
File "G:\Gunther\venv\lib\site-packages\quart\app.py", line 1836, in full_dispatch_request
result = await self.handle_user_exception(error)
File "G:\Gunther\venv\lib\site-packages\quart\app.py", line 1076, in handle_user_exception
raise error
File "G:\Gunther\venv\lib\site-packages\quart\app.py", line 1834, in full_dispatch_request
result = await self.dispatch_request(request_context)
File "G:\Gunther\venv\lib\site-packages\quart\app.py", line 1882, in dispatch_request
return await handler(**request_.view_args)
File "G:/Dati HDD F/GitHub Projects/Gunther/api.py", line 59, in send_buonanotte
await discord.play_audio("goodnight.mp3", members[user])
File "G:\Gunther\app.py", line 55, in play_audio
vc = await voiceChannel.connect()
File "G:\Gunther\venv\lib\site-packages\discord\abc.py", line 1122, in connect
await voice.connect(timeout=timeout, reconnect=reconnect)
File "G:\Gunther\venv\lib\site-packages\discord\voice_client.py", line 352, in connect
self.ws = await self.connect_websocket()
File "G:\Gunther\venv\lib\site-packages\discord\voice_client.py", line 323, in connect_websocket
await ws.poll_event()
File "G:\Gunther\venv\lib\site-packages\discord\gateway.py", line 893, in poll_event
await self.received_message(json.loads(msg.data))
File "G:\Gunther\venv\lib\site-packages\discord\gateway.py", line 825, in received_message
await self.initial_connection(data)
File "G:\Gunther\venv\lib\site-packages\discord\gateway.py", line 849, in initial_connection
recv = await self.loop.sock_recv(state.socket, 70)
File "C:\Users\Kyles\AppData\Local\Programs\Python\Python38\lib\asyncio\proactor_events.py", line 693, in sock_recv
return await self._proactor.recv(sock, n)
RuntimeError: Task <Task pending name='Task-27' coro=<ASGIHTTPConnection.handle_request() running at G:\Gunther\venv\lib\site-packages\quart\asgi.py:70> cb=[_wait.<locals>._on_completion() at C:\Users\Kyles\AppData\Local\Programs\Python\Python38\lib\asyncio\tasks.py:507]> got Future <_OverlappedFuture pending overlapped=<pending, 0x199c31f0ca0>> attached to a different loop
asyncio ライブラリがどのように機能するかを正しく理解していないと思います。何を試してもvc = await voiceChannel.connect()、app.py の行は常にメインのループとは異なるループで実行されるようです。足りないものはありますか？