mirror of
https://github.com/matthew1000/gstreamer-cheat-sheet.git
synced 2024-11-22 00:10:59 +00:00
50 lines
1.5 KiB
Python
Executable file
50 lines
1.5 KiB
Python
Executable file
#!/usr/bin/env python
|
||
# Shows how two pipelines can be connected, using proxysink/proxysrc
|
||
# This example uses Playbin to read a file, and send the video and audio to separate proxies.
|
||
# Unlike just using playbin directly, this will never end, as the other pipelines will continue 'listening'.
|
||
import gi
|
||
gi.require_version('Gst', '1.0')
|
||
from gi.repository import GObject, Gst
|
||
import os
|
||
|
||
Gst.init(None)
|
||
mainloop = GObject.MainLoop()
|
||
|
||
pipe1 = Gst.parse_launch("playbin uri=\"file://" + os.environ['SRC'] + "\"")
|
||
playsink = pipe1.get_by_name('playsink')
|
||
|
||
psink1 = Gst.ElementFactory.make("proxysink", "psink1")
|
||
psink2 = Gst.ElementFactory.make("proxysink", "psink2")
|
||
playsink.set_property('video-sink', psink1)
|
||
playsink.set_property('audio-sink', psink2)
|
||
|
||
pipe2 = Gst.parse_launch("proxysrc name=psrc1 ! autovideosink")
|
||
psrc1 = pipe2.get_by_name('psrc1')
|
||
psrc1.set_property('proxysink', psink1)
|
||
|
||
pipe3 = Gst.parse_launch("proxysrc name=psrc2 ! autoaudiosink")
|
||
psrc2 = pipe3.get_by_name('psrc2')
|
||
psrc2.set_property('proxysink', psink2)
|
||
|
||
clock = Gst.SystemClock.obtain()
|
||
pipe1.use_clock(clock)
|
||
pipe2.use_clock(clock)
|
||
pipe3.use_clock(clock)
|
||
clock.unref()
|
||
|
||
pipe1.set_base_time(0)
|
||
pipe2.set_base_time(0)
|
||
pipe3.set_base_time(0)
|
||
|
||
pipe1.set_state(Gst.State.PLAYING)
|
||
pipe2.set_state(Gst.State.PLAYING)
|
||
pipe3.set_state(Gst.State.PLAYING)
|
||
|
||
def on_error(bus, message):
|
||
print(message.parse_error())
|
||
|
||
bus1 = pipe1.get_bus()
|
||
bus1.add_signal_watch()
|
||
bus1.connect('message::error', on_error)
|
||
|
||
mainloop.run()
|