Skip to content
Snippets Groups Projects
Commit d5d1ebec authored by William Roberts's avatar William Roberts
Browse files

Remove commented out influxdb.insert

parent 0df4ae1d
No related branches found
No related tags found
No related merge requests found
......@@ -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.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment