Step 1 - Plug the Weather and Level Adapter and Boron into the IoT Node
Step 2 - Mount the temperature and humidity sensor in the solar radiation shield
Step 3 - Plug the sensors into the IoT Node
Step 4 - Create ThingSpeak and Particle accounts and register your device
Step 5 - Add Webhooks to your Particle account
Step 6: Program your Particle device and test
Step 7: Install your weather station and analyze the data

Published December 4, 2019 © MIT

Solar Powered Cellular Weather Station

Measure wind, rain, temperature, humidity, and light in remote locations using ThingSpeak, Particle, and the Sentient Things IoT Node.

IntermediateFull instructions provided6 hours13,379

Things used in this project

Hardware components

Sentient Things IoT Node

Sentient Things AM2315 Temperature and Humidity Sensor

Sentient Things Outdoor Light Sensor

Sentient Things Weather Station and Level Adapter

Particle Boron

SparkFun Weather Meters

Adafruit Lithium Ion Battery Pack - 3.7V 6600mAh

Voltaic Systems 9 Watt Solar Panel

Voltaic Systems Female 3.5x1.1mm - Extension with Leads

APRS World, LLC Solar Radiation Shield

SanDisk 8GB micro SD card

Software apps and online services

ThingSpeak API

Particle Build Web IDE

Story

This project describes the latest generation of a weather station used by the ThingSpeak team at MathWorks (see ThingSpeak Weather Station & Data Analysis for an earlier version).

This weather station provides the following improvements:

Optional solar power for locations without power
Easily repeatable and maintainable packaging and electronics based on the Sentient Things IoT Node
Updated firmware with micro SD card data logging, store and forwarding of data to overcome communication outages, and optional automatic ThingSpeak channel creation

Step 1 - Plug the Weather and Level Adapter and Boron into the IoT Node

The first step in the project is to plug the Sentient Things Weather and Level Adapter and the Particle Boron LTE (or similar Feather-based device) into the Adafruit Feather compatible header on the Sentient Things IoT Node as shown below:

Assembling the Sentient Things IoT Node, Particle Boron, and Weather and Level Adapter

The Sentient Things IoT Node is a general purpose board with an Adafruit compatible header that is designed to be the foundation of a wide range of IoT projects. It comes with a hinged water resistant enclosure and the board includes the following features:

Expandable header that is a super set of the Adafruit Feather header
Solar or mains with LiPo battery charger
Optional 3AA/A secondary battery
A real time clock and calendar with super capacitor backup
Real time clock power switching capability - i.e. the clock can power off the electronics like a deep sleep mode but with lower power consumption
Analog watchdog timer
256kbit FRAM memory
micro SD card slot
Three I/O headers that expose GPIO, serial and I2C (more may be added with additional adapters)

Most importantly, to keep your options open, it does not include a microcontroller. Almost any microcontroller that is compatible with the Feather footprint will work. This project uses the Particle Boron LTE but it is also possible to use a wide range of alternative devices such as the Adafruit HUZZAH32 for example. If you happen to have Particle Photons or Electrons you may use those too with an adapter that converts to the Feather footprint.

Step 2 - Mount the temperature and humidity sensor in the solar radiation shield

Assemble the Sentient Things AM2315 Temperature and Humidity Sensor into the solar radiation shield. Note that if you already have an AM2315 sensor you can use it and add your own RJ45 connector following the pinouts described below:

Pinouts for the AM2315. Connect SDA, SCL, 3V3 and GND as shown above.

The recommended solar radiation shield fits the AM2315 sensor well as shown below but other shields will work too.

Mount the AM2315 in the solar radiation shield.

Step 3 - Plug the sensors into the IoT Node

Plug the rain and wind weather meters, AM2315 Temperature and Humidity Sensor and TSL2591 Outdoor Light Sensor into the Sentient Things IoT Node and Weather and Level Adapter connectors. The AM2315 may be plugged into any one of the I/O connectors since they all include the I2C bus. The Wind and the Rain RJ11 connectors are marked on the Weather and Level Adapter and the Voltaic Systems 6V solar panel with extension plugs into the 6V connector. The 6V solar polarity is marked on the board. Also remember to plug a FAT formatted micro SD card into the micro SD slot on the board so that weather data an also be saved locally. Pass the cables through the cable glands as shown. Note that the Weather and Level Adapter includes a MPL3115A2 pressure and altitude sensor so do not make the glands completely airtight to allow the pressure inside the enclosure to equalize with the outside pressure. When finally mounting the enclosure outside make sure that the glands face downwards to prevent water from leaking into the enclosure.

Plug the weather station sensors into the IoT Node

Step 4 - Create ThingSpeak and Particle accounts and register your device

Create a ThingSpeak and a Particle account if you do not have one already. ThingSpeak offers free accounts for non-commercial use and Particle offers a free service level too. Note that if you use the Particle cellular option then there is a monthly fee for the data that you use.

ThingSpeak will be used to collect, display and analyze weather data in the cloud and Particle provides the device hardware, firmware and device connectivity. Particle also provides a Webhooks cloud service (described below) that will be used to minimize the data traffic.

Follow the Particle Quickstart guide to set up your Particle device (associate it with your Particle account and set up WiFi if applicable). Particle offers a handy Android or iOS app for device setup. You will also need to follow Particle's instructions to register your SIM if you are using a cellular device like the Boron LTE.

Step 5 - Add Webhooks to your Particle account

ThingSpeak offers both REST and MQTT APIs to send data to ThingSpeak. ThingSpeak also provides a Particle/Arduino compatible library to make it easy to use the APIs. This library is an excellent choice for devices that are connected via WiFi or Ethernet where there are no data charges. In the case of cellular though, it is best to minimize the data traffic by not using REST directly. One of the best ways to do that is to use Particle's (low overhead) COAP protocol to send data to the Particle servers and to have the Particle servers relay the data via REST (http) to ThingSpeak. This is done using Particle Webhooks.

The Sentient Things firmware makes use of the Particle Webhooks listed in the Code section below. Log into your Particle account Console and create three Webhooks under Integrations by pasting the JSON code below into Custom Templates and saving.

Copy and paste each Webhook JSON snippet into the Custom Template field

Note that for the Webhooks that create and update a ThingSpeak channel you will need to replace XXXXXXXXXXXXXXXX with your 16 character ThingSpeak User API key listed under your account profile on ThingSpeak.

Step 6: Program your Particle device and test

The Weather firmware listed below is used to program your Particle device. This may be done using the Particle Web IDE or by using Particle Workbench if you are familiar with the Visual Studio Code based desktop development environment. You may copy and paste the code below into a new project on the Particle Web IDE or simply follow this link to a shared version of the firmware.

You may program or flash your device over the air (at the expense of data usage) or you may flash locally connected to your computer to avoid cellular data charges by following Particle's instructions.

Plug your device into the IoT Node (if it is not there already) and turn the POWER switch on the IoT node to FBAT to supply power to Particle device. The first time your firmware runs with the Particle device plugged into the IoT Node it detects that it is the first time that it is running (by looking for a "magic number" in FRAM) and creates a new ThingSpeak channel using the Particle Webhooks that you created earlier. When you visit ThingSpeak you should see a newly created channel that looks like this:

Your firmware creates a new ThingSpeak channel with field labels and tags

The firmware saves the channel number and channel Read and Write keys sent back from ThingSpeak in FRAM for future writes to the created channel.

With the firmware running you should see weather data being posted to ThingSpeak every minute.

The firmware prints serial debug messages so if you are having trouble the first step is to connect the USB output of the Particle device to your computer and monitor the serial output. If you have the Particle CLI installed on your computer you will see the Particle device as a COM port. The Particle CLI command:

particle serial monitor --follow

is a handy way to connect to and view the serial debug output from the Particle device.

Note the following code snippet close to the top of the code:

//********CHANGE BELOW AS NEEDED**************
// Set to true and enter TS channel ID and keys AND change firstRunTest to use an existing TS channel
// Set to false if you wish to create a new TS channel the first time the code runs
bool useManualTSChannel = false;
const char *manualTSWriteKey = "XXXXXXXXXXXXXXXX";
const char *manualTSReadKey = "XXXXXXXXXXXXXXXX";
const int manualTSChannel = 895141;
// Change this value to force hard reset and clearing of FRAM when Flashing
// You have to change this value (if you have flashed before) for the TS channel to change
const int firstRunTest = 1122124;
//********CHANGE ABOVE AS NEEDED**************

You may change

bool useManualTSChannel = false;

bool useManualTSChannel = true;

and add your own ThingSpeak keys and channel number to use an existing channel.

Note that you will also need to change the "magic number"

const int firstRunTest = 1122124;

to a different value so that the firmware detects that it is running for the first time to create a new or use an existing channel.

Step 7: Install your weather station and analyze the data

Weather station anemometers are best installed away from buildings high off the ground. Options include building your own mast or using a tripod to mount the meters and the rest of the sensors on a rooftop.

ThingSpeak does a wonderful job of displaying your weather data in real-time charts on the Web. It it also possible to analyze and display your data using MATLAB as described in the previous article.

Visit the ThingSpeak weather station at MathWorks for a live demo:

Code

/*
 * Project Sentient Things IoT Node weather station
 * Description: Weather station and light level monitor. Measures Weather
 * and light level data and sends the results to Thingspeak.com
 * Author: Robert Mawrey, Sentient Things, Inc.
 * Date: December 2019
 */
#include "Particle.h"
#include "WeatherSensors.h" //(0.0.2)
#include <thingspeak-webhooks.h> //(0.0.11)
#include <ArduinoJson.h> //(5.13.4)
#include "IoTNode.h" //(0.0.2)
#include "SdCardLogHandlerRK.h" //0.1.0)

#define SERIAL_DEBUG

#ifdef SERIAL_DEBUG
  #define DEBUG_PRINT(...) Serial.print(__VA_ARGS__)
  #define DEBUG_PRINTLN(...) Serial.println(__VA_ARGS__)
#else
  #define DEBUG_PRINT(...)
  #define DEBUG_PRINTLN(...)
#endif

const int SD_CHIP_SELECT = N_D0;
SdFat sd;
SdCardPrintHandler printToSd(sd, SD_CHIP_SELECT, SPI_FULL_SPEED);

STARTUP(printToSd.withMaxFilesToKeep(3000));

#define SENSOR_SEND_TIME_MS 60000
#define SENSOR_POLL_TIME_MS 2000

#define IOTDEBUG

LEDStatus fadeRed(RGB_COLOR_RED, LED_PATTERN_FADE, LED_SPEED_NORMAL, LED_PRIORITY_IMPORTANT);

const int firmwareVersion = 0;

SYSTEM_THREAD(ENABLED);

// Using SEMI_AUTOMATIC mode to get the lowest possible data usage by
// registering functions and variables BEFORE connecting to the cloud.
//SYSTEM_MODE(SEMI_AUTOMATIC);

// Use structs defined in WeatherSensors.h
sensorReadings_t sensorReadings;
config_t config;

//********CHANGE BELOW AS NEEDED**************
// Set to true and enter TS channel ID and keys AND change firstRunTest to use an existing TS channel
// Set to false if you wish to create a new TS channel the first time the code runs
bool useManualTSChannel = false;
const char *manualTSWriteKey = "JEI7XXXXXXXXJZT9";
const char *manualTSReadKey = "2BQPVMCBXXXXXXXX";
const int manualTSChannel = 893241;
// Change this value to force hard reset and clearing of FRAM when Flashing
// You have to change this value (if you have flashed before) for the TS channel to change
const int firstRunTest = 1122124;
//********CHANGE ABOVE AS NEEDED**************


// ThingSpeak webhook keys. Do not edit.
char const* webhookKey[] = {
    "d", // "description=",
    "e", // "elevation=",
    "1", // "field1=",
    "2", // "field2=",
    "3", // "field3=",
    "4", // "field4=",
    "5", // "field5=",
    "6", // "field6=",
    "7", // "field7=",
    "8", // "field8=",
    "a", // "latitude=",
    "o", // "longitude=",
    "n", // "name=",
    "f", // "public_flag=",
    "t", // "tags=",
    "u", // "url=",
    "m", // "metadata=",
    // "api_key=",
    "end" //Do not remove or change
};

// ThingSpeak create Channel labels. Do not edit.
char const* chanLabels[] = {
    "description",
    "elevation",
    "field1",
    "field2",
    "field3",
    "field4",
    "field5",
    "field6",
    "field7",
    "field8",
    "latitude",
    "longitude",
    "name",
    "public_flag",
    "tags",
    "url",
    "metadata",
    "end" //Do not remove or change
};

//Sensor Names
char const* sensorNames[] = {
  "Weather station using the Sentient Things IoT Node",   // "description=",
  "",                       // "elevation=",
  "Wind Direction deg.",    // "field1=",
  "Wind Speed mph",         // "field2=",
  "Humidity %",             // "field3=",
  "Air Temperature F",      // "field4=",
  "Rainfall in.",           // "field5=",
  "Air Pressure in.",       // "field6=",
  "Battery Voltage V",      // "field7"
  "Light Intensity lux",    // "field8=",
  "",                       // "latitude=",
  "",                       // "longitude=",
  "Weather station",        // "name=",
  "false",                  // "public_flag=",
  "",                       // "tags=",
  "http://sentientthings.com",   // "url=",
  "",                       // "metadata=",
  "end"
};

// This is the index for the updateTSChan
int returnIndex;

byte messageSize = 1;

Timer pollSensorTimer(SENSOR_POLL_TIME_MS, capturePollSensors);

Timer sensorSendTimer(SENSOR_SEND_TIME_MS, getResetAndSendSensors);

Timer unpluggedTimer(5000,unplugged);

WeatherSensors sensors; //Interrupts for anemometer and rain bucket
// are set up here too

IoTNode node;

ThingSpeakWebhooks thingspeak;

// // Create FRAM array and ring
framArray framConfig = node.makeFramArray(1, sizeof(config));

framRing dataRing = node.makeFramRing(300, sizeof(sensorReadings));

bool readyToGetResetAndSendSensors = false;
bool readyToCapturePollSensors = false;
bool tickleWD = false;

unsigned long timeToNextSendMS;

String deviceStatus;
String i2cDevices;
bool resetDevice = false;

String i2cNames[] =
{
    "RTC",
    "Exp",
    "RTC EEPROM",
    "ADC",
    "FRAM",
    "AM2315",
    "MPL3115",
    "TSL2591"
};

byte i2cAddr[]=
{
    0x6F, //111
    0x20, //32
    0x57, //87
    0x4D, //77
    0x50, //80
    0x5C, //
    0x60,
    0x29
    
};

/* number of elements in `array` */
static const size_t i2cLength = sizeof(i2cAddr) / sizeof(i2cAddr[0]);

bool i2cExists[]=
{
  false,
  false,
  false,
  false,
  false,
  false,
  false,
  false
};

// check i2c devices with i2c names at i2c address of length i2c length returned in i2cExists
bool checkI2CDevices()
{
  byte error, address;
  bool result = true;
  for (size_t i; i<i2cLength; ++i)
  {
    // The i2c_scanner uses the return value of
    // the Write.endTransmisstion to see if
    // a device did acknowledge to the address.
    address = i2cAddr[i];

    Wire.beginTransmission(address);
    error = Wire.endTransmission();

    //Try again if !error=0
    if (!error==0)
    {
      delay(10);
      Wire.beginTransmission(address);
      error = Wire.endTransmission();
    }

    //Try reset if !error=0
    if (!error==0)
    {
      Wire.reset();
      Wire.beginTransmission(address);
      error = Wire.endTransmission();
    }
 
    if (error == 0)
    {
      DEBUG_PRINTLN(String("Device "+i2cNames[i]+ " at"+" address:0x"+String(address, HEX)));
      i2cExists[i]=true;
    }
    else
    {
      DEBUG_PRINTLN(String("Device "+i2cNames[i]+ " NOT at"+" address:0x"+String(address, HEX)));
      i2cExists[i]=false;
      result = false;
    }
  }
  return result;
}


void printI2C(int inx)
{
    for (int i=0; i<i2cLength; i++)
        {
          if (i2cAddr[i] == inx)
          {
              DEBUG_PRINTLN(String("Device "+i2cNames[i]+ " at"+" address:0x"+String(i2cAddr[i], HEX)));
          }
        }        
}

void scanI2C()
{
  byte error, address;
  int nDevices;
 
  DEBUG_PRINTLN("Scanning...");
  nDevices = 0;
  for(address = 1; address < 127; address++ )
  {
    // The i2c_scanner uses the return value of
    // the Write.endTransmisstion to see if
    // a device did acknowledge to the address.
    Wire.beginTransmission(address);
    error = Wire.endTransmission();
 
    if (error == 0)
    {
      printI2C(address);
 
      nDevices++;
    }
    else if (error==4)
    {
      DEBUG_PRINT("Unknown error at address 0x");
      if (address<16)
        DEBUG_PRINT("0");
      DEBUG_PRINTLN(address,HEX);
    }    
  }
  if (nDevices == 0)
    DEBUG_PRINTLN("No I2C devices found\n");
  else
    DEBUG_PRINTLN("done\n");
}

// Adding explicit connect routine that has to work before the rest of the code runs
void connect()
{
  #if Wiring_Cellular
  bool cellready=Cellular.ready();
  if (!cellready)
  {
    DEBUG_PRINTLN("Attempting to connect cellular...");
    Cellular.on();
    Cellular.connect();
    waitFor(Cellular.ready,180000);
    if (!Cellular.ready())
    {
    DEBUG_PRINTLN("Cellular not ready - resetting");
    delay(200);
    System.reset();
    }
  }
  else
  {
    DEBUG_PRINTLN("Cellular ready");
  }
  #endif
  
  #if Wiring_WiFi
  if (!WiFi.hasCredentials())
  {
    DEBUG_PRINTLN("Please add WiFi credentials");
    DEBUG_PRINTLN("Resetting in 60 seconds");
    delay(60000);
    System.reset();
  }
  bool wifiready=WiFi.ready();
  if (!wifiready)
  {
    DEBUG_PRINTLN("Attempting to connect to WiFi...");
    WiFi.on();
    WiFi.connect();
    waitFor(WiFi.ready,60000);
    if (!WiFi.ready())
    {
    DEBUG_PRINTLN("WiFi not ready - resetting");
    delay(200);
    System.reset();
    }
  }
  else
  {
    DEBUG_PRINTLN("Cellular ready");
  }
  #endif

  bool partconnected=Particle.connected();
  if (!partconnected)
  {
    DEBUG_PRINTLN("Attempting to connect to Particle...");
    Particle.connect();
    // Note: that conditions must be a function that takes a void argument function(void) with the () removed,
    // e.g. Particle.connected instead of Particle.connected().
    waitFor(Particle.connected,60000);
    if (!Particle.connected())
    {
      DEBUG_PRINTLN("Particle not connected - resetting");
      delay(200);
      System.reset();
    } 
  }
  else
  {
    DEBUG_PRINTLN("Particle connected");
  }
}

// setup() runs once, when the device is first turned on.
void setup() {
  // register cloudy things
  Particle.variable("version",firmwareVersion);
  Particle.variable("devicestatus",deviceStatus);

  // Subscribe to the TSBulkWriteCSV response event
  Particle.subscribe(System.deviceID() + "/hook-response/TSBulkWriteCSV", TSBulkWriteCSVHandler, MY_DEVICES);
  // Put a test in here for first run
  // Subscribe to the TSCreateChannel response event
  Particle.subscribe(System.deviceID() + "/hook-response/TSCreateChannel", TSCreateChannelHandler, MY_DEVICES);

  // etc...
  // then connect
  //Particle.connect();
  Serial.begin(115200);
  Serial1.begin(115200);

  node.begin();
  node.setPowerON(EXT3V3,true);
  node.setPowerON(EXT5V,true);

  #ifdef IOTDEBUG
  delay(5000);
 
  checkI2CDevices();
  scanI2C();
  #endif

    // Check for I2C devices again
  if (!node.ok())
  {
    #ifdef IOTDEBUG
    // Particle.publish("Unplugged","Plug the device into the IoT Node",PRIVATE);
    DEBUG_PRINTLN("Plug the device into the IoT Node");
    #endif
    deviceStatus="Device is not plugged into the IoTNode";
    fadeRed.setActive(true);
    DEBUG_PRINTLN("Resetting in 10 seconds");
    delay(10000);
    System.reset();
  }
  else
  {
    
    connect();
    framConfig.read(0, (uint8_t*)&config);

      // Code for initialization of the IoT Node
      // i.e. the first time the software runs
      // 1. A new ThingSpeak channel is created
      // 2. The channel id and keys are Saved
      // 3. a firstRunTest variable is saved in persistent memory as a flag to indicate
      // that the IoT node has been set up already.

    if (config.testCheck != firstRunTest)
    {
      // myFram.format();
      if (useManualTSChannel)
      {
        // Use the manually entered ThingSpeak channel and keys above
        config.channelId = manualTSChannel;
        strcpy(config.writeKey,manualTSWriteKey);
        strcpy(config.readKey,manualTSReadKey);
        config.testCheck = firstRunTest;
        /// Defaults
        config.particleTimeout = 20000;
        // Save to FRAM
        framConfig.write(0, (uint8_t*)&config);
        #ifdef IOTDEBUG
        Particle.publish("Updating to use channel number:",String(manualTSChannel),PRIVATE);
        DEBUG_PRINTLN(manualTSChannel);
        DEBUG_PRINTLN(manualTSWriteKey);
        DEBUG_PRINTLN(manualTSReadKey);
        #endif
      }
      else
      {
        // Create a new ThingSpeak Channel
        thingspeak.TSCreateChan(webhookKey,sensorNames, returnIndex);
        unsigned long webhookTime = millis();
        framConfig.read(0, (uint8_t*)&config);
        // Waits for TSCreateChannelHandler to run and set config.testCheck = firstRunTest
        while (config.testCheck != firstRunTest && millis()-webhookTime<60000)
        {
          #ifdef IOTDEBUG
          Particle.publish("Trying to create ThingSpeak channel",PRIVATE);
          DEBUG_PRINTLN("Trying to create ThingSpeak channel");
          #endif
          delay(5000);
        }
        System.reset();      
      }
      
    }
    else
    {
      #ifdef IOTDEBUG
      Particle.publish("Using previously created channel number",String(config.channelId),PRIVATE);
      DEBUG_PRINTLN("Using previously created channel number"+String(config.channelId));
      #endif
    }
      // end of first run code.

      if (syncRTC())
      {
        DEBUG_PRINTLN("RTC sync'ed with cloud");
      }
      else
      {
        DEBUG_PRINTLN("RTC not sync'ed with cloud");
      }
      // load pointers
      dataRing.initialize();
      sensors.begin();
      pollSensorTimer.start();
      sensorSendTimer.start();  
  }
}


void loop() {
  if (readyToGetResetAndSendSensors)
  {
    sensors.getAndResetAllSensors();
    String lastCsvData = "";
    messageSize = 1;
    if (!dataRing.isEmpty())
    {
      sensorReadings_t temporaryReadings;
      dataRing.peekLast((uint8_t*)&temporaryReadings);
      lastCsvData = "|" + sensors.sensorReadingsToCsvUS(temporaryReadings);
      messageSize = 2;
    }
    dataRing.push((uint8_t*)&sensorReadings);
    String currentCsvData = sensors.sensorReadingsToCsvUS();

    // Consider putting the SD logging in the IoTNode library
    printToSd.println(currentCsvData);

    String csvData = currentCsvData + lastCsvData;
    #ifdef IOTDEBUG
    DEBUG_PRINTLN();
    DEBUG_PRINTLN(csvData);
    DEBUG_PRINTLN(String(config.channelId));
    DEBUG_PRINTLN(String(config.writeKey));
    #endif
    String time_format = "absolute";
    if (waitFor(Particle.connected,config.particleTimeout)){
      // Update TSBulkWriteCSV later to use chars
      thingspeak.TSBulkWriteCSV(String(config.channelId), String(config.writeKey), time_format, csvData);
    }
    else
    {
      DEBUG_PRINTLN("Timeout");
    }
    readyToGetResetAndSendSensors = false;

    if (tickleWD)
    {
      node.tickleWatchdog();
      tickleWD = false;
    }

    readyToGetResetAndSendSensors = false;
    #ifdef IOTDEBUG
    DEBUG_PRINTLN("readyToGetResetAndSendSensors");
    #endif
    // Update status information
    deviceStatus = 
    String(config.channelId)+"|"+
    String(config.testCheck)+"|"+
    String(config.writeKey)+"|"+
    String(config.readKey)+"|"+
    String(config.unitType)+"|"+
    String(config.firmwareVersion)+"|"+
    String(config.particleTimeout)+"|"+
    String(config.latitude)+"|"+
    String(config.longitude)+"|"+
    i2cDevices;

  }

  if (readyToCapturePollSensors)
  {
    sensors.captureTempHumidityPressure();
    sensors.captureWindVane();
    sensors.captureLightLux();
    sensors.captureBatteryVoltage();
    readyToCapturePollSensors = false;
    #ifdef IOTDEBUG
    Particle.publish("Capturing sensors",PRIVATE);
    DEBUG_PRINTLN("capture");
    #endif
  }
  // If flag set then reset here
  if (resetDevice)
  {
    System.reset();
  }

}

void capturePollSensors()
{
  // Set the flag to poll the sensors
  readyToCapturePollSensors = true;
}

void getResetAndSendSensors()
{
  // Set the flag to read and send data.
  // Has to be done out of this Timer thread
  timeToNextSendMS = millis();
  readyToGetResetAndSendSensors = true;
}

void TSBulkWriteCSVHandler(const char *event, const char *data) {
  timeToNextSendMS = SENSOR_SEND_TIME_MS - (millis() - timeToNextSendMS);
  String resp = "true";
  if (resp.equals(String(data)))
  {
    sensorReadings_t temporaryReadings;
    if (messageSize == 2)
    {
      dataRing.popLast((uint8_t*)&temporaryReadings);
      dataRing.popLast((uint8_t*)&temporaryReadings);
    }
    else
    {
      dataRing.popLast((uint8_t*)&temporaryReadings);
    }
    #ifdef IOTDEBUG
    DEBUG_PRINTLN(data);
    #endif
  }
  tickleWD = true;
}

void TSCreateChannelHandler(const char *event, const char *data) {
  // Handle the TSCreateChannel response
  StaticJsonBuffer<256> jb;
  #ifdef IOTDEBUG
  DEBUG_PRINTLN(data);
  #endif
  //JsonObject& obj = jb.parseObject((char*)data);
  JsonObject& obj = jb.parseObject(data);
  if (obj.success()) {
      int channelId = obj["i"];
      const char* write_key = obj["w"];
      const char* read_key = obj["r"];
      // Copy to config
      config.channelId = channelId;
      strcpy(config.writeKey,write_key);
      strcpy(config.readKey,read_key);
      config.testCheck = firstRunTest;
      /// Defaults
      config.particleTimeout = 20000;
      // Save to FRAM
      framConfig.write(0, (uint8_t*)&config);
      #ifdef IOTDEBUG
      DEBUG_PRINTLN(channelId);
      DEBUG_PRINTLN(write_key);
      DEBUG_PRINTLN(read_key);
      #endif
      int len = sizeof(channelId)*8+1;
      char buf[len];
      char const* chan = itoa(channelId,buf,10);
      if (returnIndex!=-1)
      {
        thingspeak.updateTSChan(chan,sensorNames,chanLabels,returnIndex);
      }
      String chanTags = "weather, light, wind, temperature, humidity, pressure, Sentient Things," + System.deviceID();
      String lab = "tags";
      delay(1001);
      thingspeak.TSWriteOneSetting(channelId, chanTags, lab);
 
      ///
  } else {
      DEBUG_PRINTLN("Parse failed");
      Particle.publish("Parse failed",data,PRIVATE);
  }

}

bool syncRTC()
{
    uint32_t syncNow;
    bool sync = false;
    unsigned long syncTimer = millis();

    do
    {
      Particle.process();
      delay(100);
    } while (Time.now() < 1465823822 && millis()-syncTimer<500);

    if (Time.now() > 1465823822)
    {
        syncNow = Time.now();//put time into memory
        node.setUnixTime(syncNow);
        sync = true;
    }

    if (!sync)
    {
        #ifdef DEBUG
        Particle.publish("Time NOT synced",String(Time.format(syncNow, TIME_FORMAT_ISO8601_FULL)+"  "+Time.format(node.unixTime(), TIME_FORMAT_ISO8601_FULL)),PRIVATE);
        #endif
    }
    return sync;
}

void unplugged()
{
  #ifdef IOTDEBUG
  Particle.publish("Unplugged","Plug the device into the IoT Node",PRIVATE);
  DEBUG_PRINTLN("Plug the device into the IoT Node");
  #endif

}

{
    "event": "TSBulkWriteCSV",
    "responseTopic": "{{PARTICLE_DEVICE_ID}}/hook-response/TSBulkWriteCSV",
    "url": "https://api.thingspeak.com/channels/{{c}}/bulk_update.csv",
    "requestType": "POST",
    "noDefaults": true,
    "rejectUnauthorized": true,
    "responseTemplate": "{{success}}",
    "headers": {
        "Content-Type": "application/x-www-form-urlencoded"
    },
    "form": {
        "write_api_key": "{{k}}",
        "time_format": "{{t}}",
        "updates": "{{d}}"
    }
}

{
    "event": "TSWriteOneSetting",
    "responseTopic": "{{PARTICLE_DEVICE_ID}}/hook-response/TSWriteOneSetting",
    "url": "https://api.thingspeak.com/channels/{{c}}.json",
    "requestType": "PUT",
    "noDefaults": true,
    "rejectUnauthorized": true,
    "headers": {
        "Content-Type": "application/x-www-form-urlencoded"
    },
    "form": {
        "api_key": "XXXXXXXXXXXXXXXX",
        "{{n}}": "{{d}}"
    }
}

{
    "event": "TSCreateChannel",
    "responseTopic": "{{PARTICLE_DEVICE_ID}}/hook-response/TSCreateChannelJson",
    "url": "https://api.thingspeak.com/channels.json",
    "requestType": "POST",
    "noDefaults": true,
    "rejectUnauthorized": true,
    "responseTemplate": "{\"i\":{{id}},\"w\":\"{{api_keys.0.api_key}}\", \"r\":\"{{api_keys.1.api_key}}\"}",
    "headers": {
        "Content-Type": "application/x-www-form-urlencoded"
    },
    "form": {
        "api_key": "XXXXXXXXXXXXXXXX",
        "description": "{{d}}",
        "elevation": "{{e}}",
        "field1": "{{1}}",
        "field2": "{{2}}",
        "field3": "{{3}}",
        "field4": "{{4}}",
        "field5": "{{5}}",
        "field6": "{{6}}",
        "field7": "{{7}}",
        "field8": "{{8}}",
        "latitude": "{{a}}",
        "longitude": "{{o}}",
        "name": "{{n}}",
        "public_flag": "{{f}}",
        "tags": "{{t}}",
        "url": "{{u}}",
        "metadata": "{{m}}"
    }
}

Credits

Robert Mawrey

2 projects • 31 followers

Founder and CEO of Sentient Things, Inc. Former CEO of IoT startup ioBridge.com, the creators of ThingSpeak.com.

Thanks to Rob Purser, Christopher Staples, Hans Scharler, David Rich, Eric Wetjen, and Haodong Liang.

Solar Powered Cellular Weather Station

Things used in this project

Hardware components

Software apps and online services

Story

Step 1 - Plug the Weather and Level Adapter and Boron into the IoT Node

Step 2 - Mount the temperature and humidity sensor in the solar radiation shield

Step 3 - Plug the sensors into the IoT Node

Step 4 - Create ThingSpeak and Particle accounts and register your device

Step 5 - Add Webhooks to your Particle account

Step 6: Program your Particle device and test

Step 7: Install your weather station and analyze the data

Schematics

Weather and Level Adapter Hardware Files

IoT Node Hardware Files

Code

Weather Station Code

TSBulkWriteCSV Webhook

TSWriteOneSetting Webhook

TSCreateChannel Webhook

Credits

Robert Mawrey

Comments

Embed the widget on your own site

Solar Powered Cellular Weather Station

Solar Powered Cellular Weather Station

Things used in this project

Hardware components

Software apps and online services

Story

Step 1 - Plug the Weather and Level Adapter and Boron into the IoT Node

Step 2 - Mount the temperature and humidity sensor in the solar radiation shield

Step 3 - Plug the sensors into the IoT Node

Step 4 - Create ThingSpeak and Particle accounts and register your device

Step 5 - Add Webhooks to your Particle account

Step 6: Program your Particle device and test

Step 7: Install your weather station and analyze the data

Schematics

Weather and Level Adapter Hardware Files

IoT Node Hardware Files

Code

Weather Station Code

TSBulkWriteCSV Webhook

TSWriteOneSetting Webhook

TSCreateChannel Webhook

Credits

Robert Mawrey

Comments

Related channels and tags