2018-06-23 20:13:33 +02:00
|
|
|
|
2017-11-20 20:15:14 +01:00
|
|
|
void pushToInfluxDB(String device, float sensorValues[]) {
|
2018-06-23 20:13:33 +02:00
|
|
|
|
2019-01-27 16:29:58 +01:00
|
|
|
#ifdef DEBUG
|
2018-07-12 22:30:30 +02:00
|
|
|
String msg = "weather,device=" + device + " temperature=" + String(sensorValues[SENSOR_TEMPERATURE])
|
|
|
|
|
+ ",humidity=" + String(sensorValues[SENSOR_HUMIDITY])
|
|
|
|
|
+ ",light=" + String(sensorValues[SENSOR_LIGHT])
|
|
|
|
|
+ ",windspeed=" + String(sensorValues[SENSOR_WINDSPEED])
|
|
|
|
|
+ ",pressure=" + String(sensorValues[SENSOR_PRESSURE])
|
|
|
|
|
+ ",batvoltage=" + String(sensorValues[SENSOR_BAT_VOLTAGE]);
|
|
|
|
|
|
2019-01-27 16:29:58 +01:00
|
|
|
Serial.println(msg);
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
uint8_t tries = 0;
|
2018-07-12 22:30:30 +02:00
|
|
|
do {
|
|
|
|
|
tries++;
|
2019-01-27 16:29:58 +01:00
|
|
|
if (!(isnan(sensorValues[SENSOR_TEMPERATURE])))
|
|
|
|
|
influxdb.write("weather,device=" + device + " temperature=" + String(sensorValues[SENSOR_TEMPERATURE]));
|
|
|
|
|
if (!(isnan(sensorValues[SENSOR_HUMIDITY])))
|
|
|
|
|
influxdb.write("weather,device=" + device + " humidity=" + String(sensorValues[SENSOR_HUMIDITY]));
|
|
|
|
|
if (!(isnan(sensorValues[SENSOR_LIGHT])))
|
|
|
|
|
influxdb.write("weather,device=" + device + " light=" + String(sensorValues[SENSOR_LIGHT]));
|
|
|
|
|
if (!(isnan(sensorValues[SENSOR_WINDSPEED])))
|
|
|
|
|
influxdb.write("weather,device=" + device + " windspeed=" + String(sensorValues[SENSOR_WINDSPEED]));
|
|
|
|
|
if (!(isnan(sensorValues[SENSOR_PRESSURE])))
|
|
|
|
|
influxdb.write("weather,device=" + device + " pressure=" + String(sensorValues[SENSOR_PRESSURE]));
|
|
|
|
|
if (!(isnan(sensorValues[SENSOR_BAT_VOLTAGE])))
|
|
|
|
|
influxdb.write("weather,device=" + device + " batvoltage=" + String(sensorValues[SENSOR_BAT_VOLTAGE]));
|
2018-07-12 22:30:30 +02:00
|
|
|
} while (influxdb.response() != DB_SUCCESS and tries < 5);
|
2018-06-23 20:13:33 +02:00
|
|
|
}
|
2019-01-27 16:29:58 +01:00
|
|
|
|
