Свой прогресс в консоли при выполнении команды ffmpeg

[Zuldek]

import subprocess as sub
from tqdm import tqdm

process = sub.Popen("ffmpeg -i /240.mp4 -c:v libaom-av1 -pix_fmt yuv420p /output.mkv", shell=True, stdout=sub.PIPE, stderr=sub.PIPE, text=True)
with tqdm(total=100, desc="Processing", unit="%", ncols=100) as pbar:
    output = process.stdout.readline()
    error = process.stderr.readline()
    print(output)

Как выполнить прогресс в своем шаблоне?
В данном примере команда выполняется, но никакого прогресса не наблюдается. Просто зависает в консоле

Processing:   0%|                                                            | 0                        /100 [00:00<?, ?%/s]

И так до окончания...

[BDA]

Чтобы прогресс шел, нужно вызывать pbar.update с нужным значением. По запросу "ffmpeg and tqdm" нашлось несколько сниппетов и библиотек. Например, сниппет - изучите функцию ffmpeg_to_tqdm. Или библиотека ffmpeg-progress-yield - изучите пример с использованием tqdm. Или библиотека ffmpeg-python - изучите пример отображения прогресса (похоже, только для Linux).

[Zuldek]

Установил

pip install ffmpeg-progress-yield --root-user-action=ignore

Далее выполняю команду

from ffmpeg_progress_yield import FfmpegProgress
ff = FfmpegProgress(["ffmpeg", "-i", "/240.mp4", "-c:v", "libaom-av1", "-pix_fmt", "yuv420p", "-f", "/output.mkv",])
for progress in ff.run_command_with_progress():
    print(f"{progress}/100")

Выдает ошибку

Traceback (most recent call last):
  File "/var/www/c.py", line 44, in <module>
    for progress in ff.run_command_with_progress():
                    ~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^
  File "/usr/local/lib/python3.13/dist-packages/ffmpeg_progress_yield/ffmpeg_progress_yield.py", line 302, in run_command_with_progress
    raise RuntimeError(f"Error running command {self.cmd}: {self.stderr}")
RuntimeError: Error running command ['ffmpeg', '-i', '/240.mp4', '-c:v', 'libaom-av1', '-pix_fmt', 'yuv420p', '-f', '/output.mkv']: ffmpeg version 7.0.2 Copyright (c) 2000-2024 the FFmpeg developers

Не шибко разбираюсь во всем этом, но очень хочу разобраться в чем тут дело...

[Zuldek]

Не понимаю, при установке как я понял, выдает что та про права root. Я добавляю

--root-user-action=ignore

Ок, но зачем, когда я и так авторизован в ssh под root пользоватлем?

[Zuldek]

process = sub.Popen("ffmpeg -i /240.mp4 -c:v libaom-av1 -pix_fmt yuv420p /output.mkv", shell=True, stdout=sub.PIPE, stderr=sub.PIPE, text=True)
with tqdm(total=100, desc="Processing", unit="%", ncols=100) as pbar:
    pbar.update(1)
    output = process.stdout.readline()
    error = process.stderr.readline()
    print(output)

попробовал данный вариант, тоже самое...

[BDA]

import subprocess as sub
from tqdm import tqdm
import re

re_duration = re.compile("Duration: ((?:\d+:)+\d+)")
re_time = re.compile("\stime=((?:\d+:)+\d+)")

def strtime_to_seconds(s):
    hours, minutes, seconds = (float(_) for _ in s.split(':'))
    return (hours * 60 + minutes) * 60 + seconds

process = sub.Popen("ffmpeg -y -i input.mp4 -c:v libaom-av1 -pix_fmt yuv420p output.mkv", shell=True, stdout=sub.PIPE, stderr=sub.STDOUT, text=True)

for s in process.stdout:
    m = re_duration.search(s)
    if m:
        duration = strtime_to_seconds(m.group(1))
        break

previous_span = 0
with tqdm(total=duration, desc="Processing", unit="%") as pbar:
    for s in process.stdout:
        ms = [*re_time.finditer(s)]
        if ms:
            in_seconds = strtime_to_seconds(ms[-1].group(1)) - previous_span
            previous_span += in_seconds
            pbar.update(in_seconds)

[Zuldek]

Спасибо. Все как то запудрено, работает. Возможно проще сделать?

process = sub.Popen("ffmpeg -y -i /240.mp4 -c:v libaom-av1 -pix_fmt yuv420p /output.mkv", shell=True, stdout=sub.PIPE, stderr=sub.STDOUT, text=True)
output = ''
with tqdm(total=duration, desc="Processing", unit="%") as pbar:
    #for r in process.stderr:
    #    error += r.rstrip('\n')
    #    print(error+'error')

    for s in process.stdout:
        output += s.rstrip('\n')
        print(s.rstrip('\n'))
        time.sleep(0.1)

Все тоже самое в консоли выводить как и ранее.
В моем примере просто берет строчку из процесса через time.sleep(0.1). Как узнать что произошло что то нестандартное в процессе? Если есть ошибка, взять все что в переменной и в месте с ошибкой записать в файл. Не в процессе записать, а по окончанию. Когда процесс к примеру был остановлен по ошибке, либо что то не критичное произошло, что не остановило процесс преобразования...

def twrite(log_F, text, tp = 'a+'):
	z = open(log_F, tp, encoding = "utf-8")
	z.write(text)
	z.close()