Air Quality with MQ-135 and Wemos D1 mini ESP8266

Measure Air quality with MQ-135 and ESP8266 Wemos D1 mini

As the MQ135 is not  really suited as a CO2 sensor (See my previous blog) and I still wanted to use it, I will use it as an air quality probe on an ESP8266.

As the title mentioned I will use an ESP8266 connected to my local WiFi router for this to send the data to thingspeak.com.Image of the Wemos d1 mini ESP8266 module
The ESP8266 I use is the Wemos D1 mini. The Wemos D1 mini has an USB interface and can be programmed with the normal Arduino GUI. You can add the board to it. See this article for how to add this board to the GUI.

I also use an DHT22 (AM2302) in this project to measure temperature and dht22 connectionshumidity. The DHT22 data pin is connected to pin D5 of the ESP8266 in my project. VCC is connected to the 5V of the ESP, GND is connected to GND.  You can of course any digital pin you want in your project. Just change line “#define DHTPIN D5” with the pin number you want.

For the MQ-135 you can only connect it to pin A0, as this is the only analog pin on the ESP8266.

For the air quality I store the lowest measured value in the EEPROM, so anything worse/higher that this best value is bad air quality. I use variable a1 & a2 & a3 to check if it is an new ESP8266, if these value in EEPROM are different than the stored values I presume that it is a new ESP and then set the lowest value to 510, if the values are the same I do not change the lowest value in EEPROM.

Below the program I use for this project.
I will try to describe any main step of it.

As there are some problems copying the below text I have added download links at the bottom of this page.

// Add the ESP8266 library
#include "ESP8266WiFi.h"

// replace with your channel’s thingspeak API key
String apiKey = "XXXXXXXXXXXXXXXXX";
const char* server = "api.thingspeak.com";

// Add the EEPROM library to store the lowest measured MQ-135 value
#include "EEPROM.h"
int address = 24;
byte value;

// DHT22 setup
#include "DHT.h"
#define DHTPIN D5
#define DHTTYPE DHT22   // DHT 22  (AM2302), AM2321
DHT dht(DHTPIN, DHTTYPE);

float val;
float vall;
int sensorPin = A0;
int sensorValue = 0;
float v;
float h;  // humidity
float tc;  // temperature
float tf;    // temperature
float f = 0.;
float pp = 0.;
// number of analog MQ-135 samples taken each time
int s = 25;
int t;
int x;
int lowest = 500;
int lowest_l;
int lowest_h;
int tel = 0;
int telc = 0;
int id = 1;
int air;
int airt;
int airv;
// change one value below to reset lowest value back to 510
int a1 = 148;
int a2 = 231;
int a3 = 23;
// cl should be >= 3 before writing new low
// value to EEPROM
int cl = 0;

// 5 SSID's possible for when you need to measure
// at different places
const char* ssid1 = "your ssid 1";
const char* password1 = "your ssid 1 password";
const char* ssid2 = "your ssid 2";
const char* password2 = "your ssid 2 password";
const char* ssid3 = "your ssid 3";
const char* password3 = "your ssid 3 password";
const char* ssid4 = "your ssid 4";
const char* password4 = "your ssid 4 password";
const char* ssid5 = "your ssid 5";
const char* password5 = "your ssid 5 password";

// start with ssid1
const char* ssid = ssid1;
const char* password = password1;

WiFiClient client;

void setup() {
  Serial.begin(57600);
  EEPROM.begin(512);
  pinMode(sensorPin, INPUT);
  WiFi.begin(ssid, password);
  Serial.print("Trying ");
  Serial.print (ssid);
  Serial.print(" - ");
  while (WiFi.status() != WL_CONNECTED) {
    telc = telc + 1;
    if ( telc >= 10) {
      if ( id == 1 ) {
        ssid = ssid1;
        password = password1;
        id = 2;
      } else {
        if ( id == 2 ) {
          ssid = ssid2;
          password = password2;
          id = 3;
        } else  {
          if ( id == 3 ) {
            ssid = ssid3;
            password = password3;
            id = 4;
          } else  {
            if ( id == 4 ) {
              ssid = ssid4;
              password = password4;
              id = 5;
            } else {
              if ( id == 5 ) {
                ssid = ssid5;
                password = password5;
                id = 1;
              }
            }
          }
        }
      }
      telc = 0;
      Serial.println(".");
      Serial.print("Trying ");
      Serial.print (ssid);
      Serial.print(" - ");
      WiFi.begin(ssid, password);
    }
    delay(2000);
    Serial.print(".");
  }
  Serial.println("Connected");
  delay(100);
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());

  // check if this is new hardware to set EEPROM to 510
  if (EEPROM.read(505) == a1 || EEPROM.read(506) == a2 || EEPROM.read(507) == a3) {
    Serial.println ("EEPROM setup is correct, not changing current values");
  } else {
    // this should be a new start
    EEPROM.write(500, 255);
    EEPROM.write(501, 255);
    EEPROM.write(505, a1);
    EEPROM.write(506, a2);
    EEPROM.write(507, a3);
    delay(50);
    EEPROM.commit();
    Serial.println ("New start for MQ135, startup values set");
  }
  lowest_l = EEPROM.read(500);
  lowest_h = EEPROM.read(501);
  lowest = lowest_l + lowest_h;
  dht.begin();

  // sleep 10 minutes to warm up the MQ135
  // 10 minutes could be to low as warmup can take longer
  Serial.println("Sleep 10 minutes to warm up MQ-135");
  delay(600000);
}

void loop() {
  v = 0;
  t = 0;
  while (t < s) {
    // Read the anolog value s (25) times
    val = (analogRead(sensorPin)) * 1;
    v = v + val;
    t++;
    delay(10);
  }

  vall = v / s;
  Serial.print ("raw = ");
  Serial.println (vall);
  if (vall <= lowest - 1 ) { cl = cl + 1; } else { cl = 0; } // to avoid wrong low value, the value must be 3 times low if (cl >= 3) {
    cl = 0;
    lowest = vall;
    if (lowest >= 255) {
      lowest_l = 255;
      lowest_h = lowest - 255;
    } else {
      lowest_l = lowest;
      lowest_h = 0;
    }
    EEPROM.write(500, lowest_l);
    EEPROM.write(501, lowest_h);
    delay(50);
    EEPROM.commit();
    Serial.println ("New lowest value, saving to EEPROM");
  }

  vall = vall - lowest;
  if (vall <= 0 ) { vall = 0; } airt = airt + vall; airv = airt / (tel + 1); Serial.print ("low: "); Serial.println (lowest); Serial.print ("Bad Air quality : "); Serial.println (vall); Serial.print ("Bad Air quality average: "); Serial.print (airv); Serial.print (" "); Serial.print (tel + 1); Serial.print (" "); Serial.println (airt); delay(4982); tel = tel + 1; if (tel >= 57) {
    tel = 0;
    air = airt / 57;
    ReadDHT();
    if (tc == 1 && h == 1) {
      delay(2000);
      ReadDHT();
    }
    if (tc == 1 && h == 1) {
      delay(2000);
      ReadDHT();
    }
    if (tc == 1 && h == 1) {
      delay(2000);
      ReadDHT();
    }

    ZendData_thingspeak();
    airt = 0;
  }
}

void ZendData_thingspeak() {
  // I am using 4 fields at Thingspeak
  // 1 = temperature
  // 2 = humidity
  // 3 = Air Quality
  // 4 = lowest ever Air Quality
  if (client.connect(server, 80)) { // "184.106.153.149" or api.thingspeak.com
    String postStr = apiKey;
    postStr += "&field1=";
    postStr += String(tc);
    postStr += "&field2=";
    postStr += String(h);
    postStr += "&field3=";
    postStr += String(air);
    postStr += "&field4=";
    postStr += String(lowest);
    postStr += "\r\n\r\n";

    client.print("POST /update HTTP/1.1\n");
    client.print("Host: api.thingspeak.com\n");
    client.print("Connection: close\n");
    client.print("X-THINGSPEAKAPIKEY: " + apiKey + "\n");
    client.print("Content-Type: application/x-www-form-urlencoded\n");
    client.print("Content-Length: ");
    client.print(postStr.length());
    client.print("\n\n");
    client.print(postStr);
    Serial.println("Data send to Thingspeak");
    client.stop();
  }
}

void ReadDHT() {
  // Reading temperature or humidity takes about 250 milliseconds!
  // Sensor readings may also be up to 2 seconds 'old' (its a very slow sensor)
  h = dht.readHumidity();
  // Read temperature as Celsius (the default)
  tc = dht.readTemperature();
  // Read temperature as Fahrenheit (isFahrenheit = true)
  tf = dht.readTemperature(true);

  // Check if any reads failed and exit early (to try again).
  if (isnan(h) || isnan(tc) || isnan(tf)) {
    Serial.println("Failed to read from DHT sensor!");
    h = 1;
    tc = 1;
    return;
  }
  Serial.print("Humidity: ");
  Serial.print(h, 1);
  Serial.println(" %\t");
  Serial.print("Temperature: ");
  Serial.print(tc, 1);
  Serial.println(" *C ");
}

If you only want to use the MQ135 without the DHT22 then use the code below.

// Add the ESP8266 library
#include "ESP8266WiFi.h"

// replace with your channel’s thingspeak API key
String apiKey = "XXXXXXXXXXXXXXXXX";
const char* server = "api.thingspeak.com";

// Add the EEPROM library to store the lowest measured MQ-135 value
#include "EEPROM.h"
int address = 24;
byte value;

float val;
float vall;
int sensorPin = A0;
int sensorValue = 0;
float v;
float f = 0.;
float pp = 0.;
// number of analog MQ-135 samples taken each time
int s = 25;
int t;
int x;
int lowest = 500;
int lowest_l;
int lowest_h;
int tel = 0;
int telc = 0;
int id = 1;
int air;
int airt;
int airv;
// change one value below to reset lowest value back to 510
int a1 = 148;
int a2 = 231;
int a3 = 23;
// cl should be >= 3 before writing new low
// value to EEPROM
int cl = 0;

// 5 SSID's possible for when you need to measure
// at different places
const char* ssid1 = "your ssid 1";
const char* password1 = "your ssid 1 password";
const char* ssid2 = "your ssid 2";
const char* password2 = "your ssid 2 password";
const char* ssid3 = "your ssid 3";
const char* password3 = "your ssid 3 password";
const char* ssid4 = "your ssid 4";
const char* password4 = "your ssid 4 password";
const char* ssid5 = "your ssid 5";
const char* password5 = "your ssid 5 password";
const char* ssid = ssid1;
const char* password = password1;

WiFiClient client;

void setup() {
  Serial.begin(57600);
  EEPROM.begin(512);
  pinMode(sensorPin, INPUT);
  WiFi.begin(ssid, password);
  Serial.print("Trying ");
  Serial.print (ssid);
  Serial.print(" - ");
  while (WiFi.status() != WL_CONNECTED) {
    telc = telc + 1;
    if ( telc >= 10) {
      if ( id == 1 ) {
        ssid = ssid1;
        password = password1;
        id = 2;
      } else {
        if ( id == 2 ) {
          ssid = ssid2;
          password = password2;
          id = 3;
        } else {
          if ( id == 3 ) {
            ssid = ssid3;
            password = password3;
            id = 4;
          } else {
            if ( id == 4 ) {
              ssid = ssid4;
              password = password4;
              id = 5;
            } else {
              if ( id == 5 ) {
                ssid = ssid5;
                password = password5;
                id = 1;
              }
            }
          }
        }
      }
      telc = 0;
      Serial.println(".");
      Serial.print("Trying ");
      Serial.print (ssid);
      Serial.print(" - ");
      WiFi.begin(ssid, password);
    }
    delay(2000);
    Serial.print(".");
  }
  Serial.println("Connected");
  delay(100);
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());

  // check if this is new hardware to set EEPROM to 510
  if (EEPROM.read(505) == a1 || EEPROM.read(506) == a2 || EEPROM.read(507) == a3) {
    Serial.println ("EEPROM setup is correct, not changing current values");
  } else {
    // this should be a new start
    EEPROM.write(500, 255);
    EEPROM.write(501, 255);
    EEPROM.write(505, a1);
    EEPROM.write(506, a2);
    EEPROM.write(507, a3);
    delay(50);
    EEPROM.commit();
    Serial.println ("New start for MQ135, startup values set");
  }
  lowest_l = EEPROM.read(500);
  lowest_h = EEPROM.read(501);
  lowest = lowest_l + lowest_h;


  // sleep 10 minutes to warm up the MQ135
  // 10 minutes could be to low as warmup can take longer
  Serial.println("Sleep 10 minutes to warm up MQ-135");
  delay(600000);
}

void loop() {
  v = 0;
  t = 0;
  while (t < s) {
    // Read the anolog value s (25) times
    val = (analogRead(sensorPin)) * 1;
    v = v + val;
    t++;
    delay(10);
  }

  vall = v / s;
  Serial.print ("raw = ");
  Serial.println (vall);
  if (vall <= lowest - 1 ) { cl = cl + 1; } else { cl = 0; } // to avoid wrong low value, the value must be 3 times low if (cl >= 3) {
    cl = 0;
    lowest = vall;
    if (lowest >= 255) {
      lowest_l = 255;
      lowest_h = lowest - 255;
    } else {
      lowest_l = lowest;
      lowest_h = 0;
    }
    EEPROM.write(500, lowest_l);
    EEPROM.write(501, lowest_h);
    delay(50);
    EEPROM.commit();
    Serial.println ("New lowest value, saving to EEPROM");
  }

  vall = vall - lowest;
  if (vall <= 0 ) { vall = 0; } airt = airt + vall; airv = airt / (tel + 1); Serial.print ("low: "); Serial.println (lowest); Serial.print ("Bad Air quality : "); Serial.println (vall); Serial.print ("Bad Air quality average: "); Serial.print (airv); Serial.print ("  "); Serial.print (tel + 1); Serial.print ("  "); Serial.println (airt); delay(4982); tel = tel + 1; if (tel >= 57) {
    tel = 0;
    air = airt / 57;
    ZendData_thingspeak();
    airt = 0;
  }
}

void ZendData_thingspeak() {
  // I am using 2 fields at Thingspeak
  // 1 = Air Quality
  // 2 = lowest ever Air Quality
  if (client.connect(server, 80)) { // "184.106.153.149" or api.thingspeak.com
    String postStr = apiKey;
    postStr += "&field1=";
    postStr += String(air);
    postStr += "&field2=";
    postStr += String(lowest);
    postStr += "\r\n\r\n";

    client.print("POST /update HTTP/1.1\n");
    client.print("Host: api.thingspeak.com\n");
    client.print("Connection: close\n");
    client.print("X-THINGSPEAKAPIKEY: " + apiKey + "\n");
    client.print("Content-Type: application/x-www-form-urlencoded\n");
    client.print("Content-Length: ");
    client.print(postStr.length());
    client.print("\n\n");
    client.print(postStr);
    Serial.println("Data send to Thingspeak");
    client.stop();
  }
}
 

Download links.

Microsoft Explorer and Microsoft Edge seems to put this on one unusable line.
But Firefox and Google Chrome are both working.

MQ135_DHT22_ESP8266.ino
MQ135_ESP8266.ino

shop at aliexpress

11 thoughts on “Air Quality with MQ-135 and Wemos D1 mini ESP8266”

  1. Please help me. I’m a beginner.
    Unfortunately, the code does not work. I can upload it without error, but it is not connected to the router. I replaced the semicolons because they did not abandon the Arduino IDE.
    Do not know where the bug is?
    Thanks

    1. Hi Jozsef,

      Lets try it without the multi SSID’s

      Just above the “WiFi.begin(ssid, password);” add two lines:
      ssid = ssid1;
      password = password1;
      WiFi.begin(ssid, password);

      Change the ssid1 and password1 with the login values of your router.

      Regards,
      Rob.

  2. Hello,
    This is Bhavana, I have stated this project directly with NodeMCU8266 I’m also facing the same problem can you help me as soon as possible.

    Regards,
    Bhavana.

  3. Hi,
    what this value means ? “int s = 25; ”
    Can i change it? or how do i know which value is ok for me?

    Thanks.

    1. Hi Dani,

      It is used in a loop. the loop now runs 25 times and measures the air quality. All measurements are added to one total and then divided again thru 25. So the outcome is the average of the 25 measurements.
      You can change the number, but better not make it smaller, otherwise it will fluctuate much more.
      Making s bigger is no problem.

      Regards,
      Rob.

  4. Hello,
    If I understand correctly the project look at deviation of reading right?
    If it is the case how can I know the initial readings are not already base on actual bad air quality?
    is there a standard value of minimum air quality I can use a minimum reference?
    By the way, it work righ away when I tried it.
    Thanks
    Eric

    1. Hi Eric,

      The script is storing the lowest ever measured value in flash.
      So take the meter out with an powerbank to the woods or farmlands.
      You can presume that the air will be almost clean there.
      The value will than be stored.
      So at home you can see how ‘bad/good’ the air quality is in reverence to the woods/farmlands.

      Regards,
      Rob.

Leave a Reply

Your email address will not be published. Required fields are marked *

This site uses Akismet to reduce spam. Learn how your comment data is processed.