CgV,pddlmZddlmZmZddlmZmZddlm Z ddl m Z ddl Z ddl Z ddlZddlZddlmZmZdd lmZmZmZmZmZmZGd d eZd Zdd ZdZdZdZ dZ!dZ"dZ#eddZ$eddZ%e ddZ&e ddZ'gdZ(y))unicode_literals)get_outgoing_edges topo_sort) basestringconvert_kwargs_to_cmd_line_args)str)reduceN)inputoutput)get_stream_spec_nodes FilterNode GlobalNode InputNode OutputNodeoutput_operatorceZdZfdZxZS)Errorcftt| dj|||_||_y)Nz'{} error (see stderr output for detail))superr__init__formatstdoutstderr)selfcmdrr __class__s T/var/www/it7/html/youtubeDownloader/venv/lib/python3.12/site-packages/ffmpeg/_run.pyrzError.__init__s0 eT# 5 < 1sn T//1D1DD EF  ! !d445 4#5#5yA ::ff %%rcVdj||j|jfS)Nz[{}])rr5r6)r9r:s r_format_output_stream_namer@@s' ==););T=P=P)PQ RRrc.|j}t||}|Dcgc]}t||}}|Dcgc]}t||}}dj dj ||j |dj |}|Scc}wcc}w)Nz{}{}{}r4)incoming_edgesrr>r@rjoin _get_filter) nodeoutgoing_edge_mapr9rBoutgoing_edgesr:inputsoutputs filter_specs r_get_filter_specrKDs((N'.?@NES=A!/48FGU>B"?D9G// )).92777;KK s B Bcd}|D]l}||}t|jD]I\}}t|dkDrtdj ||dj ||||f<|dz }Kny)NrrzpEncountered {} with multiple outgoing edges with same upstream label {!r}; a `split` filter is probably requiredzs{})sorteditemslenr.r) filter_nodesoutgoing_edge_mapsr9 stream_countr5rFr6 downstreamss r_allocate_filter_stream_namesrTSsL%  .}=+12C2I2I2K+L  'NK;!# ::@&%~; >C\\,=WOM>9 : A L  rct||||Dcgc]}t||||}}dj|Scc}w)N;)rTrKrC)rPrQr9rE filter_specss r_get_filter_argrXdsS!,0BOT!  1$7IL 88L !! s<c,t|jS)N)listr1)rEs r_get_global_argsr[ms  ?rch|jtjk7rtdj |g}t |j dk(rtdj ||j D]5}t||d}|dk7st |j dkDs/|d|gz }7tj|j}|jd }d |vr|d |jd gz }d |vr|d t|jd gz }d|vr|dt|jdgz }d|vrZ|jd}t|ts2t|tjrdj |d|d}|d|gz }|t!|z }||gz }|S)NzUnsupported output node: {}rz$Output node {} has no mapped streamsT)r;0rz-mapr%rr' video_bitratez-b:v audio_bitratez-b:ar&r)r()r*r r r.rrOrBr>r+r,r-r r8r collectionsIterabler)rEr9r1r: stream_namer,r%r&s r_get_output_argsrcqs yyFOO#6==dCDD D 4  1$?FFtLMM##*/ T  # T%8%8!9A!= V[) )D *YYt{{ #Fzz*%H6 vzz(+,,&  VZZ89::&  VZZ89::vZZ - *j1j  ,,7 ! 1 z!}EJ  ++ +F 33DXJD Krc Xt|}g}t|\}}|Dcgc]}t|ts|}}|Dcgc]}t|ts|}}|Dcgc]}t|t s|} }|Dcgc]}t|t s|} }t|D cic]\} }|dft| } } }t| || } |ttj|Dcgc] }t|c}z }| r|d| gz }|ttj|Dcgc]}t|| c}z }|ttj| Dcgc] }t|c}gz }|r|dgz }|Scc}wcc}wcc}wcc}wcc}} wcc}wcc}wcc}w)z4Build command-line arguments to be passed to ffmpeg.Nz-filter_complexz-y)r rr8rrrr enumerater rXr operatoraddr2rcr[) stream_specoverwrite_outputnodesr1 sorted_nodesrQrE input_nodes output_nodes global_nodesrPir9 filter_args rget_argsrqs "+ .E D'0'7$L$$0PDJtY4O4PKP%1RTZj5QDRLR%1RTZj5QDRLR%1RTZj5QDRLR;D[;QR4d|SV+ROR /A?SJF8<X D F8<<\!RT"24"8!RTV WWD  KQRRRR!PY!RsFFFFF F 6F FF*F+F (F" F' ct|tr|g}nt|tk7r t|}|t ||zS)aBuild command-line for invoking ffmpeg. The :meth:`run` function uses this to build the commnad line arguments and should work in most cases, but calling this function directly is useful for debugging or if you need to invoke ffmpeg manually for whatever reason. This is the same as calling :meth:`get_args` except that it also includes the ``ffmpeg`` command as the first argument. ri)r8rtyperZrq)rhrris rcompilerus=#z"e cd 3i +8HI IIrct|||}|rtjnd}|s|rtjnd} |s|rtjnd} tj||| | S)aD Asynchronously invoke ffmpeg for the supplied node graph. Args: pipe_stdin: if True, connect pipe to subprocess stdin (to be used with ``pipe:`` ffmpeg inputs). pipe_stdout: if True, connect pipe to subprocess stdout (to be used with ``pipe:`` ffmpeg outputs). pipe_stderr: if True, connect pipe to subprocess stderr. quiet: shorthand for setting ``capture_stdout`` and ``capture_stderr``. **kwargs: keyword-arguments passed to ``get_args()`` (e.g. ``overwrite_output=True``). Returns: A `subprocess Popen`_ object representing the child process. Examples: Run and stream input:: process = ( ffmpeg .input('pipe:', format='rawvideo', pix_fmt='rgb24', s='{}x{}'.format(width, height)) .output(out_filename, pix_fmt='yuv420p') .overwrite_output() .run_async(pipe_stdin=True) ) process.communicate(input=input_data) Run and capture output:: process = ( ffmpeg .input(in_filename) .output('pipe':, format='rawvideo', pix_fmt='rgb24') .run_async(pipe_stdout=True, pipe_stderr=True) ) out, err = process.communicate() Process video frame-by-frame using numpy:: process1 = ( ffmpeg .input(in_filename) .output('pipe:', format='rawvideo', pix_fmt='rgb24') .run_async(pipe_stdout=True) ) process2 = ( ffmpeg .input('pipe:', format='rawvideo', pix_fmt='rgb24', s='{}x{}'.format(width, height)) .output(out_filename, pix_fmt='yuv420p') .overwrite_output() .run_async(pipe_stdin=True) ) while True: in_bytes = process1.stdout.read(width * height * 3) if not in_bytes: break in_frame = ( np .frombuffer(in_bytes, np.uint8) .reshape([height, width, 3]) ) out_frame = in_frame * 0.3 process2.stdin.write( frame .astype(np.uint8) .tobytes() ) process2.stdin.close() process1.wait() process2.wait() .. _subprocess Popen: https://docs.python.org/3/library/subprocess.html#popen-objects rsN)stdinrr)ru subprocessPIPEPopen) rhr pipe_stdin pipe_stdout pipe_stderrquietrir1 stdin_stream stdout_stream stderr_streams r run_asyncrs[n ;6F GD&0:??dL'2eJOOM'2eJOOM    L} rc t|||du||||}|j|\}} |j} | r td|| || fS)a7Invoke ffmpeg for the supplied node graph. Args: capture_stdout: if True, capture stdout (to be used with ``pipe:`` ffmpeg outputs). capture_stderr: if True, capture stderr. quiet: shorthand for setting ``capture_stdout`` and ``capture_stderr``. input: text to be sent to stdin (to be used with ``pipe:`` ffmpeg inputs) **kwargs: keyword-arguments passed to ``get_args()`` (e.g. ``overwrite_output=True``). Returns: (out, err) tuple containing captured stdout and stderr data. N)r{r|r}r~riffmpeg)r communicatepollr) rhrcapture_stdoutcapture_stderrr r~riprocessouterrretcodes rrunr!sd0 $"")G""5)HCllnGHc3'' 8Or)rurrqrr)F)rF)rFFFFF)rFFNFF)) __future__rdagrr_utilsrrbuiltinsr functoolsr r`r+rfrx_ffmpegr r rjr rrrrr Exceptionrr2r>r@rKrTrXr[rcrqrurr__all__rrrs'.? "I$ &S ""!H0JJ$  \\~   $$N ?r