python - 线程中的线程

Question

我的公司正在致力于视觉效果，我们通过浏览器为我们的客户设置了内部镜头回放。为此，我们需要将视频文件上传到 FTP 服务器。

我想将图像序列转换为 mp4并在渲染完成后直接上传此文件。

为此，我使用:

一个命令提示符转换

一个命令提示符获取 `md5hash

一种用于上传文件

我已经在我的本地计算机上实现了这一点，我只是在其中链接了 os.system('command') .

在认识到程序因较长的图像序列而卡住很长时间后，我更改了脚本以使用 os.system 生成一个线程。链。
但在 Render Farm Server 上，此脚本实际上不起作用。

RenderFarm 服务器运行 Python 2.5

有一些代码示例:

class CopraUpload(threading.Thread):

    # initializing Thread
    # via super constructor
    def __init__(self):
        threading.Thread.__init__(self)


    # return the size of the
    # created mp4 file
    #
    # @return: the file size in byte
    def _getFileSize(self):


    # creates a random id for organising
    # the server upload used as flag
    #
    # @return: a hash
    def _getHash(self):
            self.fileLoc = str(self.outputfileName + '.mp4')
            self.fileLoc = os.path.normpath(self.fileLoc)
            return str(os.path.getsize(self.fileLoc))

    # integrates the "missing" data for the xml file
    # generated post render from the mp4 file
    def _setPreviewDataToXML(self):
        self.xmlFile = str(self.outputfileName + '_copraUpload.xml')
        self.xmlFile = os.path.normpath(self.xmlFile)

        ett = ET.parse(self.xmlFile)
        root = ett.getroot()
        for child in root.getiterator('preview_size'):
            child.text = self._getFileSize()
        for child in root.getiterator('preview_md5hash'):
            child.text = self._getHash()
        ett.write(self.xmlFile)


    # create a connection to a ftp server
    # and copies the mp4 file and the xml file
    # on the server
    def _uploadToCopra(self):

        os.system(self.uploadCommand)
        #process = Popen(self.uploadCommand)


    # the main function of the program
    # called via start from a Thread Object
    def run(self):

        # the command which will be send to the commando shell
        # for further adjustments see ffmpeg help with ffmpeg.exe -h
        FinalCommand = self.ffmpegLocation + " -r "+ self.framerate + " -i " + self.inputPath + " -an -strict experimental -s hd720 -vcodec libx264 -preset slow -profile:v baseline -level 31 -refs 1 -maxrate 6M -bufsize 10M -vb 6M -threads 0 -g 8 -r " + self.framerate + " " + self.outputfileName + ".mp4 -y"
        FinalCommandList = FinalCommand.split(" ")


        # calling the program
        print "Start ffmpeg convertion"

        outInfo = os.path.normpath("C:\\Users\\sarender\\Desktop\\stdoutFFMPEG.txt")
        outError = os.path.normpath("C:\\Users\\sarender\\Desktop\\stderrFFMPEG.txt")
        stdoutFile = open(outInfo,"w")
        stderrFile = open(outError,"w")

        handle = subp.check_all(FinalCommandList,stdout = stdoutFile,stderr = stderrFile)
        handle.communicate()
        stdoutFile.close()
        stderrFile.close()
        print "Convertion from ffmpeg done"

        # fill the xml file with the missing data
        # - preview file size
        # - preview md5hash
        self._setPreviewDataToXML()
        self._uploadToCopra()
        print "---------------------------------->FINISHED------------------------------------------------------>"


    # Creates a callable Thread for the Copra Upload.
    # start is calling the run method which will start the Uploading

和主要开始:

    if "$(RenderSet.writenode)" == "PREVIEW":
        print "---------------------------------->Initializing Script------------------------------------------------------>"
        process = CopraUpload()
        process.start()

怎么了:

脚本在渲染后开始， ffmpeg转换图像序列并创建 mp4 .但在那之后它就停止了。它不打印 "Conversion from ffmpeg complet" .只是停止脚本。

它实际上应该使用 ffmpeg 创建线程转换并等到它完成。在它应该在一个 xml 文件中写入一些东西并将它们上传到服务器之后。

我错过了什么吗？是 subprocess在一个线程内不是要走的路吗？但我需要一个线程，因为我不能死锁渲染管理服务器。

Answer 1

我的猜测是命令失败并在 handle.communicate() 中引发异常.确保捕获所有异常并将它们记录在某处，因为线程无法传递异常。

此外，您不应该使用 FinalCommand.split(" ") - 如果文件名包含空格，这将以奇怪(且不可预测)的方式失败。创建一个列表，而不是将该列表传递给 subp :

FinalCommand = [
    self.ffmpegLocation,
    "-r", self.framerate,
    "-i", self.inputPath,
    "-an",
    "-strict experimental",
    ...
]

也更具可读性。