Я подключаю сокет DEALER к ROUTER, используя: socket = context.socket(zmq.DEALER) socket.setsockopt(zmq.IDENTITY, 'id') socket.connect('tcp://myhost:3456') и часто повторное подключение осуществляется по телефону: socket.close() socket =...

У меня есть поток, который ожидает ввода сигналов через ZMQ и сетевой ввод-вывод через TCP (и другой делает то же самое с UDP). socket_tcp = socket.socket( socket.AF_INET, socket.SOCK_STREAM ) socket_tcp.connect( ( self.config.tcp_ip,...

Я хочу отправить несколько сообщений из одного сокета в другой, и я столкнулся с этой проблемой. client.py context = Context() for i in range(10): print(i) out_socket = context.socket(REQ) out_socket.connect("tcp://localhost:%s"...

В руководстве для ZeroMQ есть это: Если вы используете inproc и пары сокетов, вы создаете тесно связанное приложение, то есть такое, в котором ваши потоки структурно взаимозависимы. Делайте это, когда низкая задержка действительно жизненно...

Я использую библиотеку papermill для одновременного запуска нескольких ноутбуков с использованием многопроцессорной обработки. Это происходит в Python 3.6.6, Red Hat 4.8.2-15 в контейнере Docker. Однако, когда я запускаю скрипт python, около 5%...

В настоящее время я работаю над проектом Benchmark, где пытаюсь нагрузить сервер запросами zmq. Мне было интересно, как лучше всего подойти к этому, я думал о том, чтобы иметь контекст для создания сокета и вставлять его в поток, в котором я буду...