Как получить кадры opencv с помощью ZeroMQ?

Я использую следующий код для получения кадров от клиента:

def fetch_frame(self):

    context = zmq.Context()
    footage_socket = context.socket(zmq.REP)
    footage_socket.bind('tcp://*:5555')

    while True:
        frame = footage_socket.recv_string()

        frame = frame.encode()

        img = base64.b64decode(frame)

        npimg = np.fromstring(img, dtype=np.uint8)
        source = cv2.imdecode(npimg, 1)

К сожалению, выдает следующую ошибку:

zmq.error.ZMQError: Operation cannot be accomplished in current state

Как правильно получить изображение с помощью zmq?

ОБНОВЛЯТЬ:

Ниже приведена трассировка:

 File "/home/receive/main.py", line 77, in <module>
    main()
  File "/home/receive/main.py", line 73, in main
    ci.fetch_frame()
  File "/home/receive/main.py", line 59, in fetch_frame
    frame = footage_socket.recv_string()
  File "/home/.local/lib/python3.8/site-packages/zmq/sugar/socket.py", line 608, in recv_string
    msg = self.recv(flags=flags)
  File "zmq/backend/cython/socket.pyx", line 791, in zmq.backend.cython.socket.Socket.recv
  File "zmq/backend/cython/socket.pyx", line 827, in zmq.backend.cython.socket.Socket.recv
  File "zmq/backend/cython/socket.pyx", line 191, in zmq.backend.cython.socket._recv_copy
  File "zmq/backend/cython/socket.pyx", line 186, in zmq.backend.cython.socket._recv_copy
  File "zmq/backend/cython/checkrc.pxd", line 26, in zmq.backend.cython.checkrc._check_rc
zmq.error.ZMQError: Operation cannot be accomplished in current state

Что выдает ошибку? Пожалуйста, отредактируйте свой вопрос и включите всю трассировку (или, как минимум, укажите, какая строка вашего кода ее вызывает).

martineau 09.12.2020 20:58

@martineau, пожалуйста, проверьте обновленный вопрос. я добавил логи

Mr. Randy Tom 09.12.2020 21:02

Да, именно такую ​​информацию следует вкладывать в подобные вопросы, чтобы помочь другим понять, что не так.

martineau 09.12.2020 21:05

Может ли проблема быть на другом конце?

DisappointedByUnaccountableMod 09.12.2020 21:07
Почему в Python есть оператор "pass"?
Почему в Python есть оператор "pass"?
Оператор pass в Python - это простая концепция, которую могут быстро освоить даже новички без опыта программирования.
Некоторые методы, о которых вы не знали, что они существуют в Python
Некоторые методы, о которых вы не знали, что они существуют в Python
Python - самый известный и самый простой в изучении язык в наши дни. Имея широкий спектр применения в области машинного обучения, Data Science,...
Основы Python Часть I
Основы Python Часть I
Вы когда-нибудь задумывались, почему в программах на Python вы видите приведенный ниже код?
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
Алиса и Боб имеют неориентированный граф из n узлов и трех типов ребер:
Оптимизация кода с помощью тернарного оператора Python
Оптимизация кода с помощью тернарного оператора Python
И последнее, что мы хотели бы показать вам, прежде чем двигаться дальше, это
Советы по эффективной веб-разработке с помощью Python
Советы по эффективной веб-разработке с помощью Python
Как веб-разработчик, Python может стать мощным инструментом для создания эффективных и масштабируемых веб-приложений.
0
4
225
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вопрос: "ZMQError: Operation cannot be accomplished in current state"

Основная причина в том, что ваш код нарушил задокументированные свойства ZeroMQ REQ/REP.

Запрос REP-экземпляра на .send()-ed сообщение до того, как REQ-экземпляр уже «запросил» своего контрагента первым, API должен выдать такую ​​ошибку.

Точно так же, если вы пытаетесь .recv() отправить сообщение на REQ-стороне, до того, как оно впервые «спросит» .send()REP-сторону (чтобы ответить), API должен выдать такую ​​ошибку.


РЕШЕНИЕ ?

В случае, если никакое другое взаимодействие не требуется, PUSH/PULL Архетип масштабируемого шаблона формального общения, где PUSH-сторона будет .send(), а PULL-сторона будет .recv(), ИМХО, лучший путь вперед.


Вы можете прочитать больше советов и ссылок по этому поводу в этом.

Другие вопросы по теме