From 048e5deec86401f10cd402abb48c32efaa2ccf61 Mon Sep 17 00:00:00 2001 From: Jun Aishima Date: Wed, 14 May 2025 11:17:41 -0400 Subject: [PATCH] remove using PersistentDict, use RedisJSONDict instead * for LSDC metadata * this will go into the standard Redis because this metadata is being used for Bluesky scans, even though they are not being called from bsui --- start_bs.py | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/start_bs.py b/start_bs.py index 72a95a89..75b2991b 100755 --- a/start_bs.py +++ b/start_bs.py @@ -9,6 +9,13 @@ from mxtools.governor import _make_governors from ophyd.signal import EpicsSignalBase EpicsSignalBase.set_defaults(timeout=10, connection_timeout=10) # new style +import redis +from redis_json_dict import RedisJSONDict + +# setup RedisJsonDict +uri = f"info.{os.environ['BEAMLINE_ID']}.nsls2.bnl.gov" +# Provide an endstation prefix, if needed, with a trailing "-" +new_md = RedisJSONDict(redis.Redis(uri),prefix="lsdc-") #12/19 - author unknown. DAMA can help """ @@ -34,15 +41,13 @@ import bluesky.plans as bp from bluesky.run_engine import RunEngine -from bluesky.utils import get_history, PersistentDict RE = RunEngine() beamline = os.environ["BEAMLINE_ID"] from nslsii import configure_kafka_publisher configure_kafka_publisher(RE, beamline) -configdir = os.environ['CONFIGDIR'] -RE.md = PersistentDict('%s%s_bluesky_config' % (configdir, beamline)) from databroker import Broker db = Broker.named(beamline) +RE.md = new_md RE.subscribe(db.insert)