Add starter bash script for legacy db insert

aosstower/level_00/legacy_db_insert.py

@@ -78,8 +78,11 @@ def main(*args):
         src = open(args.src, "r")
         record_gen = read_frames(src, tail=args.tail)
 
-    for record in record_gen:
+    for idx, record in enumerate(record_gen):
         data = (record['stamp'], record)
+        if args.debug:
+            print(idx, data)
+            continue
         failures = legacy_db.insert_records([data], station=station)
         if failures:
             ERR.info("(%s) %s", failures[0][0], record)

scripts/start_tower_legacy_db_ingest.sh

+#!/usr/bin/env bash
+#
+# Runs the tower ingest in a screen session named 'tower_db_ingest'.
+#
+# If a screen session is already running with that name, exit, otherwise start
+# a new detached screen session named 'tower_db_ingest'.
+#
+NAME=tower_db_ingest
+PYENV=/opt/metobs/aoss_tower
+#SRC=/mnt/data/ingest/rig_tower/rig_tower.dat
+#DBURL=postgresql://buoy_ingest:bu0y1ngest@tahiti.ssec.wisc.edu/buoy
+DBURL=postgresql://metobs_ingest:m3t0b5@metobs01.instrument/metobs
+LOGFN=$PYENV/log/tower_db_ingest.log
+
+export PGAPPNAME=tower_db_ingest
+
+SCRN=$(screen -list | grep $NAME | awk '{print $1}')
+if [ -n "$SCRN" ]; then
+echo Screen already running: $SCRN
+else
+screen -S $NAME -d -m $PYENV/bin/python -m aosstower.level_00.legacy_db_insert \
+                                --loglvl info \
+                                --logfn $LOGFN \
+                                --ldmp \
+                                $DBURL \
+                                RIGTower
+echo Started in screen $(screen -list | grep $NAME | awk '{print $1}')
+fi