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()