How to Convert RTP Stream to RTSP using GStreamer for DeepStream?

[EugenioVLopes]

How to Convert RTP Stream to RTSP using GStreamer for DeepStream?

Context

I am developing a Flask microservice that receives an RTP stream (H.264) from Kurento and makes it available as an RTSP stream using GStreamer and GstRtspServer. The goal is to allow DeepStream to consume the RTSP stream for further processing. However, I would like to confirm whether my current pipeline is the best approach or if there is a more efficient alternative.

Current Implementation

I start the RTSP server using GStreamer’s GstRtspServer and update the pipeline dynamically when receiving an RTP stream. Below is my current setup:

• Flask microservice to manage the RTSP server
• GStreamer pipeline used to convert RTP to RTSP

def update_rtsp_pipeline(rtp_port):
    global rtsp_factory
    with gst_lock:
        if rtsp_server is None or rtsp_factory is None:
            logger.error("RTSP server or media factory not initialized")
            return
        launch_line = (
            f'udpsrc port={rtp_port} buffer-size=65536 caps="application/x-rtp,media=video,clock-rate=90000,encoding-name=H264,payload=96" '
            "! rtph264depay ! h264parse ! queue max-size-buffers=200 leaky=downstream "
            "! rtph264pay config-interval=1 name=pay0 pt=96"
        )
        rtsp_factory.set_launch(launch_line)
        logger.info(f"RTSP pipeline updated to receive RTP on port {rtp_port}")

The microservice exposes an endpoint that allows configuring the RTP input dynamically:

@app.route("/input/<int:rtp_port>", methods=["POST"])
def start_rtp_and_rtsp_stream(rtp_port):
    Gst.debug_set_threshold_from_string("*:5", True)
    start_rtsp_server()
    update_rtsp_pipeline(rtp_port)
    return (
        jsonify(
            {
                "message": f"RTSP server configured to receive RTP on port {rtp_port}",
                "rtsp_url": "rtsp://127.0.0.1:8554/test",
            }
        ),
        200,
    )

Questions

1. Is this approach efficient for converting an RTP stream from Kurento to an RTSP stream for DeepStream consumption?
2. Are there any improvements I can make to reduce latency or enhance stability?
3. Is there an alternative solution that would be better suited for integrating Kurento with DeepStream?

Any insights or suggestions from the community would be greatly appreciated!