Привет, я пытаюсь создать поток изображений zmq, чтобы выполнить обработку изображений на другом компьютере и отправить обратно обработанное изображение, но у меня возникли некоторые проблемы с подключением по какой-то причине. У меня странные дрожания, и изображение просто зависает несколько кадров
вот мой код
context = zmq.Context(1)
socket = context.socket(zmq.REQ)
socket.bind("tcp://*:%s" % port)
p = Process(target=self.camera_process, args=(cam_name, port))
p.start()
pipeline = SettingsManager().cams[cam_name]["pipelines"]["pipeline0"]
while True:
# start = time.time(
_, image = cv_sink.grabFrame(image)
socket.send_pyobj({'image': image,
'pipeline': pipeline})
# end = time.time()
image = socket.recv_pyobj()
и для другой машины
context = zmq.Context(1)
socket = context.socket(zmq.REP)
socket.connect("tcp://localhost:%s" % port)
while True:
obj = socket.recv_pyobj()
image = obj['image']
# curr_pipeline = obj["pipeline"]
# hsv_image = self._hsv_threshold(curr_pipeline["hue"],
# curr_pipeline["saturation"], curr_pipeline["value"],
# image, curr_pipeline["erode"], curr_pipeline["dilate"])
# contours = self.find_contours(hsv_image)
# filtered_contours = self.filter_contours(contours, cam_area, curr_pipeline["area"], curr_pipeline["ratio"],
# curr_pipeline["extent"])
# res = self.draw_image(input_image=image, is_binary=False, rectangles=filtered_contours)
socket.send_pyobj(image)
некоторые библиотеки не являются "напрямую" opencv, но изображение, которое я получаю, является изображением открытого формата cv, и то, что я пытаюсь сделать, это обработать, что на другой машине в настоящее время вся обработка изображения отключена специально и до сих пор у меня есть эта странная задержка ссылка на видео с задержкой . спасибо за помощь