Взгляните на мою оболочку модуля gst
: https://github.com/vmlaker/gstwrap
Обратите внимание, что ветвление и мультиплексирование определяются тщательным связыванием элементов.Ваш конкретный конвейер тогда:
from gstwrap import Element, Pipeline
ee = (
# From src to sink [0:5]
Element('v4l2src'),
Element('capsfilter', [('caps','video/x-raw-yuv,framerate=30/1,width=640,height=360')]),
Element('tee', [('name', 't_vid')]),
Element('queue'),
Element('videoflip', [('method', 'horizontal-flip')]),
Element('xvimagesink', [('sync', 'false')]),
# Branch 1 [6:9]
Element('queue'),
Element('videorate'),
Element('capsfilter', [('caps', 'video/x-raw-yuv,framerate=30/1')]),
Element('queue'),
# Branch 2 [10:15]
Element('alsasrc'),
Element('capsfilter', [('caps', 'audio/x-raw-int,rate=48000,channels=2,depth=16')]),
Element('queue'),
Element('audioconvert'),
Element('queue'),
# Muxing
Element('avimux', [('name', 'mux')]),
Element('filesink', [('location', 'me_dancing_funny.avi')]),
)
pipe = Pipeline()
for index in range(len(ee)):
pipe.add(ee[index])
ee[0].link(ee[1])
ee[1].link(ee[2])
ee[2].link(ee[3])
ee[3].link(ee[4])
ee[4].link(ee[5])
# Branch 1
ee[2].link(ee[6])
ee[6].link(ee[7])
ee[7].link(ee[8])
ee[8].link(ee[9])
# Branch 2
ee[10].link(ee[11])
ee[11].link(ee[12])
ee[12].link(ee[13])
ee[13].link(ee[14])
ee[14].link(ee[15])
# Muxing
ee[9].link(ee[15])
ee[15].link(ee[16])
print(pipe)
pipe.start()
raw_input('Hit <enter> to stop.')