1 2 3 4 5 6 7 8 9 10 11
import zmq import os ctx = zmq.Context() s = ctx.socket(zmq.PULL) s.bind(st := f"tcp://{os.environ['ADDRESS']}") import time while True: print(s.recv_multipart())