mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-04-22 03:04:35 +02:00
Data Backend account
36 lines
1022 B
Python
36 lines
1022 B
Python
import zmq
|
|
from _ctypes import Structure
|
|
from ctypes import c_uint64, c_uint16
|
|
|
|
class ImageMetadata(Structure):
|
|
_pack_ = 1
|
|
_fields_ = [
|
|
("version", c_uint64),
|
|
("id", c_uint64),
|
|
("height", c_uint64),
|
|
("width", c_uint64),
|
|
("dtype", c_uint16),
|
|
("encoding", c_uint16),
|
|
("source_id", c_uint16),
|
|
("status", c_uint16),
|
|
("user_1", c_uint64),
|
|
("user_2", c_uint64)]
|
|
|
|
def as_dict(self):
|
|
return dict((f, getattr(self, f)) for f, _ in self._fields_)
|
|
|
|
|
|
|
|
|
|
|
|
zmq_context = zmq.Context()
|
|
backend_socket = zmq_context.socket(zmq.SUB)
|
|
#backend_socket.setsockopt(zmq.RCVTIMEO, 100)
|
|
backend_socket.setsockopt_string(zmq.SUBSCRIBE, "")
|
|
backend_socket.connect("ipc:///tmp/std-daq-cSAXS.EG01V01-assembler")
|
|
|
|
while True:
|
|
image_bytes = backend_socket.recv()
|
|
image_meta = ImageMetadata.from_buffer_copy(image_bytes)
|
|
print(f'Image received: {image_meta.id}')
|