我正在尝试使用ffmpeg创建视频文件,使用在单独线程上动态创建的帧
虽然我可以创建这些帧并将它们存储在磁盘/内存中,但我希望避免这种情况,因为帧的数量/大小可能很高,许多“作业”可以使用不同的格式或选项创建。但是,同样重要的是,我想更好地理解这背后的逻辑,因为我承认我对线程/处理实际上是如何工作的还不是很了解
现在我正在尝试在QThread对象中创建QProcess,然后在进程启动后运行映像创建线程,但它似乎不起作用:没有创建任何文件,我甚至没有从标准错误中获得任何输出(但我知道我应该这样做,因为如果我不使用线程,我可以获得它)
不幸的是,由于我对QProcess如何处理线程和管道(以及所有可能的ffmpeg选项)知之甚少,我真的不明白如何实现这一点
除了获得创建的输出文件外,预期的结果是能够启动编码(同时可能对更多编码进行排队),同时保持UI响应并获得当前处理状态的通知
import re
from PyQt5 import QtCore, QtGui, QtWidgets
logRegExp = r'(?:(n:\s+)(?P<frame>\d+)\s).*(?:(pts_time:\s*)(?P<time>\d+.\d*))'
class Encoder(QtCore.QThread):
completed = QtCore.pyqtSignal()
frameDone = QtCore.pyqtSignal(object)
def __init__(self, width=1280, height=720, frameCount=100):
super().__init__()
self.width = width
self.height = height
self.frameCount = frameCount
def start(self):
self.currentLog = ''
self.currentData = bytes()
self.process = QtCore.QProcess()
self.process.setReadChannel(self.process.StandardError)
self.process.finished.connect(self.completed)
self.process.readyReadStandardError.connect(self.stderr)
self.process.started.connect(super().start)
self.process.start('ffmpeg', [
'-y',
'-f', 'png_pipe',
'-i', '-',
'-c:v', 'libx264',
'-b:v', '800k',
'-an',
'-vf', 'showinfo',
'/tmp/test.h264',
])
def stderr(self):
self.currentLog += str(self.process.readAllStandardError(), 'utf-8')
*lines, self.currentLog = self.currentLog.split('\n')
for line in lines:
print('STDERR: {}'.format(line))
match = re.search(logRegExp, line)
if match:
data = match.groupdict()
self.frameDone.emit(int(data['frame']))
def run(self):
font = QtGui.QFont()
font.setPointSize(80)
rect = QtCore.QRect(0, 0, self.width, self.height)
for frame in range(1, self.frameCount + 1):
img = QtGui.QImage(QtCore.QSize(self.width, self.height), QtGui.QImage.Format_ARGB32)
img.fill(QtCore.Qt.white)
qp = QtGui.QPainter(img)
qp.setFont(font)
qp.setPen(QtCore.Qt.black)
qp.drawText(rect, QtCore.Qt.AlignCenter, 'Frame {}'.format(frame))
qp.end()
img.save(self.process, 'PNG')
print('frame creation complete')
class Test(QtWidgets.QWidget):
def __init__(self):
super().__init__()
layout = QtWidgets.QVBoxLayout(self)
self.startButton = QtWidgets.QPushButton('Start')
layout.addWidget(self.startButton)
self.frameLabel = QtWidgets.QLabel()
layout.addWidget(self.frameLabel)
self.process = Encoder()
self.process.completed.connect(lambda: self.startButton.setEnabled(True))
self.process.frameDone.connect(self.frameLabel.setNum)
self.startButton.clicked.connect(self.create)
def create(self):
self.startButton.setEnabled(False)
self.process.start()
import sys
app = QtWidgets.QApplication(sys.argv)
test = Test()
test.show()
sys.exit(app.exec_())
如果我在run()
的末尾添加以下行,那么实际上创建了文件,我得到了stderr输出,但是我可以看到它是在for循环完成后处理的,这显然不是预期的结果:
self.process.closeWriteChannel()
self.process.waitForFinished()
self.process.terminate()
好处:我在Linux上,我不知道它在Windows上是否有不同的工作方式(我假设它在MacOS上也会有类似的工作方式),但无论如何,我想知道是否有不同,以及如何处理它们
事实证明,我有一部分是对的,一部分是错的
考虑到上述情况,我只使用线程创建图像,然后使用保存的每个图像的QByteArray发出信号;最后,在图像创建完成后,我等待实际完成(基于
showinfo
过滤器输出),以便线程在该点实际被视为已完成。在多个作业的情况下,可以使用一些优化来排队进一步创建映像,但考虑到这可能不会大大提高性能,我更喜欢当前的方法这是修改后的代码,我用不同的格式进行了测试,它似乎可以按预期工作
相关问题 更多 >
编程相关推荐