diff --git a/aosstower/level_00/influxdb.py b/aosstower/level_00/influxdb.py index 2350a38677b3d51572fa0eb57035939a9894a8cc..f5d528768d4545c580af2e5761ada7ef0ac989f6 100644 --- a/aosstower/level_00/influxdb.py +++ b/aosstower/level_00/influxdb.py @@ -190,8 +190,8 @@ def main(): influx_gen = influxdb.grouper(influx_gen, args.bulk) updater = Updater() for record in influx_gen: - # lines = influxdb.frame_records(record, **station_tags) - # influxdb.insert(lines, host=args.host, port=args.port, dbname=args.dbname) + lines = influxdb.frame_records(record, **station_tags) + influxdb.insert(lines, host=args.host, port=args.port, dbname=args.dbname) # Record is in a list of size 1, but want just the record. avg = updater.rolling_average(record[0]) # Once every 5 minutes: 0 through 295 seconds inclusive.