appsink test

gistfile1.txt

import sys
import pygst
pygst.require("0.10")
import gst
import gobject


def main(url):
    print url
    gobject.threads_init()
    command = 'rtspsrc location=%s' % url
    command += ' ! appsink name=app enable-last-buffer=true emit-signals=true'
    print command
    pipeline = gst.parse_launch(command)
    app = pipeline.get_by_name('app')

    def on_new_buffer(appsink):
        buf = appsink.get_property('last-buffer')
        print str(buf.data)
    app.connect('new-buffer', on_new_buffer)
    mainloop = gobject.MainLoop()
    pipeline.set_state(gst.STATE_PAUSED)
    pipeline.set_state(gst.STATE_PLAYING)
    mainloop.run()

if __name__ == "__main__":
    main(sys.argv[1])