Youtube-dl 在 python-rq 任务中监控状态
Youtube-dl monitoring status while in python-rq task
我正在尝试轮询以查看 youtube-dl 作业的状态。我无法弄清楚如何让它工作。
以下是我的python-rqworker.py文件
class MyLogger(object):
def debug(self, msg):
pass
def warning(self, msg):
pass
def error(self, msg):
print(msg)
def my_hook(d):
if d['status'] == 'finished':
print('Done downloading, now converting ...')
ydl_opts = {
'format': 'bestaudio/best', # choice of quality
'extractaudio' : True, # only keep the audio
'outtmpl': temp_filepath, # name the location
'noplaylist' : True, # only download single song, not playlist
'prefer-ffmpeg' : True,
'postprocessors': [{
'key': 'FFmpegExtractAudio',
'preferredcodec': 'mp3',
}],
'logger': MyLogger(),
'progress_hooks': [my_hook],
}
with youtube_dl.YoutubeDL(ydl_opts) as ydl:
result = ydl.download([url])
在我的主应用程序中,我尝试了所有变体,但似乎仍然无法获得 logger/my_hook 输出。
job = q.fetch_job(job_id)
一旦我有了 job_id,我似乎唯一能得到的就是 job.result,如果它还没有完成 returns None
,我尝试打印以查看状态,但似乎无法找到它。
我可能正在考虑让 my_hood 或记录器写入一个单独的临时文件,我可以读取该行,但我认为这可能过分了?
任何帮助或可能的解决方法将不胜感激。
在 github 问题的帮助下,我能够使用 get_current_job 更新它并将其传递给 meta。
class MyLogger(object):
def debug(self, msg):
print(msg)
job = get_current_job()
job.meta['progress'] = msg
job.save()
我正在尝试轮询以查看 youtube-dl 作业的状态。我无法弄清楚如何让它工作。
以下是我的python-rqworker.py文件
class MyLogger(object):
def debug(self, msg):
pass
def warning(self, msg):
pass
def error(self, msg):
print(msg)
def my_hook(d):
if d['status'] == 'finished':
print('Done downloading, now converting ...')
ydl_opts = {
'format': 'bestaudio/best', # choice of quality
'extractaudio' : True, # only keep the audio
'outtmpl': temp_filepath, # name the location
'noplaylist' : True, # only download single song, not playlist
'prefer-ffmpeg' : True,
'postprocessors': [{
'key': 'FFmpegExtractAudio',
'preferredcodec': 'mp3',
}],
'logger': MyLogger(),
'progress_hooks': [my_hook],
}
with youtube_dl.YoutubeDL(ydl_opts) as ydl:
result = ydl.download([url])
在我的主应用程序中,我尝试了所有变体,但似乎仍然无法获得 logger/my_hook 输出。
job = q.fetch_job(job_id)
一旦我有了 job_id,我似乎唯一能得到的就是 job.result,如果它还没有完成 returns None
,我尝试打印以查看状态,但似乎无法找到它。
我可能正在考虑让 my_hood 或记录器写入一个单独的临时文件,我可以读取该行,但我认为这可能过分了? 任何帮助或可能的解决方法将不胜感激。
在 github 问题的帮助下,我能够使用 get_current_job 更新它并将其传递给 meta。
class MyLogger(object):
def debug(self, msg):
print(msg)
job = get_current_job()
job.meta['progress'] = msg
job.save()