Не работает очередь вопроизведения музыки у дискорд бота, что делать?

Question

[Oh_noo2195]

Я попробовал разобраться как реализовать очередь воспроизведения, но зашёл в тупик, и как понимаю написал глупость. Буду рад любой помощи:>

Если это максимально глупая ошибка, то прошу без хейта, я только учусь.

Вот ошибка, появляется не всегда и при этом очередь все равно не работает, но музыка воспроизводится.
future: exception=AttributeError("'function' object has no attribute 'start'")>
Traceback (most recent call last):
File "/app/main.py", line 41, in audio_player_task
current.start()
AttributeError: 'function' object has no attribute 'start'
[tls @ 0x76ea2c0] Error in the pull function.
[tls @ 0x76ea2c0] IO error: Connection reset by peer
[https @ 0x76e6b40] Will reconnect at 540672 in 0 second(s), error=Connection reset by peer.
[tls @ 0x6c292c0] Error in the pull function.
[tls @ 0x6c292c0] IO error: Connection reset by peer
[https @ 0x6c25b40] Will reconnect at 540672 in 0 second(s), error=Connection reset by peer.

songs = asyncio.Queue()
play_next_song = asyncio.Event()

async def audio_player_task():
    while True:
        play_next_song.clear()
        current = await songs.get()
        current.start()
        await play_next_song.wait()

def toggle_next(self):
    client.loop.call_soon_threadsafe(play_next_song.set)

@bot.command(name='play')
async def play(ctx, *, url: str):
    if ctx.author.voice is None:
        embed = discord.Embed(title=f'подключись к каналу', color=discord.Color.red())
        bot_msg = await ctx.send(embed=embed)
        await asyncio.sleep(5)
        await bot_msg.delete()
    voice_channel = ctx.author.voice.channel        
    if ctx.voice_client is None:
        await voice_channel.connect()
    else:
        await ctx.voice_client.move_to(voice_channel)
    ctx.voice_client.stop()
    FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
    YDL_OPTIONS = {'format':"bestaudio", 'noplaylist': True, 'default_search': 'auto', 'forceduration': True, 'quiet': True}

    vc = ctx.voice_client

    with youtube_dl.YoutubeDL(YDL_OPTIONS) as ydl:
        info = ydl.extract_info(url, download=False)
        if 'entries' in info:
            url2 = info['entries'][0]["formats"][0]
        elif 'formats' in info:
            url2 = info["formats"][0]
        url = info["webpage_url"]
        stream_url = url2["url"]
        source = await discord.FFmpegOpusAudio.from_probe(stream_url, **FFMPEG_OPTIONS)
        vc.play(source, after = toggle_next)
        await songs.put(vc.play)

client.loop.create_task(audio_player_task())

Comments

[Vindicar]

Ну без хейта никак нельзя. =)

"Не работать" программа может очень многими способами. Как именно она не работает?
Эксепшн вылетает?
Молча игнорирует команду?
Команда отрабатывает, но не переключает трек?
Телепаты на карантине, так что дополни вопрос.

[Oh_noo2195]

Vindicar, дополнил

Answer 1

[Vindicar]

vc.play(source, after = toggle_next)
await songs.put(vc.play)

Ты запускаешь воспроизведение вызовом метода vc.play(), а потом помещаешь в очередь ссылку на этот метод.
Что, по-твоему, сиё должно делать? Потому что оно явно этого не делает, и делать не будет.

Comments

[Oh_noo2195]

Ох, спасибо что нашли ошибку, но можно наводку как сделать так чтобы это заработало, я просто уже в тупике... (

[Vindicar]

Oh_noo2195, а что ты пытаешься сделать? Простую одностороннюю очередь для воспроизведения?
Так храни в очереди ссылки, откуда брать контент.
У тебя будет отдельная корутина (назовём её play_song()), которая будет делать следующее:
0. Войти в голосовой канал, если еще не там.
1. Извлечь очередную ссылку из очереди (спать, если её нет).
2. Загрузить и извлечь контент.
3. Скормить контент в голосовой чат.
В качестве коллбэка after указываешь отдельную функцию (не корутину, насколько я понял!), которая запланирует новый вызов play_song() через loop.create_task(). Чтобы получить loop, используй asyncio.get_running_loop().
Таким образом, когда воспроизведение прервётся, автоматически запланируется воспроизведение следующей песни. Когда очередь будет исчерпана, текущий вызов play_song() уснёт, пока в очереди не появится новая песня.
Соответственно в обработчике команды !play кладешь ссылку в очередь и всё. Дальше play_song() сама обо всём позаботится. Просто запусти её при старте бота через всё тот же create_task().

Вот если тебе нужно чтобы бот заходил в войс чат только по запросу, и выходил по таймауту когда песни кончатся, тогде дело усложняется.

[Oh_noo2195]

Vindicar, Я чувствую себя сейчас очень глупым, потому что я понимаю что сделал все неправильно.
Прошу не закидайте тапками если все очень плохо(((((
Если все очень плохо, хотя-бы посмеётесь

FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
YDL_OPTIONS = {'format':"bestaudio", 'noplaylist': True, 'default_search': 'auto', 'forceduration': True, 'quiet': True}
songs = asyncio.Queue()
play_next_song = asyncio.Event()

def get():
    asyncio.get_running_loop(play_song())

async def play_song():     
    if ctx.voice_client is None:
        await voice_channel.connect()
    else:
        await ctx.voice_client.move_to(voice_channel)
    ctx.voice_client.stop()
    while True:
        play_next_song.clear()
        current = await songs.get()
        current.start()
        await play_next_song.wait()
    voice_channel = ctx.author.voice.channel   
    vc = ctx.voice_client
    with youtube_dl.YoutubeDL(YDL_OPTIONS) as ydl:
        info = ydl.extract_info(url, download=False)
        if 'entries' in info:
            url2 = info['entries'][0]["formats"][0]
        elif 'formats' in info:
            url2 = info["formats"][0]
        url = info["webpage_url"]
        stream_url = url2["url"]
        source = await discord.FFmpegOpusAudio.from_probe(stream_url, **FFMPEG_OPTIONS)
        vc.play(source, after = loop)

@bot.command(name='play')
async def play(ctx, *, url: str):
    await get()   
    if ctx.author.voice is None:
        embed = discord.Embed(title=f'подключись к каналу, ебло', color=discord.Color.red())
        bot_msg = await ctx.send(embed=embed)
        await asyncio.sleep(5)
        await bot_msg.delete()
        await songs.put(play_song)
def loop():
    client.loop.create_task(play_song(ctx))

[Vindicar]

Oh_noo2195, я же советовал хранить в Queue только ссылки на песни, т.е. строки с URL.
так что закладываем туда
await songs.put(url)
А потом внутри play_song() вынимаем
url = await songs.get()

В качестве after указываешь функцию такого вида (переделай её из get)
def run_play_song(err = None):
asyncio.get_event_loop().create_task(play_song())

Далее, так как ты play_song() запускаешь не сразу, то тебе нужно знать, запущена ли она. Объяви глобалку
play_song_is_running = False
А внутри play_song первым делом измени
global play_song_is_running
play_song_is_running = True

Тогда в команде play() ты сможешь это проверить:
global play_song_is_running
if not play_song_is_running:
run_play_song()
Обрати внимание, что у тебя run_play_song() - не корутина! Её надо вызывать без await.

[Oh_noo2195]

Vindicar, я попробовал сделать так, как вы объяснили,но я получаю вот такую ошибку. Извиняюсь если напрягаю вопросами.
File "/app/main.py", line 80, in run_play_song
asyncio.get_running_loop(play_song())
TypeError: _asyncio.get_running_loop() takes no arguments (1 given)
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/app/.heroku/python/lib/python3.9/site-packages/discord/ext/commands/bot.py", line 902, in invoke
await ctx.command.invoke(ctx)
File "/app/.heroku/python/lib/python3.9/site-packages/discord/ext/commands/core.py", line 864, in invoke
await injected(*ctx.args, **ctx.kwargs)
File "/app/.heroku/python/lib/python3.9/site-packages/discord/ext/commands/core.py", line 94, in wrapped
raise CommandInvokeError(exc) from exc
discord.ext.commands.errors.CommandInvokeError: Command raised an exception: TypeError: _asyncio.get_running_loop() takes no arguments (1 given)

FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
YDL_OPTIONS = {'format':"bestaudio", 'noplaylist': True, 'default_search': 'auto', 'forceduration': True, 'quiet': True}
songs = asyncio.Queue()
play_next_song = asyncio.Event()
play_song_is_running = False

def loop():
    asyncio.get_event_loop().create_task(play_song())

async def play_song():
    url = await songs.get()  
    if ctx.voice_client is None:
        await voice_channel.connect()
    else:
        await ctx.voice_client.move_to(voice_channel)
    ctx.voice_client.stop()
    while True:
        global play_song_is_running
        play_song_is_running = True   
        voice_channel = ctx.author.voice.channel   
    vc = ctx.voice_client
    with youtube_dl.YoutubeDL(YDL_OPTIONS) as ydl:
        info = ydl.extract_info(url, download=False)
        if 'entries' in info:
            url2 = info['entries'][0]["formats"][0]
        elif 'formats' in info:
            url2 = info["formats"][0]
        url = info["webpage_url"]
        stream_url = url2["url"]
        source = await discord.FFmpegOpusAudio.from_probe(stream_url, **FFMPEG_OPTIONS)
        vc.play(source, after = loop)

@bot.command(name='play')
async def play(ctx, *, url: str): 
    run_play_song()  
    if ctx.author.voice is None:
        embed = discord.Embed(title=f'подключись к каналу, ебло', color=discord.Color.red())
        bot_msg = await ctx.send(embed=embed)
        await asyncio.sleep(5)
        await bot_msg.delete()
    global play_song_is_running
    if not play_song_is_running:
        run_play_song()
        await songs.put(url)

def run_play_song(err = None):
    asyncio.get_running_loop(play_song())

[Vindicar]

Oh_noo2195, ну будь внимательнее же. Ты написал
asyncio.get_running_loop(play_song())
А я написал
asyncio.get_event_loop().create_task(play_song())

Прям какая-то избирательная слепота, что ты постоянно теряешь из виду вызов create_task().

[Oh_noo2195]

Vindicar, Новая ошибка

File "/app/main.py", line 72, in play

run_play_song()

File "/app/main.py", line 85, in run_play_song

asyncio.get_event_loop().create_task(play_song())

TypeError: play_song() missing 1 required positional argument: 'ctx'

The above exception was the direct cause of the following exception:

Traceback (most recent call last):

File "/app/.heroku/python/lib/python3.9/site-packages/discord/ext/commands/bot.py", line 902, in invoke

await ctx.command.invoke(ctx)

File "/app/.heroku/python/lib/python3.9/site-packages/discord/ext/commands/core.py", line 864, in invoke

await injected(*ctx.args, **ctx.kwargs)

File "/app/.heroku/python/lib/python3.9/site-packages/discord/ext/commands/core.py", line 94, in wrapped

raise CommandInvokeError(exc) from exc

discord.ext.commands.errors.CommandInvokeError: Command raised an exception: TypeError: play_song() missing 1 required positional argument: 'ctx'

FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
YDL_OPTIONS = {'format':"bestaudio", 'noplaylist': True, 'default_search': 'auto', 'forceduration': True, 'quiet': True}
songs = asyncio.Queue()
play_next_song = asyncio.Event()
play_song_is_running = False

def loop():
   asyncio.get_running_loop()

async def play_song(ctx):
    url = await songs.get()  
    global play_song_is_running
    play_song_is_running = True   
    if ctx.voice_client is None:
        await voice_channel.connect()
    else:
        await ctx.voice_client.move_to(voice_channel)
    ctx.voice_client.stop()
    while True:
        play_song.clear()
        current = await songs.get()
        current.start()
        await play_next_song.wait()
        voice_channel = ctx.author.voice.channel   
    vc = ctx.voice_client
    with youtube_dl.YoutubeDL(YDL_OPTIONS) as ydl:
        info = ydl.extract_info(url, download=False)
        if 'entries' in info:
            url2 = info['entries'][0]["formats"][0]
        elif 'formats' in info:
            url2 = info["formats"][0]
        url = info["webpage_url"]
        stream_url = url2["url"]
        source = await discord.FFmpegOpusAudio.from_probe(stream_url, **FFMPEG_OPTIONS)
        vc.play(source, after = loop)

@bot.command(name='play')
async def play(ctx, *, url: str): 
    run_play_song()  
    if ctx.author.voice is None:
        embed = discord.Embed(title=f'подключись к каналу, ебло', color=discord.Color.red())
        bot_msg = await ctx.send(embed=embed)
        await asyncio.sleep(5)
        await bot_msg.delete()
    global play_song_is_running
    if not play_song_is_running:
        run_play_song()
        await songs.put(url)


def run_play_song(err = None):
    asyncio.get_event_loop().create_task(play_song())

[Vindicar]

Oh_noo2195, ну да... может, имеет смысл внутри play() сохранить voice_client в глобальной переменной, чтобы не таскать контекст туда-сюда. Тогда внутри play_song() вместо ctx будешь обращаться к этой переменной.

[Oh_noo2195]

Vindicar, ох, я понимаю что достал вас, но думаю что это финальный вопрос.
Сможете помочь?
Task exception was never retrieved

future: exception=NameError("name 'vc' is not defined")>

Traceback (most recent call last):

File "/app/main.py", line 63, in play_song

if vc is None:

NameError: name 'vc' is not defined

FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
YDL_OPTIONS = {'format':"bestaudio", 'noplaylist': True, 'default_search': 'auto', 'forceduration': True, 'quiet': True}
songs = asyncio.Queue()
play_next_song = asyncio.Event()
play_song_is_running = False

def loop():
   asyncio.get_running_loop()

async def play_song():
    url = await songs.get()  
    global play_song_is_running
    global vc
    play_song_is_running = True   
    if vc is None:
        await voice_channel.connect()
    else:
        await vc.move_to(voice_channel)
    vc.stop()
    while True:
        play_song.clear()
        current = await songs.get()
        current.start()
        await play_next_song.wait()
        voice_channel = ctx.author.voice.channel   

    with youtube_dl.YoutubeDL(YDL_OPTIONS) as ydl:
        info = ydl.extract_info(url, download=False)
        if 'entries' in info:
            url2 = info['entries'][0]["formats"][0]
        elif 'formats' in info:
            url2 = info["formats"][0]
        url = info["webpage_url"]
        stream_url = url2["url"]
        source = await discord.FFmpegOpusAudio.from_probe(stream_url, **FFMPEG_OPTIONS)
        vc.play(source, after = loop)

@bot.command(name='play')
async def play(ctx, *, url: str): 
    run_play_song() 
    if ctx.author.voice is None:
        embed = discord.Embed(title=f'подключись к каналу, ебло', color=discord.Color.red())
        bot_msg = await ctx.send(embed=embed)
        await asyncio.sleep(5)
        await bot_msg.delete()
    global play_song_is_running
    if not play_song_is_running:
        run_play_song()
        await songs.put(url)
        vc = ctx.voice_client


def run_play_song(err = None):
    asyncio.get_event_loop().create_task(play_song())

[Vindicar]

Oh_noo2195, ну он же тебе английским по белому пишет - имя vc не определено. Так как к моменту выполнения if глобальной переменной vc еще нет, её значение будет присвоено позднее.
В начале скрпита пропиши vc = None

[Oh_noo2195]

Vindicar, ((((((((((((

Ошибка:

Traceback (most recent call last):

File "/app/main.py", line 53, in play_song

await voice_channel.connect()

AttributeError: 'NoneType' object has no attribute 'connect'

FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
YDL_OPTIONS = {'format':"bestaudio", 'noplaylist': True, 'default_search': 'auto', 'forceduration': True, 'quiet': True}
songs = asyncio.Queue()
play_next_song = asyncio.Event()
play_song_is_running = False

def loop():
   asyncio.get_running_loop()

async def play_song():
    url = await songs.get() 
    global play_song_is_running
    global vc
    global voice_channel
    global voice_channel
    voice_channel = None
    vc = None 
    play_song_is_running = True   
    if vc is None:
        await voice_channel.connect()
    else:
        await vc.move_to(voice_channel)
    vc.stop()
    while True:
        play_song.clear()
        current = await songs.get()
        current.start()
        await play_next_song.wait()
        voice_channel = ctx.author.voice.channel   

    with youtube_dl.YoutubeDL(YDL_OPTIONS) as ydl:
        info = ydl.extract_info(url, download=False)
        if 'entries' in info:
            url2 = info['entries'][0]["formats"][0]
        elif 'formats' in info:
            url2 = info["formats"][0]
        url = info["webpage_url"]
        stream_url = url2["url"]
        source = await discord.FFmpegOpusAudio.from_probe(stream_url, **FFMPEG_OPTIONS)
        vc.play(source, after = loop)

@bot.command(name='play')
async def play(ctx, *, url: str):  
    if ctx.author.voice is None:
        embed = discord.Embed(title=f'подключись к каналу, ебло', color=discord.Color.red())
        bot_msg = await ctx.send(embed=embed)
        await asyncio.sleep(5)
        await bot_msg.delete()
    global play_song_is_running
    if not play_song_is_running:
        run_play_song()
        await songs.put(url)
        vc = ctx.voice_client
        voice_channel = ctx.author.voice.channel 
def run_play_song(err = None):
    asyncio.get_event_loop().create_task(play_song())

[Vindicar]

global vc
    global voice_channel
    global voice_channel
    voice_channel = None
    vc = None 
    play_song_is_running = True   
    if vc is None:
        await voice_channel.connect()
    else:
        await vc.move_to(voice_channel)

Oh_noo2195, что-то мне подсказывает что ты вообще не понимаешь что за буквы ты пишешь.
Поучи основы... не питона даже - программирования как такового. Потом уже берись за ботов.
Зачем делать глобальный voice_channel? Зачем его объявлять дважды? Если ты САМ ему присваиваешь None, почему ты пытаешься вызываеть его методы полторы строчки спустя?

Определи уже порядок действий в своей программе - можно на бумаге, без кода.
1. Запуск бота. Создаём глобальные переменные (очередь, vc), инициализируем vc = None.
2. Первый вызов команды !play. Определяем, первый ли он по значению vc. Если первый, т.е. vc всё ещё None, присоединяемся к войсчату, сохраняем ссылку на ctx.voice_client в vc, выполняем run_play_song().
В любом случае, добавляем полученную ссылку (url) в очередь.
3. Второй вызов команды !play. Так как vc уже не None, то только кладём url в очередь. play_song() уже работает, она об этой ссылке позаботится, используя сохранённый в vc объект voice_chat.
Вот и всё!