adding led events table

Pioreactor · Feb 2, 2021 · 6362b65 · 6362b65
1 parent 7da5801
commit 6362b65
Show file tree

Hide file tree

Showing 3 changed files with 34 additions and 1 deletion.
diff --git a/pioreactor/background_jobs/leader/mqtt_to_db_streaming.py b/pioreactor/background_jobs/leader/mqtt_to_db_streaming.py
@@ -105,6 +105,20 @@ def parse_dosing_events(topic, payload):
             "source_of_event": payload["source_of_event"],
         }
 
+    def parse_led_events(topic, payload):
+        payload = json.loads(payload)
+        metadata = produce_metadata(topic)
+
+        return {
+            "experiment": metadata.experiment,
+            "pioreactor_unit": metadata.pioreactor_unit,
+            "timestamp": metadata.timestamp,
+            "channel": payload["channel"],
+            "intensity": payload["intensity"],
+            "event": payload["event"],
+            "source_of_event": payload["source_of_event"],
+        }
+
     def parse_growth_rate(topic, payload):
         metadata = produce_metadata(topic)
 
@@ -164,6 +178,7 @@ def parse_algorithm_settings(topic, payload):
         Metadata("pioreactor/+/+/od_filtered/+/+", "od_readings_filtered", parse_od),
         Metadata("pioreactor/+/+/od_raw/+/+", "od_readings_raw", parse_od),
         Metadata("pioreactor/+/+/dosing_events", "dosing_events", parse_dosing_events),
+        Metadata("pioreactor/+/+/led_events", "led_events", parse_led_events),
         Metadata("pioreactor/+/+/growth_rate", "growth_rates", parse_growth_rate),
         Metadata("pioreactor/+/+/pid_log", "pid_logs", parse_pid_logs),
         Metadata(

diff --git a/pioreactor/background_jobs/od_reading.py b/pioreactor/background_jobs/od_reading.py
@@ -99,7 +99,11 @@ def __init__(self, od_channels, unit=None, experiment=None, fake_data=False):
     def start_ir_led(self):
         ir_channel = config.get("leds", "ir_led")
         r = led_intensity(
-            ir_channel, intensity=100, unit=self.unit, experiment=self.experiment
+            ir_channel,
+            intensity=100,
+            source_of_event=self.job_name,
+            unit=self.unit,
+            experiment=self.experiment,
         )
         if not r:
             raise ValueError("IR LED could not be started. Stopping OD reading.")

diff --git a/sql/create_tables.sql b/sql/create_tables.sql
@@ -49,6 +49,20 @@ CREATE INDEX IF NOT EXISTS dosing_events_ix
 ON dosing_events (experiment);
 
 
+CREATE TABLE IF NOT EXISTS led_events (
+    timestamp              TEXT  NOT NULL,
+    experiment             TEXT  NOT NULL,
+    event                  TEXT  NOT NULL,
+    channel                TEXT  NOT NULL,
+    intensity              REAL  NOT NULL,
+    pioreactor_unit        TEXT  NOT NULL,
+    source_of_event        TEXT
+);
+
+CREATE INDEX IF NOT EXISTS led_events_ix
+ON led_events (experiment);
+
+
 
 CREATE TABLE IF NOT EXISTS growth_rates (
     timestamp              TEXT  NOT NULL,