如何使用GStreamer播放PCM数据数组

import gi
gi.require_version('Gst', '1.0')
from gi.repository import Gst

# 初始化GStreamer
Gst.init(None)

# 创建管道
pipeline = Gst.Pipeline()

# 创建元素
source = Gst.ElementFactory.make("appsrc", "source")
caps = Gst.Caps.from_string("audio/x-raw, format=S16LE, channels=2, rate=44100")
source.set_property("caps", caps)
decoder = Gst.ElementFactory.make("decodebin", "decoder")
converter = Gst.ElementFactory.make("audioconvert", "converter")
sink = Gst.ElementFactory.make("autoaudiosink", "sink")

# 将元素添加到管道中
pipeline.add(source)
pipeline.add(decoder)
pipeline.add(converter)
pipeline.add(sink)

# 连接元素
source.link(decoder)
decoder.connect("pad-added", on_pad_added, converter)
converter.link(sink)

def push_data(data):
    buf = Gst.Buffer.new_allocate(None, len(data), None)
    buf.fill(0, data)
    source.emit("push-buffer", buf)

# 启动管道
pipeline.set_state(Gst.State.PLAYING)

# 播放PCM数据数组
pcm_data = [0x00, 0x01, 0x02, ...]  # PCM数据数组
push_data(pcm_data)

# 停止播放
pipeline.set_state(Gst.State.NULL)