okoyono/weatherstation
7
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Add influxdb and push the sensor data to the database

Browse source
This commit is contained in:
Aaron Fischer 2017-11-20 20:15:14 +01:00
parent dd0e2b2e40
commit f6d8abc723
3 changed files with 28 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
firmware/config.h
View file

@ -9,3 +9,11 @@
#define STATUS_LED_PIN BUILTIN_LED #define STATUS_LED_PIN BUILTIN_LED
#define ANEMOMETER_PIN D4 #define ANEMOMETER_PIN D4
const char *INFLUXDB_HOST = "influxdb.okoyono.de";
const uint16_t INFLUXDB_PORT = 80;
const char *INFLUXDB_DB = "weatherstation";
const char *INFLUXDB_USER = "oko";
const char *INFLUXDB_PASS = "de1873a0d2f8f21f17cf4d8db4f65c59";
String DEVICE_NAME = "aaron";

11
firmware/firmware.ino
View file

@ -3,12 +3,12 @@
#include <DNSServer.h> #include <DNSServer.h>
#include <ESP8266WebServer.h> #include <ESP8266WebServer.h>
#include <WiFiManager.h> #include <WiFiManager.h>
#include <ESP8266Influxdb.h>
#include "config.h" #include "config.h"
/** /**
* Whishlist: * Whishlist:
* - Push sensor values to influxdb
* - Webserver for /metrics endpoint (Prometheus) * - Webserver for /metrics endpoint (Prometheus)
* - Show current sensor values over simple webpage * - Show current sensor values over simple webpage
* - Push sensor values to various 3rd party services (https://openweathermap.org/) * - Push sensor values to various 3rd party services (https://openweathermap.org/)
@ -27,6 +27,7 @@ float currentSensorData[4] = {0.0, 0.0, 0.0, 0.0};
WiFiManager wifiManager; WiFiManager wifiManager;
Influxdb influxdb(INFLUXDB_HOST, INFLUXDB_PORT);
void setup() { void setup() {
#ifdef DEBUG #ifdef DEBUG
@ -37,7 +38,7 @@ void setup() {
pinMode(STATUS_LED_PIN, OUTPUT); pinMode(STATUS_LED_PIN, OUTPUT);
pinMode(ANEMOMETER_PIN, INPUT_PULLUP); pinMode(ANEMOMETER_PIN, INPUT_PULLUP);
// Establish wifi connection // Establish WiFi connection
String wifiName = "oko-weather-" + String(ESP.getChipId()); String wifiName = "oko-weather-" + String(ESP.getChipId());
wifiManager.setMinimumSignalQuality(15); wifiManager.setMinimumSignalQuality(15);
if (!wifiManager.autoConnect(wifiName.c_str(), "DEADBEEF")) { if (!wifiManager.autoConnect(wifiName.c_str(), "DEADBEEF")) {
@ -50,6 +51,10 @@ void setup() {
#ifdef DEBUG #ifdef DEBUG
Serial.println("Connected!"); Serial.println("Connected!");
#endif #endif
// Open the InfluxDB session
influxdb.opendb(INFLUXDB_DB, INFLUXDB_USER, INFLUXDB_PASS);
delay(2000);
} }
void loop() { void loop() {
@ -69,7 +74,7 @@ void loop() {
Serial.println("Windspeed: " + String(currentSensorData[SENSOR_WINDSPEED]) + " Km/h"); Serial.println("Windspeed: " + String(currentSensorData[SENSOR_WINDSPEED]) + " Km/h");
#endif #endif
pushToInfluxDB(currentSensorData); pushToInfluxDB(DEVICE_NAME, currentSensorData);
delay(UPDATE_INTERVAL*1000); delay(UPDATE_INTERVAL*1000);
} }

8
firmware/influxdb.ino
View file

@ -1,4 +1,6 @@
void pushToInfluxDB(float sensorValues[]) { void pushToInfluxDB(String device, float sensorValues[]) {
influxdb.write("weather,device=" + device + " temperature=" + String(sensorValues[SENSOR_TEMPERATURE]));
influxdb.write("weather,device=" + device + " humidity=" + String(sensorValues[SENSOR_HUMIDITY]));
influxdb.write("weather,device=" + device + " light=" + String(sensorValues[SENSOR_LIGHT]));
influxdb.write("weather,device=" + device + " windspeed=" + String(sensorValues[SENSOR_WINDSPEED]));
} }