La lecture de l'audio et de la vidéo avec un Pipeline Gstreamer (Python)

J'ai construit un exemple lecteur vidéo qui permet d'utiliser les éléments que vous avez décrit.

Il devrait vous montrer comment connecter les plaquettes à l'eachother dynamiquement.

"' 
Copyright (c) 2011 Joar Wandborg 

L'autorisation est accordée à titre gratuit, à toute personne obtenant une copie de ce logiciel et des fichiers de documentation associés (le "Logiciel"), d'utiliser le Logiciel sans restriction, y compris, sans limitation, le droit d'utiliser, copier, modifier, fusionner, publier, distribuer, sous-licencier et/ou vendre des copies du Logiciel, et de permettre à des personnes à qui le Logiciel est fourni à le faire, sous réserve des conditions suivantes: 

L'avis de copyright ci-dessus et cet avis d'autorisation doivent être inclus dans toutes les copies ou parties substantielles du Logiciel. 

LE LOGICIEL EST FOURNI "TEL QUEL", SANS GARANTIE D'AUCUNE SORTE, EXPRESSE OU IMPLICITE, Y COMPRIS MAIS NON LIMITÉ AUX GARANTIES DE QUALITÉ MARCHANDE, D'ADÉQUATION À UN USAGE PARTICULIER ET D'ABSENCE DE CONTREFAÇON. EN AUCUN CAS LES AUTEURS OU LES DÉTENTEURS DES DROITS D'AUTEUR SERA TENU RESPONSABLE POUR TOUTE RÉCLAMATION, DOMMAGES OU DE TOUTE AUTRE RESPONSABILITÉ, QUE CE SOIT DANS UNE ACTION CONTRACTUELLE, DÉLICTUELLE OU AUTRE, DÉCOULANT DE, OU EN RELATION AVEC LE LOGICIEL OU L'UTILISATION OU D'AUTRES TRANSACTIONS DANS LE LOGICIEL. 

--- 

- Une réponse à la http://stackoverflow.com/questions/8187257/play-audio-and-video-with-a-pipeline-in-gstreamer-python/8197837 
- Plaît-il? Achetez-moi une bière! https://flattr.com/thing/422997/Joar-Wandborg 
"' 

l'importation de la tps 
importation gobject 
gobject.threads_init() 
l'importation de journalisation 


la journalisation.basicConfig() 

_log = logging.getLogger (___nom_) 
_log.setLevel(journalisation.DEBUG) 


classe VideoPlayer(objet): 
"' 
Lecteur vidéo Simple 
"' 

source_file = None 

def __init__(self, **kwargs): 
auto.boucle = gobject.MainLoop() 

si kwargs.get('src'): 
auto.source_file = kwargs.get('src') 

self.__setup() 

def run(self): 
auto.de la boucle.run() 

def stop(self): 
auto.de la boucle.quit() 

def __setup(self): 
_log.info ("Configuration des VideoPlayer...') 
self.__le programme d'installation_pipeline() 
_log.info ("mettre en place") 

def __installation_pipeline(self): 
auto.pipeline = tps.Pipeline('video-player-pipeline") 

# Élément Source 
auto.filesrc = tps.element_factory_make('filesrc') 
auto.filesrc.set_property('location', self.source_file) 
auto.pipeline.ajouter(de soi.filesrc) 

# Demuxer 
auto.décodeur = tps.element_factory_make('decodebin2') 
auto.décodeur.connect ("pad ajoutée", self.__sur_décodé_pad) 
auto.pipeline.ajouter(de soi.décodeur) 

# Des éléments de la vidéo 
auto.videoqueue = tps.element_factory_make('file', 'videoqueue') 
auto.pipeline.ajouter(de soi.videoqueue) 

auto.autovideoconvert = tps.element_factory_make('autovideoconvert') 
auto.pipeline.ajouter(de soi.autovideoconvert) 

auto.autovideosink = tps.element_factory_make('autovideosink') 
auto.pipeline.ajouter(de soi.autovideosink) 

# Les éléments Audio 
auto.audioqueue = tps.element_factory_make('file', 'audioqueue') 
auto.pipeline.ajouter(de soi.audioqueue) 

auto.audioconvert = tps.element_factory_make('audioconvert') 
auto.pipeline.ajouter(de soi.audioconvert) 

auto.autoaudiosink = tps.element_factory_make('autoaudiosink') 
auto.pipeline.ajouter(de soi.autoaudiosink) 

auto.progressreport = tps.element_factory_make('progressreport') 
auto.progressreport.set_property('update-freq', 1) 
auto.pipeline.ajouter(de soi.progressreport) 

# Lien de la source et de demuxer 
linkres = tps.element_link_many( 
auto.filesrc, 
auto.décodeur) 

si pas linkres: 
_log.erreur ("impossible de lien source & demuxer éléments!\n{0}'.format( 
linkres)) 

linkres = tps.element_link_many( 
auto.audioqueue, 
auto.audioconvert, 
auto.autoaudiosink) 

si pas linkres: 
_log.erreur ("impossible de lier des éléments audio!\n{0}'.format( 
linkres)) 

linkres = tps.element_link_many( 
auto.videoqueue, 
auto.progressreport, 
auto.autovideoconvert, 
auto.autovideosink) 

si pas linkres: 
_log.erreur ("impossible de lier des éléments de la vidéo!\n{0}'.format( 
linkres)) 

auto.bus = auto.pipeline.get_bus() 
auto.bus.add_signal_watch() 
auto.bus.connect('message', self.__sur_le message) 

auto.pipeline.set_state(tps.STATE_PLAYING) 

def __sur_décodé_pad(auto, pad, données): 
_log.debug('on_decoded_pad: {0}'.format(pad)) 

si pad.get_caps()[0].to_string().startswith('audio'): 
pavé.lien(de soi.audioqueue.get_pad('lavabo')) 
autre chose: 
pavé.lien(de soi.videoqueue.get_pad('lavabo')) 

def __sur_le message(auto, bus, message): 
_log.debug(' - MESSAGE: {0}'.format(message)) 


si __name__ == '__principaux__': 
joueur = VideoPlayer( 
src='/home/joar/Vidéos/big_buck_bunny_1080p_stereo.avi) 

joueur.run()

OriginalL'auteur joar

Je suis sûr que vous avez mises en œuvre. Mais pour les autres qui regarde votre question, ma réponse peut vous aider . Le code est comme suit

 #!/usr/bin/python
import pygst
pygst.require('0.10')
import gst
import pygtk
pygtk.require('2.0')
import gtk
# this is very important, without this, callbacks from gstreamer thread
# will messed our program up
def on_new_decoded_pad(dbin, pad, islast):
structure_name = pad.get_caps()[0].get_name()
decode = pad.get_parent()
pipeline = decode.get_parent()
if structure_name.startswith("video"):
queuev = pipeline.get_by_name('queuev')
decode.link(queuev)
if structure_name.startswith("audio"):
queuea = pipeline.get_by_name('queuea')
print queuea
decode.link(queuea)
def main():
pipeline = gst.Pipeline('pipleline')
filesrc = gst.element_factory_make("filesrc", "filesrc")
filesrc.set_property('location', '/home/thothadri/Videos/nuclear.avi')
decode = gst.element_factory_make("decodebin", "decode")
queuev = gst.element_factory_make("queue", "queuev")
sink = gst.element_factory_make("autovideosink", "sink")
queuea = gst.element_factory_make("queue", "queuea")
convert = gst.element_factory_make('audioconvert', 'convert')
sink_audio = gst.element_factory_make("autoaudiosink", "sink_audio")
pipeline.add(filesrc,decode,queuev,queuea,convert,sink,sink_audio)
gst.element_link_many(filesrc, decode)
gst.element_link_many(queuev,sink)
gst.element_link_many(queuea,convert,sink_audio)
decode.connect("new-decoded-pad", on_new_decoded_pad)
pipeline.set_state(gst.STATE_PLAYING)
main()
gtk.gdk.threads_init()
gtk.main()  

OriginalL'auteur Thothadri Rajesh