discord.pyで音声再生中に新たな入力を受け付けない

Question

##概要
discord.pyでdiscordのbotを製作していて、テキストチャンネルの発言をボイスチャンネルで読み上げようとしています。読み上げにはVoiceTextのAPIを使用してwaveファイルを取得し、ffmpegPCMAudioで再生しています。
##環境
Windows 10 home 64bit

Python 3.9
discord.py 1.7.3
python-voicetext 0.3.1
##症状
長文を読み上げている最中にテキストチャンネルに新たに発言すると、エラーが発生し、新しい方の発言は読み上げられない。
##コード

import discord
import datetime
import time
import os
from voicetext import VoiceText
import wave
import asyncio


TOKEN = ''
KEY = ""


client = discord.Client()
vt = VoiceText(KEY)
check_text_channel = None


#接続時の処理
@client.event
async def on_ready():
    dt_now = datetime.datetime.now()
    print(f"[{dt_now}]Launch complete!")

#メッセージが送られた時
@client.event
async def on_message(message):
    
    #botの発言は無視
    if message.author.bot:
        return
    
    #ボイスチャンネルに接続
    elif message.content == "yomi.c":
        if message.author.voice is None:
            await message.channel.send(f"{message.author.mention}さんはボイスチャンネルに接続していません")
            dt_now = datetime.datetime.now()
            print(f"[{dt_now}]{message.author}さんはボイスチャンネルに接続していません")          
        
        else:
            await message.author.voice.channel.connect()
            global check_text_channel
            check_text_channel = message.channel
            await message.channel.send(f"{message.author.voice.channel.name}に接続しました")
            dt_now = datetime.datetime.now()
            print(f"[{dt_now}]{message.author.voice.channel.name}に接続しました")
            
    
    #ボイスチャンネルから切断
    elif message.content == "yomi.dc":
        if message.guild.voice_client is None:
            await message.channel.send("ボイスチャンネルに接続していません")
            dt_now = datetime.datetime.now()
            print(f"[{dt_now}]ボイスチャンネルに接続していません")

        else:
            await message.guild.voice_client.disconnect()
            await message.channel.send("切断しました")
            dt_now = datetime.datetime.now()
            print(f"[{dt_now}]切断しました")
            
    #読み上げ
    elif message.channel == check_text_channel:
        if message.guild.voice_client is None:
            await message.channel.send("ボイスチャンネルに接続していません")
            dt_now = datetime.datetime.now()
            print(f"[{dt_now}]ボイスチャンネルに接続していません")

        else:
            #音声ファイル作成
            ut = time.time()
            with open(f"{ut}.wav","wb") as f:
                f.write(vt.speed(150).to_wave(message.content))
        
            #音声読み上げ
            message.guild.voice_client.play(discord.FFmpegPCMAudio(f"{ut}.wav"))
            

            #音声ファイル削除
            with wave.open(f"{ut}.wav", "rb")as f:
                wave_length=(f.getnframes() / f.getframerate()) #再生時間
            print(f"PlayTime:{wave_length}")
            await asyncio.sleep(wave_length + 5)
            os.remove(f"{ut}.wav")

client.run(TOKEN)

##エラーメッセージ

PlayTime:7.034013605442177
Ignoring exception in on_message
Traceback (most recent call last):
  File "C:\Users\GardenTree\AppData\Local\Programs\Python\Python39\lib\site-packages\discord\client.py", line 343, in _run_event
    await coro(*args, **kwargs)
  File "d:\Desktop\yomi-KAI\yomi-KAI.py", line 76, in on_message
    message.guild.voice_client.play(discord.FFmpegPCMAudio(f"{ut}.wav"))
  File "C:\Users\GardenTree\AppData\Local\Programs\Python\Python39\lib\site-packages\discord\voice_client.py", line 558, in play
    raise ClientException('Already playing audio.')
discord.errors.ClientException: Already playing audio.
INFO:discord.player:Preparing to terminate ffmpeg process 35480.
INFO:discord.player:ffmpeg process 35480 has not terminated. Waiting to terminate...
INFO:discord.player:ffmpeg process 35480 should have terminated with a return code of 1.
INFO:discord.player:Preparing to terminate ffmpeg process 7840.
INFO:discord.player:ffmpeg process 7840 successfully terminated with return code of 0.

##調べたこと

• ブロッキングが発生している？
• Queueを使えば良い？

##実現したいこと
長文を読み上げ中に新たなテキストが送られると、長文を読み終わった後に読んでほしい。

Answer 1

VioceClient.playは、引数afterに指定した関数を音声再生後かエラー発生時に実行することができます。
なのでキューが空になるまでafterで再帰すればいいです。

また、キューはcollections.dequeを使うと良いと思います。
複数のサーバーで運用される場合、キューはサーバーごとに持たないと音声が混ざってしまうのでdictなどに格納するといいでしょう。

ざっくりとですが、イメージとしては、

from collections import defaultdict, deque

queue_dict = defaultdict(deque)

def enqueue(voice_client, guild, source):
    queue = queue_dict[guild.id]
    queue.append(source)
    if not voice_client.is_playing():
        play(voice_client, queue)

def play(voice_client, queue):
    if not queue or voice_client.is_playing():
        return
    source = queue.popleft()
    voice_client.play(source, after=lambda e:play(voice_client, queue))

のような感じでしょうか。プログラムに合わせて適宜読み替えてください。

Comments

[GardenTree]

6行目のstack_dictはqueue_dictのtypoでしょうか？
また、読み替えるところを教えていただきたいです。

[kairi003]

Typoです修正しました
いや別に読み替えなきゃいけないわけでもないんですけど、あんまり元のコードに合わせて書いてないので、afterにwavの削除を組み込むとか、引数をmessageにするとかしてみてくださいって意味です

[GardenTree]

何度も申し訳ないのですが、playのqueueには何を渡せばよいのでしょうか？

[kairi003]

AudioSource、つまり今回はFFmpegPCMAudioです

[GardenTree]

voice_client.play(source, lambda e:play(voice_client, queue))
TypeError: play() takes 2 positional arguments but 3 were given
というエラーメッセージが表示されるのですが、どのようにすればよいのでしょうか？

[kairi003]

すみません、after=が必要でした

[GardenTree]

enqueue(message.guild.voice_client, message.guild, f"{ut}.wav")
play(message.guild.voice_client, discord.FFmpegPCMAudio)
このように呼び出せばよいのでしょうか？

[kairi003]

すみません、
>>playのqueue
から勘違いしてました。

playはenqueueから呼び出しています。
引数queueはそのサーバーのqueue、つまりqueue_dict[guild.id]です。
playを直接呼び出すことはしません。
enuqueueはenqueue(message.guild.voice_client, message.guild, discord.FFmpegPCMAudio(f"{ut}.wav"))です。

[GardenTree]

思ったとおりに動作しました！！
ありがとうございます！