Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import numpy
- import zmq
- def send_array(socket, A, flags=0, copy=True, track=False):
- """send a numpy array with metadata"""
- md = dict(
- dtype = str(A.dtype),
- shape = A.shape,
- )
- socket.send_json(md, flags|zmq.SNDMORE)
- return socket.send(A, flags, copy=copy, track=track)
- def recv_array(socket, flags=0, copy=True, track=False):
- """recv a numpy array"""
- md = socket.recv_json(flags=flags)
- msg = socket.recv(flags=flags, copy=copy, track=track)
- buf = buffer(msg)
- A = numpy.frombuffer(buf, dtype=md['dtype'])
- return A.reshape(md['shape'])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement