MNT: Update elastic index

nslsii/__init__.py

@@ -1,5 +1,6 @@
 from IPython import get_ipython
 from ._version import get_versions
+import .loggers import configure_elastic
 __version__ = get_versions()['version']
 del get_versions
 
@@ -148,6 +149,9 @@ def configure_base(user_ns, broker_name, *,
         ch.setLevel(logging.ERROR)
         ophyd.ophydobj.logger.addHandler(ch)
 
+    configure_elastic(broker_name)
+    #Configure elastic log handler including bluesky, carproto and ophyd
+
     # convenience imports
     # some of the * imports are for 'back-compatibility' of a sort -- we have
     # taught BL staff to expect LiveTable and LivePlot etc. to be in their

nslsii/loggers.py

@@ -39,13 +39,17 @@ def emit(self, record):
         except Exception:
             self.handleError(record)
 
+def configure_elastic(beamline):
+    url = 'http://elasticsearch.cs.nsls2.local/' + beamline + '.blueksy'
 
-bluesky_logger = logging.getLogger('bluesky')
-carproto_logger = logging.getLogger('carproto')
-ophyd_logger = logging.getLogger('ophyd')
+    bluesky_logger = logging.getLogger('bluesky')
+    bluesky_elastic_hdr = ElasticHandler(url, level = logging.DEBUG)
+    bluesky_logger.addHandler(elastic_hdr)
 
-elastic_hdr = ElasticHandler('http://elasticsearch.cs.nsls2.local/test/_doc/1')
+    carproto_logger = logging.getLogger('carproto')
+    carproto_elastic_hdr = ElasticHandler(url, level = logging.INFO)
+    carproto_logger.addHandler(elastic_hdr)
 
-bluesky_logger.addHandler(elastic_hdr)
-carproto_logger.addHandler(elastic_hdr)
-ophyd_logger.addHandler(elastic_hdr)
+    ophyd_logger = logging.getLogger('ophyd')
+    ophyd_elastic_hdr = ElasticHandler(url, level = logging.INFO)
+    ophyd_logger.addHandler(elastic_hdr)