video.py 文件源码

def run(self):
        filename = '.' + filename_tmpl.format(self.date, 0, self.extension)
        print('Starting new video File [{}]'.format(filename))
        video = cv2.VideoWriter(filename, self.fourcc, self.fps, self.size)
        while True:
            f = self.queue.get()
            if f is QueueFinished:
                self.queue.task_done()
                break
            video.write(f)
            self.queue.task_done()
        duration = (datetime.now() - self.date).total_seconds()
        new_filename = filename_tmpl.format(self.date, round(duration), self.extension)
        print('Releasing resources for [{}] and renaming it to [{}]'.format(filename, new_filename))
        video.release()
        os.rename(filename, new_filename)
        try:
            redis.publish('video:new', new_filename)
        except:
            print("Error publishing {} to redis".format(new_filename), file=sys.stderr)