在python中从opencv写入Gstreamer管道

import cv2

def write_to_gstreamer_pipeline(data, pipeline):
    pipeline.stdin.write(data.tobytes())

# 创建Gstreamer管道
pipeline = cv2.VideoWriter(
    'appsrc ! videoconvert ! x264enc ! mp4mux ! filesink location=output.mp4',
    cv2.CAP_GSTREAMER,
    0,
    25,
    (640, 480),
    True
)

# 从文件中读取视频数据
cap = cv2.VideoCapture('input.mp4')

while cap.isOpened():
    ret, frame = cap.read()
    if not ret:
        break

    # 将帧数据写入Gstreamer管道
    write_to_gstreamer_pipeline(frame, pipeline)

cap.release()
pipeline.stdin.close()
pipeline.wait()