mirror of
https://github.com/bec-project/bec_widgets.git
synced 2026-03-10 02:37:59 +01:00
27 lines
754 B
Python
27 lines
754 B
Python
import time
|
|
|
|
from bec_lib import MessageEndpoints, RedisConnector, messages
|
|
|
|
connector = RedisConnector("localhost:6379")
|
|
metadata = {}
|
|
|
|
scan_id = "ScanID1"
|
|
|
|
metadata.update(
|
|
{"scan_id": scan_id, "async_update": "append"} # this will be different for each scan
|
|
)
|
|
for ii in range(20):
|
|
data = {"mca1": [1, 2, 3, 4, 5, 6, 7, 8, 9, 10], "mca2": [10, 9, 8, 7, 6, 5, 4, 3, 2, 1]}
|
|
msg = messages.DeviceMessage(signals=data, metadata=metadata).dumps()
|
|
|
|
connector.xadd(
|
|
topic=MessageEndpoints.device_async_readback(
|
|
scan_id=scan_id, device="mca"
|
|
), # scan_id will be different for each scan
|
|
msg={"data": msg}, # TODO should be msg_dict
|
|
expire=1800,
|
|
)
|
|
|
|
print(f"Sent {ii}")
|
|
time.sleep(0.5)
|