Есть блокирующий метод, который должен c помощью либы ZeroMQ сделать несколько асинхронных запросов каждому слушателям из списка, после отправки сообщения, дождаться первого ответа от любого из..., после получения первого же ответа нужно реджектнуть остальные соединения и вернуть полученное сообщение.
Как всё это дело можно навернуть на asyncio?
На данный момент реализован только функционал запрос-ответа.
import zmq
socket = None
message = None
id = 500
req_timeout_ms = 1500
request = b'test data'
socket = context.socket(zmq.DEALER)
socket.setsockopt(zmq.IDENTITY, id)
socket.setsockopt(zmq.RCVTIMEO, req_timeout_ms)
socket.connect('tcp://127.0.0.1:7654')
socket.send_multipart([request])
message = socket.recv()
print(message)
socket = None
...socket.setsockopt(zmq.IDENTITY, id)
что-то я сомневаюсь что код работаетzmq.asyncio
? Начиная с версии 15 можно использовать асинхронный контекст для zmq.