Error installing PyGObject in window for running RTSP streaming.

jakaskerl
thank you for getting back.
I did try everything u mentioned issue is still the same.
While implementing H265_MAINgetting following error on terminal.

[rtsp @ 0x7f6524000cc0] method DESCRIBE failed: 503 Service Unavailable

rtsp://11.11.11.25:8554/OAK60: Server returned 5XX Server Error reply

Than you
Nikul

jakaskerl
I have figured out that 60 FPS with 1080P is what causing problem. However I can not compromise with 60FPS as it something crucial for the project i am working on. Any thoughts ?

jakaskerl So a bandwidth or processing issue? In both cases, can you afford to lower the resolution? Something like 720p should be much less (less than 50%) demanding.

Thank you @jakaskerl

I am assuming its not a bandwidth issue since it is connected pretty good industrial network infrastructure.

If Its processing, Is there any other way then lowering down resolution.

@erik .

Hi Erik.
Apart from the issues with FPS and resolution, I have an additional concern. I have disabled the TCP server on one device, leaving it in a bootable state. I am currently experimenting with gen2-RTSP. My objective is to have multiple scripts running for each camera to stream them individually to different endpoints. However, when I run the script for one device, I encounter difficulties streaming from the other device simultaneously. Below is the code I'm using:

#!/usr/bin/env python3

import threading

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


class RtspSystem(GstRtspServer.RTSPMediaFactory):
    def __init__(self, **properties):
        super(RtspSystem, self).__init__(**properties)
        self.data = None
        self.launch_string = 'appsrc name=source is-live=true block=true format=GST_FORMAT_TIME ! h265parse ! rtph265pay name=pay0 config-interval=1 name=pay0 pt=96'

    def send_data(self, data):
        self.data = data

    def start(self):
        t = threading.Thread(target=self._thread_rtsp)
        t.start()

    def _thread_rtsp(self):
        loop = GLib.MainLoop()
        loop.run()

    def on_need_data(self, src, length):
        if self.data is not None:
            retval = src.emit('push-buffer', Gst.Buffer.new_wrapped(self.data.tobytes()))
            if retval != Gst.FlowReturn.OK:
                print(retval)

    def do_create_element(self, url):
        return Gst.parse_launch(self.launch_string)

    def do_configure(self, rtsp_media):
        self.number_frames = 0
        appsrc = rtsp_media.get_element().get_child_by_name('source')
        appsrc.connect('need-data', self.on_need_data)


class RTSPServer(GstRtspServer.RTSPServer):
    def __init__(self, **properties):
        super(RTSPServer, self).__init__(**properties)
        self.rtsp = RtspSystem()
        self.rtsp.set_shared(True)
        self.get_mount_points().add_factory("/oak63", self.rtsp)
        self.attach(None)
        Gst.init(None)
        self.rtsp.start()

    def send_data(self, data):
        self.rtsp.send_data(data)

if __name__ == "__main__":
    import depthai as dai

    server = RTSPServer()

    pipeline = dai.Pipeline()

    FPS = 60
    colorCam = pipeline.create(dai.node.ColorCamera)
    colorCam.setResolution(dai.ColorCameraProperties.SensorResolution.THE_720_P)
    colorCam.setInterleaved(False)
    colorCam.setColorOrder(dai.ColorCameraProperties.ColorOrder.BGR)
    # colorCam.setIspScale(2,3)
    # colorCam.setFps(FPS)

    videnc = pipeline.create(dai.node.VideoEncoder)
    videnc.setDefaultProfilePreset(FPS, dai.VideoEncoderProperties.Profile.H265_MAIN)
    colorCam.video.link(videnc.input)

    veOut = pipeline.create(dai.node.XLinkOut)
    veOut.setStreamName("encoded")
    videnc.bitstream.link(veOut.input)

    desired_ip = "00.00.00.00
    device_infos = dai.DeviceBootloader.getAllAvailableDevices()
    device_info = [device_info for device_info in device_infos if device_info.name == desired_ip][0]
    if device_info:
        if device_info.protocol != dai.XLinkProtocol.X_LINK_USB_VSC:
            print("Running RTSP stream may be unstable due to connection... (protocol: {})".format(device_info.protocol))

        with dai.Device(pipeline, device_info) as device:
            encoded = device.getOutputQueue("encoded", maxSize=30, blocking=True)
            print("Setup finished, RTSP stream available under \"rtsp://localhost:8554/oak63\"")
            while True:
                data = encoded.get().getData()
                server.send_data(data)
    else
        print('No device found')

Further I haven't been able to figure out where am I loosing packages.
need your suggestion how can I achieve desired outcome which is having 60FPS with 1080 Resolution and running different script on different end point in single host.

Thank you very much.
Nikul

jakaskerl
@erik
Hi
Thank you for prompt response appreciate it.
Apologies it seems like it was bandwidth issue, since it is working for now with lower bit rate.

Now I just want to run multiple script on single host to run multiple RTSP server for different streaming. I somewhat tried running one script with different end point for streamings but that may cause problem in the future since i want other cameras to stream parallel while I am experimenting with one.

jakaskerl I see you are hardcoding the endpoints. These need to differ from one script to the other, otherwise you will get conflicts.

end points and ports are different in each script.

Demo1.py
port = 8555

endpoint = '/oak63'

server = RTSPServer(port, endpoint)

Demo2.py
port = 8554

endpoint = '/oak62'

server = RTSPServer(port, endpoint)

jakaskerl Which machine is this for? I suspected a bandwidth issue on the machine that both receives a stream from the OAK device as well as serve another stream via RTSP.

This one is linux machine, running the script which gets the stream from OAK device and serves through RTSP.

jakaskerl Can this be reproducible? Increasing the bitrate induces stream errors?

Reducing the bit rate makes the streaming better(Not the best), That seems to be consistent so far.

erik
Thank you for getting back.
Will let you know whatever we make decision .