blackteay/ffmpeg-python
1
0
Fork 0
mirror of https://github.com/kkroening/ffmpeg-python.git synced 2025-04-06 04:15:44 +08:00
Code Issues Projects Releases Wiki Activity

Added an option to return immediately from run() so you could process the output of ffmpeg while it's processing

Browse Source
This commit is contained in:
Nitay Megides 2018-07-27 04:31:32 +03:00
parent b6f150c4c3
commit ce33461259
2 changed files with 36 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
README.md
View File

@ -32,6 +32,27 @@ import ffmpeg
) )
``` ```
You could also use pipes to direct the output of ffmpeg to a socket, a file or for processing in python
```python
import ffmpeg
out, err, subproc = (
ffmpeg
.input('rtsp://%s:8554/default')
.output('-', format='h264')
# wait=False means run() returns immediately and does not wait for ffmpeg process to end
.run(capture_stdout=True, wait=False)
)
packet_size = 4096
while subproc.poll() is None:
out_packet = out.read(packet_size)
try:
tcp_socket.send(out_packet)
except socket.error as e:
return
```
## Complex filter graphs ## Complex filter graphs
FFmpeg is extremely powerful, but its command-line interface gets really complicated really quickly - especially when working with signal graphs and doing anything more than trivial. FFmpeg is extremely powerful, but its command-line interface gets really complicated really quickly - especially when working with signal graphs and doing anything more than trivial.

22
ffmpeg/_run.py
View File

@ -186,7 +186,7 @@ def compile(stream_spec, cmd='ffmpeg', overwrite_output=False):
@output_operator() @output_operator()
def run( def run(
stream_spec, cmd='ffmpeg', capture_stdout=False, capture_stderr=False, input=None, stream_spec, cmd='ffmpeg', capture_stdout=False, capture_stderr=False, input=None,
quiet=False, overwrite_output=False): quiet=False, overwrite_output=False, wait=True):
"""Ivoke ffmpeg for the supplied node graph. """Ivoke ffmpeg for the supplied node graph.
Args: Args:
@ -196,21 +196,29 @@ def run(
quiet: shorthand for setting ``capture_stdout`` and ``capture_stderr``. quiet: shorthand for setting ``capture_stdout`` and ``capture_stderr``.
input: text to be sent to stdin (to be used with ``pipe:`` input: text to be sent to stdin (to be used with ``pipe:``
ffmpeg inputs) ffmpeg inputs)
wait: wait until the ffmpeg process is done before returning. If you're using pipes, you might
want this False
**kwargs: keyword-arguments passed to ``get_args()`` (e.g. **kwargs: keyword-arguments passed to ``get_args()`` (e.g.
``overwrite_output=True``). ``overwrite_output=True``).
Returns: (out, err) tuple containing captured stdout and stderr data. Returns: If wait is True (default), this function returns (out, err) tuple containing captured stdout and stderr data.
If wait is False, this function returns (out, err, popen) tuple containing the subprocess handle as well
""" """
args = compile(stream_spec, cmd, overwrite_output=overwrite_output) args = compile(stream_spec, cmd, overwrite_output=overwrite_output)
stdin_stream = subprocess.PIPE if input else None stdin_stream = subprocess.PIPE if input else None
stdout_stream = subprocess.PIPE if capture_stdout or quiet else None stdout_stream = subprocess.PIPE if capture_stdout or quiet else None
stderr_stream = subprocess.PIPE if capture_stderr or quiet else None stderr_stream = subprocess.PIPE if capture_stderr or quiet else None
p = subprocess.Popen(args, stdin=stdin_stream, stdout=stdout_stream, stderr=stderr_stream) p = subprocess.Popen(args, stdin=stdin_stream, stdout=stdout_stream, stderr=stderr_stream)
out, err = p.communicate(input) if wait:
retcode = p.poll() out, err = p.communicate(input)
if retcode: retcode = p.poll()
raise Error('ffmpeg', out, err) if retcode:
return out, err raise Error('ffmpeg', out, err)
return out, err
else:
out = p.stdout
err = p.stderr
return out, err, p
__all__ = [ __all__ = [