Простейшая DIY интернет-метеостанция за 5$

#include <ESP8266WiFi.h>
#include <Adafruit_BME280.h>
#include <PubSubClient.h>

Adafruit_BME280 bme; // I2C

// Replace with your network details
const char* ssid = «WIFINET»;
const char* password = «пароль_вайфай»;
float h, t, tF, p, pb, pin, dp, dpF;
char temperatureString[6];
char temperatureFString[6];
char dpString[6];
char dpFString[6];
char humidityString[6];
char pressureString[7];
char pressureInString[6];
#define SRV «narodmon.ru»
#define MAC «хх:dd:c2: хх:a3: хх» //МАК-адрес метеостанции
#define PASS «ххххх» // пароль для mqtt постинга на narodmon
#define USERNAME «yyyyyyyyy» // логин на narodmon
#define TOPIC «yyyyyyyy/BME280/»

#define SRV2 «weatherstation.wunderground.com»
#define StationID «ZZZZZZZ» // ID станции на сайте wunderground.com
#define PASS2 «xxxxx» // Key станции на сайте wunderground.com

//MQTT Narodmon
char server[] = SRV;
char authMethod[] = USERNAME;
char token[] = PASS;
char clientId[] = MAC;
char conntopic[] = TOPIC «status»;

//HTTP GET WUnderground
char server2[] = SRV2;
char authMethod2[] = StationID;
char token2[] = PASS2;
char webpage[] = «GET /weatherstation/updateweatherstation.php?»;

WiFiClient nmClient;
WiFiClient wuClient;
PubSubClient clientMQ(server, 1883, nmClient);
// only runs once on boot
void setup() {
// Initializing serial port for debugging purposes
Serial.begin(115200);
delay(10);

// Connecting to WiFi network
Serial.println();
Serial.print(«Connecting to „);
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(“.»);
}
Serial.println("");
Serial.println(«WiFi connected»);

// Printing the ESP IP address
Serial.println(WiFi.localIP());
Serial.println(F(«BME280 start»));

if (!bme.begin()) {
Serial.println(«Could not find a valid BME280 sensor, check wiring!»);
while (1);
}
}

// runs over and over again
void loop() {

getWeather();
doPublishNM(«humidity», String(h, 2));
doPublishNM(«temperature», String(t, 2));
doPublishNM(«pressure», String(p, 2));
doPublishWU(temperatureFString, pressureInString, humidityString, dpFString);
delay(600000);
}

void getWeather() {

h = 0;
float valh;
for (int i=0; i<30; i++) {
delay (random(50,500));

valh = bme.readHumidity();
Serial.print(valh);
Serial.print("\n");
h = h+valh;
}
h=h/30;
Serial.print("\n");
t = 0;
float valt;
for (int i=0; i<30; i++) {
delay (random(50,500));
valt = bme.readTemperature();
Serial.print(valt);
Serial.print("\n");
t = t+valt;
}
t=t/30;
tF=(t*1.8)+32;
Serial.print(tF);
p = 0;
float valp;
for (int i=0; i<30; i++) {
delay (random(50,500));
valp = bme.readPressure();
Serial.print(valp);
Serial.print("\n");
p = p+valp;
}
p=p/30/100.0F;
dp = t-((1-(h/100))/0.05);
dpF = (dp*1.8)+32;
pb = p/pow(2.718281828, -0.029*9.81*150/(8.31*(t+273.15))); // приводим абсолютное давление к уровню Балтийского моря (высота 150м)
pin = p*0.0296133971008484;
dtostrf(t, 5, 2, temperatureString);
dtostrf(tF, 4, 2, temperatureFString);
dtostrf(h, 5, 2, humidityString);
dtostrf(p, 6, 2, pressureString);
dtostrf(pin, 4, 2, pressureInString);
dtostrf(dpF, 5, 2, dpFString);

}

// MQTT публикация Narodmon.ru
void doPublishNM(String id, String value) {
// если не подключен, то подключаемся. Висит пока не подключится!!!
if (!!!clientMQ.connected()) {
Serial.print(«Reconnecting client to „); Serial.println(server);
while (!!!clientMQ.connect(clientId, authMethod, token, conntopic,0,0,“online»)) {
Serial.print(".");
delay(500);
}
Serial.print(«connected with: „); Serial.print(clientId); Serial.print(authMethod); Serial.print(token);
Serial.println();
}

String topic = TOPIC;
String payload = value;
// String topic += id;
topic.concat(id);
Serial.print(“Publishing on: „); Serial.println(topic);
Serial.print(“Publishing payload: „); Serial.println(payload);
if (clientMQ.publish(topic.c_str(), (char*) payload.c_str())) {
Serial.println(“Publish ok»);
} else {
Serial.println(«Publish failed»);
}
}

// HTTP GET публикация WUnderground
void doPublishWU(String temperatureFString, String pressureInString, String humidityString, String dpFString) {

if (wuClient.connect(server2, 80)) {
Serial.print(F("… Connected to server: "));
Serial.print(server2);
char c = wuClient.read();
Serial.print(F(", Server response: "));
Serial.write©;
Serial.println(F(""));
Serial.println(F("… Sending DATA "));
Serial.println(F(""));
wuClient.print(webpage);
Serial.print(webpage);
wuClient.print(«ID=»);
Serial.print(«ID=»);
wuClient.print(authMethod2);
Serial.print(authMethod2);
wuClient.print("&PASSWORD=");
Serial.print("&PASSWORD=");
wuClient.print(token2);
Serial.print(token2);
wuClient.print("&dateutc=");
Serial.print("&dateutc=");
wuClient.print(«now»);
Serial.print(«now»);
wuClient.print("&tempf=");
Serial.print("&tempf=");
wuClient.print(temperatureFString);
Serial.print(temperatureFString);
wuClient.print("&baromin=");
Serial.print("&baromin=");
wuClient.print(pressureInString);
Serial.print(pressureInString);
wuClient.print("&humidity=");
Serial.print("&humidity=");
wuClient.print(humidityString);
Serial.print(humidityString);

wuClient.print("&dewptf=");
Serial.print("&dewptf=");
wuClient.print(dpFString);
Serial.print(dpFString);
wuClient.print("&softwaretype=Arduino%20UNO%20version1&action=updateraw");
Serial.print("&softwaretype=Arduino%20UNO%20version1&action=updateraw");

//Finishing the communication

wuClient.println("/ HTTP/1.1\r\nHost: host:port\r\nConnection: close\r\n\r\n");
Serial.println(F("… Server Response:"));

while(wuClient.connected()) {
while (wuClient.available()) {
char c = wuClient.read();
Serial.print©;
}
}
wuClient.flush();
wuClient.stop();
}
else {
Serial.println(F(«Connection failed»));
char c = wuClient.read();
Serial.write©;
wuClient.flush();
wuClient.stop();}

}