This package supports FFmpeg asynchronously invoke with async / await pattern wrapping ffmpeg.run_async() of ffmpeg-python and returned subprocess.Popen.

import asyncio from ffmpeg import Progress from ffmpeg.asyncio import FFmpeg async def main(): ffmpeg = ( FFmpeg() .option("y") .input("input.mov") .output( "output.mp4", codec="copy", ) ) @ffmpeg.on("progress") async def on_progress(progress: Progress): await asyncio.sleep(1) print(progress) ...

from ffmpeg import FFmpeg, Progress def main(): ffmpeg = ( FFmpeg() .option("y") .input( "rtsp://username:password@127.0.0.1/cam", rtsp_transport="tcp", rtsp_flags="prefer_tcp", ) .output("output.mp4", vcodec="copy") ) @ffmpeg.on("progress") def time_to_terminate(progress: Progress): if progress.frame > 200: ffmpeg.terminate() ffmpeg.execute() if __name__ == "__main__": main() import asyncio from ffmpeg import Progress from ffmpeg.asyncio import FFmpeg async def main(): ffmpeg = ( FFmpeg() .option("y") .input( "rtsp://username:password@127.0.0.1/cam", rtsp_transport="tcp", rtsp_flags="prefer_tcp", ) .output("output.mp4", vcodec="copy") ) @ffmpeg.on("progress") def time_to_terminate(progress: Progress): if progress.frame > 200: ffmpeg.terminate() await ffmpeg.execute() if __name__ == "__main__": asyncio.run(main())

May 18, 2024 - import asyncio from ffmpeg_asyncio import FFmpeg, Progress async def main(): ffmpeg = ( FFmpeg() .input("input.mp4") .output("output.mp4") ) @ffmpeg.on("progress") def on_progress(progress: Progress): print(progress) @ffmpeg.on("completed") ...

Asynchronously invoke ffmpeg for the supplied node graph.

from ffmpeg import FFmpeg, Progress def main(): ffmpeg = ( FFmpeg() .option("y") .input( "rtsp://username:password@127.0.0.1/cam", rtsp_transport="tcp", rtsp_flags="prefer_tcp", ) .output("output.mp4", vcodec="copy") ) @ffmpeg.on("progress") def time_to_terminate(progress: Progress): if progress.frame > 200: ffmpeg.terminate() ffmpeg.execute() if __name__ == "__main__": main() import asyncio from ffmpeg import Progress from ffmpeg.asyncio import FFmpeg async def main(): ffmpeg = ( FFmpeg() .option("y") .input( "rtsp://username:password@127.0.0.1/cam", rtsp_transport="tcp", rtsp_flags="prefer_tcp", ) .output("output.mp4", vcodec="copy") ) @ffmpeg.on("progress") def time_to_terminate(progress: Progress): if progress.frame > 200: ffmpeg.terminate() await ffmpeg.execute() if __name__ == "__main__": asyncio.run(main())

import asyncio from ffmpeg import Progress from ffmpeg.asyncio import FFmpeg async def main(): ffmpeg = ( FFmpeg() .option("y") .input("input.mov") .output( "output.mp4", codec="copy", ) ) @ffmpeg.on("progress") async def on_progress(progress: Progress): await asyncio.sleep(1) print(progress) ...

import asyncio import signal import os from subprocess import PIPE, Popen async def recScreen(): cmd = 'ffmpeg -f gdigrab -framerate 30 -i desktop output.mkv' process = Popen(cmd) await asyncio.sleep(15) print("Done sleep") process.terminate() ...

probe_coroutine.py: retrieve file metadata in asynchronous pipeline or list using Python asyncio coroutines. Testing asynchronous techniques with video playback makes some effects obvious. The FFplay asyncio example is more advanced than the FFprobe example. In the FFprobe example, the lazy asyncio generator produces metadata concurrently as fast as it's requested.

Source code in ffmpeg/asyncio/ffmpeg.py · Execute FFmpeg using specified global options and files. Parameters: Raises: Returns: Source code in ffmpeg/asyncio/ffmpeg.py · Gracefully terminate the running FFmpeg process. Raises: Source code in ffmpeg/asyncio/ffmpeg.py ·

November 7, 2025 - Welcome to my special sauce fork of ffmpeg-python, with asyncio support.

December 18, 2024 - import httpx client = httpx.AsyncClient() async def write_input( client: httpx.AsyncClient, video_link: str, process: asyncio.subprocess.Process ) -> None: async with client.stream("GET", video_link) as response: async for chunk in ...

May 4, 2019 - Now I'm working on Asynchronous application. And using asyncio library which is built in python3. And uses async/await syntax. Good to have possibility to return ffmpeg process as a coroutine and use it in a asyncio way. For example: pro...

import asyncio from ffmpeg_asyncio import FFmpeg, Progress async def main(): ffmpeg = ( FFmpeg() .input("input.mp4") .output("output.mp4") ) @ffmpeg.on("progress") def on_progress(progress: Progress): print(progress) @ffmpeg.on("completed") ...

>>> ff = ffmpy3.FFmpeg( ... inputs={'input.mp4': None}, ... outputs={'output.avi': None} ... ) >>> ff.run_async() >>> await ff.wait() ... See Examples section for usage examples.

Async Python bindings for FFmpeg - with complex filtering support - asyncio-ffmpeg/README.md at asyncio · regulad/asyncio-ffmpeg

packet_size = 4096 process = ( ffmpeg .input('rtsp://%s:8554/default') .output('-', format='h264') .run_async(pipe_stdout=True) ) while process.poll() is None: packet = process.stdout.read(packet_size) try: tcp_socket.send(packet) except ...

A fork of the excellent python-ffmpeg binding for FFmpeg, updated for native async API support only.

from ffmpeg import FFmpeg, Progress def main(): ffmpeg = ( FFmpeg() .option("y") .input( "rtsp://username:password@127.0.0.1/cam", rtsp_transport="tcp", rtsp_flags="prefer_tcp", ) .output("output.mp4", vcodec="copy") ) @ffmpeg.on("progress") def time_to_terminate(progress: Progress): if progress.frame > 200: ffmpeg.terminate() ffmpeg.execute() if __name__ == "__main__": main() import asyncio from ffmpeg import Progress from ffmpeg.asyncio import FFmpeg async def main(): ffmpeg = ( FFmpeg() .option("y") .input( "rtsp://username:password@127.0.0.1/cam", rtsp_transport="tcp", rtsp_flags="prefer_tcp", ) .output("output.mp4", vcodec="copy") ) @ffmpeg.on("progress") def time_to_terminate(progress: Progress): if progress.frame > 200: ffmpeg.terminate() await ffmpeg.execute() if __name__ == "__main__": asyncio.run(main())

from ffmpeg import FFmpeg, Progress def main(): ffmpeg = ( FFmpeg() .option("y") .input("input.mov") .output( "output.mp4", {"codec:v": "libx264", "filter:v": "scale=1280:-1"}, preset="veryslow", crf=24, ) ) @ffmpeg.on("progress") def on_progress(progress: Progress): print(progress) ffmpeg.execute() if __name__ == "__main__": main() import asyncio from ffmpeg import Progress from ffmpeg.asyncio import FFmpeg async def main(): ffmpeg = ( FFmpeg() .option("y") .input("input.mov") .output( "output.mp4", {"codec:v": "libx264", "filter:v": "scale=1280:-1"}, vf="scale=1280:-1", preset="veryslow", crf=24, ) ) @ffmpeg.on("progress") def on_progress(progress: Progress): print(progress) await ffmpeg.execute() if __name__ == "__main__": asyncio.run(main())