diff --git a/sensors/ads1115/ads1115_influx.py b/sensors/ads1115/ads1115_influx.py index 46ad5a24aa698201b09b8f8ed00232f00e01a684..07700c3c3ab0117181107052bf593992cfae30ae 100644 --- a/sensors/ads1115/ads1115_influx.py +++ b/sensors/ads1115/ads1115_influx.py @@ -1,5 +1,7 @@ import time import os +from datetime import datetime +import threading import ADS1115 as ads1115_lib from influxdb import InfluxDBClient @@ -12,11 +14,12 @@ adc = ads1115_lib.ADS1115() # Add timestamp to measurement # Accumulate measurement to write multiples points +measurement = [] -while True: - measurement = [ - { +def getMeasurements(): + new_measurement = { 'measurement': 'ads1115', + 'time': datetime.now(), 'fields': { 'ain0': adc.readADCSingleEnded(), 'ain1': adc.readADCSingleEnded(1), @@ -24,7 +27,12 @@ while True: 'ain3': adc.readADCSingleEnded(channel=3, pga=1024, sps=16) } } - ] + measurement.append(new_measurement) + +threading.Timer(0.1, getMeasurements).start() + +while True: influx_client.write_points(measurement) + measurement.clear() time.sleep(1)