Project
Background
Step 1: Setting up Weather Service (wunderground) -&gt
Step 2: Setting up Raspberry Pi -&gt
Wunderground API test
Step 3: ARTIK cloud setup process -&gt
Demonstration of Project

Published September 28, 2016 © GPL3+

RPi WeatherTwitter

Let your Raspberry Pi 'tweet' about "weather of city".

IntermediateFull instructions provided5 hours917

Things used in this project

Hardware components

Raspberry Pi 1 Model B

could be use any Pi model

SD card

RGB Diffused Common Anode

optional( used here to indicate visual status)

Resistor 330 ohm

required only if using RGB led

Solderless Breadboard Half Size

if you want to avoid soldering RGB led with resistor on general purpose pcb

Male/Female Jumper Wires

Software apps and online services

Samsung ARTIK Cloud for IoT

Weather Underground api

Twitter

Hand tools and fabrication machines

Soldering iron (generic)

only if connecting RGB led on general purpose pcb

Story

Project

This is about connecting Raspberry Pi to twitter using ARTIK cloud service. Here raspberry forecast weather like weatherman and weatherwoman using wunderground API and send data to ARTIK Cloud. Various rules are defined on ARTIK Cloud to make alert Tweets regarding weather of your city for friends, family and other connected peoples arriving there.

Working flow diagram

Background

Now let’s go through story behind making this project. In most of countries we know there are three major season’s summer, rain and winter. Due to unawareness of weather situation in other cities where we go, then we face certain difficulty or some time condition may worsen. Such as chance of Heatstroke in extreme summer, rainfall, extreme storm, etc.

Unaware of Weather condition

With this prototype project such situation can be predicted in advance to take necessary action. We can also share to our friends and family members on social media like Twitter using IoT technology. It enhances chance of awareness as many of us forget to watch weather news report but are active on social media.

Received Alert

Here Project development is divided into 3 major steps:

Setting up Weather Service (wunderground)

Setting up Raspberry Pi

ARTIK cloud setup process

Let's begin...

Step 1: Setting up Weather Service (wunderground) ->

Steps are simple to get API, just Sign up to wunderground website (https://www.wunderground.com)

Click on more -> weather API for Developers -> explore my option-> select startus plan(for developer free) and click purchase->Fill details and click purchase -> That’s It (key onscreen)

wunderground API key setup

You can check response by typing (of your city) http://api.wunderground.com/api/YourAPIKeyId/conditions/q/USA/newyork.json

http://api.wunderground.com/api/YourAPIKeyId/forecast/q/India/Mumbai.json

In your browser window, this shows you response in JSON file.

Here are some examples how to extract data from JSON file I have used in code:

var json_data = JSON.stringify(result); 
var jsondata = JSON.parse(json_data); 
Temp = jsondata.current_observation.temp_c; 
var relHumidity = jsondata.current_observation.relative_humidity; 
var tomRelHumidity = jsondata.forecast.simpleforecast.forecastday[0].avehumidity; 
var tomforcast = jsondata.forecast.txt_forecast.forecastday[0].fcttext;

Step 2: Setting up Raspberry Pi ->

If you already have raspberry pi with OS install then you can directly move for nodejs installation visit on below website to install OS

https://www.howtoforge.com/tutorial/howto-install-raspbian-on-raspberry-pi/

Below are steps to Install node.js version to your raspberry pi ->

We need to select proper node file corresponding to ARM processor available on Pi. To know regarding your pi model visit -> http://www.makershed.com/pages/raspberry-pi-comparison-chart

OR simply

uname -a

for Raspberry Pi model B rev2

for Raspberry Pi 3

Now download Node.js source for Raspberry Pi Model A, B, B+ and Compute Module as

wget https://nodejs.org/dist/v4.0.0/node-v4.0.0-linux-armv6l.tar.gz 
tar -xvf node-v4.0.0-linux-armv6l.tar.gz 
cd node-v4.0.0-linux-armv6l

For Raspberry Pi 2 and Pi 3

wget https://nodejs.org/dist/v4.0.0/node-v4.0.0-linux-armv7l.tar.gz 
tar -xvf node-v4.0.0-linux-armv7l.tar.gz 
cd node-v4.0.0-linux-armv7l

Copy to /usr/local

sudo cp -R * /usr/local/

I have tested setup on raspberry Pi 3 and Pi model B(REV 2), its working fine. After you’re done then verify installation by typing following two commands:

nodejs version check

Make separate folder and copy code wundergroundAPITest.js files provided in code section into your folder OR Simply you can git clone as:

git clone https://github.com/BJSingh/WeatherBotTweet-Messenger-Project.git 
cd WeatherBotTweet-Messenger-Project

After this you need to install following node module packages (onoff package only needed if using RGB led)

npm install ws wunderground-api-client onoff

Once your done till here, now you can go for first testing of project

Wunderground API test:

Add you API key properly in wundergroundAPITest.js code file and run it as

node wundergroundAPITest.js

you can verify response received:

Step 3: ARTIK cloud setup process ->

Setup include first creating DeviceType on ARTIK developer portal, next connecting devices and finally adding rules on ARTIK cloud portal shown below

Steps of DeviceType Creation on ARTIK Developer

Steps to connect Devices on ARTIK Cloud

Steps to ADD Rules on ARTIK Cloud

you can get PDF version of above process:

DeviceType Creation on ARTIK Developer.pdf

Connecting_Devices_on_ARTIKcloud.pdf

Adding_Rules_ARTIKCloud.pdf

Now we are ready to WeatherBotTweet Messenger in action.

To run you need to have copy of testCode.js in same folder created earlier.

Make sure you have added your DeviceId and Token key in code file, I have commented where to add. Then just type below command into Raspberry Pi

node testCode.js

Demonstration of Project:

Your WeatherBot is ready with minimal Hardware, now you can make changes to testCode and add some more functionality to it as shown in final code file weatherTweetCode.js in code section.

Below I have shown how to add or upload multiple data on ARTIKCloud for processing.

ARTIKCloud Setup:

ARTIKCloud Setup For Multiple value upload

Working :

Working Of WeatherBotTweet Messenger

Just for demo I have use condition for HIGH temperature and Rainfall, you can defined rule according to your city's weather condition.

Comment if having any queries and Thank You.

Code

var WunderApi = require("wunderground-api-client").WunderApi;
var combined = new WunderApi('64----yourkey---fe', null, 'conditions', 'forecast');//replace with your wounderground API key

	
combined.query('India/Bhiwandi') //replace with you country/city
  .then(function (result) {
	  //uncomment console log to view complete result in console window if you want
	  //console.log(result);
	  
	  //JSON.stringify turns a Javascript object into JSON text and stores that JSON text in a string.
	  //JSON.parse turns a string of JSON text into a Javascript object.
	  var json_data = JSON.stringify(result);
	  var jsondata = JSON.parse(json_data);
	  
	  //uncomment below line to view full data received from wunderground which is converted into Javascript object
	  //console.log(jsondata);
	  var Temp = jsondata.current_observation.temp_c;
	  var relHumidity = jsondata.current_observation.relative_humidity;
	  console.log("Today Temp: "+Temp);
	  console.log("Today relativeHumidity: "+relHumidity);
	  
	  
	  var dayTemp = jsondata.forecast.simpleforecast.forecastday[0].high.celsius;
	  var nightTemp = jsondata.forecast.simpleforecast.forecastday[0].low.celsius;
	  var tomRelHumidity = jsondata.forecast.simpleforecast.forecastday[0].avehumidity;
	  var tomforcast = jsondata.forecast.txt_forecast.forecastday[0].fcttext;
	  console.log("Tom DayT: "+dayTemp);
	  console.log("Tom NightT: "+nightTemp);
	  console.log("Tom relHumidity: "+tomRelHumidity);
	  console.log("Tom weather: "+tomforcast);
	  
	  
	  
	  })
  .fail(function (err) {console.dir(err)})
  .done();

//weather and its forcast tweet using Artik cloud and Raspberry Pi

//related to artik cloud
var webSocketUrl = "wss://api.artik.cloud/v1.1/websocket?ack=true";
var device_id_temp = "e831---------youid--------276d"; //replace with your corresponding device id ; id for current temperature
var device_token_temp = "5d-----------------b39c4a";   // current temperature token
var device_id_wd = "34e------------------------cdh9f";		//id for rainPredictData
var device_token_wd = "3e2a---------------------b1391";	//token for rainPredictData

var isWebSocketReady = false;
var ws = null;

var WebSocket = require('ws');

//Led indicator setup remove below comment if you want to use RGB led /*** ----to--- ***/
/***
var GPIO = require('onoff').Gpio,
    red = new GPIO(17,'out'),
    green = new GPIO(27,'out'),
    blue = new GPIO(22,'out');

//here I have used common anode RGB led, so to on corresponding led make it 0
red.writeSync(1);
green.writeSync(0);
blue.writeSync(0);
***/

//related to weather api
var WunderApi = require("wunderground-api-client").WunderApi;
var combined = new WunderApi('6s4------yourid--------48fe', null, 'conditions', 'forecast'); //replace with your wounderground API key
var Temp = 0;
var predict = false;

//to predict chance of rain happening
function rainPredictFunction(relHum) {
	if (relHum > 85) {
		predict = true;
	}
	else predict = false;
}

/**
 * Gets the current time in millis
 */
function getTimeMillis(){
    return parseInt(Date.now().toString());
}

/**
 * Create a /websocket device channel connection
 */
function start() {
    //Create the websocket connection
    isWebSocketReady = false;
    ws = new WebSocket(webSocketUrl);
    ws.on('open', function() {
        console.log("Websocket connection is open ....");
        register();
    });
    ws.on('message', function(data, flags) {
        console.log("Received message: " + data + '\n');
    });
    ws.on('close', function() {
        console.log("Websocket connection is closed ....");
    });
}

/**
 * Sends a register message to the websocket and starts the message flooder
 */
function register(){
    console.log("Registering device on the websocket connection");
    try{
        var registerMessage = '{"type":"register", "sdid":"'+device_id_temp+'", "Authorization":"bearer '+device_token_temp+'", "cid":"'+getTimeMillis()+'"}';
        //uncomment below line if you want to view regisration of your device to artik cloud 
	    //console.log('Sending register message ' + registerMessage + '\n');
        ws.send(registerMessage, {mask: true});

		registerMessage = '{"type":"register", "sdid":"'+device_id_wd+'", "Authorization":"bearer '+device_token_wd+'", "cid":"'+getTimeMillis()+'"}';
        //console.log('Sending register message ' + registerMessage + '\n');
        ws.send(registerMessage, {mask: true});

		isWebSocketReady = true;
    }
    catch (e) {
        console.error('Failed to register messages. Error in registering message: ' + e.toString());
    }
}

/**
 * Send one message to ARTIK Cloud
 */
function sendData(){
    try{

		var uploadVal = {
			 currenttempData : {
				"currentTempVal": Temp
			},
			 rainPredictData : {
				"rainPredictStatus": predict
			}
		}

        ts = ', "ts": '+getTimeMillis();
        var payload = '{"sdid":"'+device_id_temp+'"'+ts+', "data": '+JSON.stringify(uploadVal.currenttempData)+', "cid":"'+getTimeMillis()+'"}';
        //uncomment below line to view payload of your data
	    //console.log('Sending payload ' + payload);
        ws.send(payload, {mask: true});

		ts = ', "ts": '+getTimeMillis();
		var payload = '{"sdid":"'+device_id_wd+'"'+ts+', "data": '+JSON.stringify(uploadVal.rainPredictData)+', "cid":"'+getTimeMillis()+'"}';
        //console.log('Sending payload ' + payload);
        ws.send(payload, {mask: true});

    } catch (e) {
        console.error('Error in sending a message: ' + e.toString());
    }
}

/**
 * All start here
 */
start(); // create websocket connection

setInterval(function(){


	combined.query('India/Bhiwandi')
	  .then(function (result) {
		  //console.log(result);
		  var json_data = JSON.stringify(result);
		  var jsondata = JSON.parse(json_data);
		  Temp = jsondata.current_observation.temp_c;
		  var relHumidity = jsondata.current_observation.relative_humidity;
		  console.log("Today Temp: "+Temp);
		  console.log("Today relativeHumidity: "+relHumidity);


		  var dayTemp = jsondata.forecast.simpleforecast.forecastday[0].high.celsius;
		  var nightTemp = jsondata.forecast.simpleforecast.forecastday[0].low.celsius;
		  var tomRelHumidity = jsondata.forecast.simpleforecast.forecastday[0].avehumidity;
		  var tomforcast = jsondata.forecast.txt_forecast.forecastday[0].fcttext;
      
		  console.log("Tom DayT: "+dayTemp);
		  console.log("Tom NightT: "+nightTemp);
		  console.log("Tom relHumidity: "+tomRelHumidity);
		  console.log("Tom weather: "+tomforcast);
		  rainPredictFunction(tomRelHumidity);
		  console.log(predict);
		  
		  //remove below comment if you are using RGB led /*** ----to--- ***/
		  /***
		  if(predict){
	            //blue led on to indicate chane of rain
		    red.writeSync(1);
		    green.writeSync(1);
                    blue.writeSync(0);     
		  }
		  ***/
		  //console.log(jsondata);

		  })
	  .fail(function (err) {console.dir(err)})
	  .done();


	if (!isWebSocketReady){
		console.log("Websocket is not ready. Skip sending data to ARTIK Cloud (temp:" + Temp +")"+"(predict:"+predict+")");
		return;
	}

	sendData();

},5000);

//weather and its forcast tweet using Artik cloud and Raspberry Pi

//Led indicator setup remove below comment if you want to use RGB led /*** ----to--- ***/

var GPIO = require('onoff').Gpio,
    redLed = new GPIO(17,'out'),
    greenLed = new GPIO(27,'out'),
    blueLed = new GPIO(22,'out');

//here I have used common anode RGB led, so to on corresponding led make it 0
//comment below 3 lines if you are not using RGB led
redLed.writeSync(0);		// on
greenLed.writeSync(1);		// off
blueLed.writeSync(1);		// off

//related to artik cloud
var webSocketUrl = "wss://api.artik.cloud/v1.1/websocket?ack=true";
var device_id_todayData = "09dfddaa61034fec8513c1e188d47ce9"; //replace with your corresponding device id ; id for all current weather data
var device_token_todayData = "31bc52f35adf4ee98e084e82bf488e19";   // token
var device_id_tomData = "e84fec6b5e1e42a8a51b7e5e877b83c2";		//id for predicted tomorrow's weather data
var device_token_tomData = "1e3b94d54e24425291dca7167e03e05c";	//token

var isWebSocketReady = false;
var ws = null;

var WebSocket = require('ws');


//related to weather api
var WunderApi = require("wunderground-api-client").WunderApi;
var combined = new WunderApi('64-------acb--4fe', null, 'conditions', 'forecast'); //replace with your wounderground API key
var predict = false;
var todayRelHum;		
var todayTemp, todayWindFlow;
var tomTemp, tomRelHum, tomWindFlow;

//to predict chance of rain happening
function rainPredictFunction(relHum) {
	if (relHum == 100) {
		predict = true;
	}
	else predict = false;
}

/**
 * Gets the current time in millis
 */
function getTimeMillis(){
    return parseInt(Date.now().toString());
}

/**
 * Create a /websocket device channel connection
 */
function start() {
    //comment below 3 lines if you are not using RGB led
	redLed.writeSync(0);
	greenLed.writeSync(0);
	blueLed.writeSync(1);

	//Create the websocket connection
    isWebSocketReady = false;
    ws = new WebSocket(webSocketUrl);
    ws.on('open', function() {
        console.log("Websocket connection is open ....");
        register();
    });
    ws.on('message', function(data, flags) {
        console.log("Received message: " + data + '\n');
    });
    ws.on('close', function() {
        console.log("Websocket connection is closed ....");
    });
}

/**
 * Sends a register message to the websocket and starts the message flooder
 */
function register(){
	//comment below 3 lines if you are not using RGB led
	redLed.writeSync(1);
	greenLed.writeSync(0);
	blueLed.writeSync(0);

    console.log("Registering device on the websocket connection");
    try{
        var registerMessage = '{"type":"register", "sdid":"'+device_id_todayData+'", "Authorization":"bearer '+device_token_todayData+'", "cid":"'+getTimeMillis()+'"}';
        //uncomment below line if you want to view regisration of your device to artik cloud
	    //console.log('Sending register message ' + registerMessage + '\n');
        ws.send(registerMessage, {mask: true});

		registerMessage = '{"type":"register", "sdid":"'+device_id_tomData+'", "Authorization":"bearer '+device_token_tomData+'", "cid":"'+getTimeMillis()+'"}';
        //console.log('Sending register message ' + registerMessage + '\n');
        ws.send(registerMessage, {mask: true});

		isWebSocketReady = true;
    }
    catch (e) {
        console.error('Failed to register messages. Error in registering message: ' + e.toString());
    }
}

/**
 * Send one message to ARTIK Cloud
 */
function sendData(){
	//comment below 3 lines if you are not using RGB led
	redLed.writeSync(0);
	greenLed.writeSync(1);
	blueLed.writeSync(0);

    try{

		var uploadVal = {
			 todayWData : {
				 "todayRelHumVal":todayRelHum,			//Weather API returns this as 78%, which is string
				 "todayTempVal":todayTemp,				//while others only number , double e.g. 33.4
				 "todayWindFlowVal":todayWindFlow		// Integer number e.g. 13
				 },
			 tomorrowWData : {
				"tomRelHumVal":tomRelHum,				//But for this it is Integer number
				"tomTempVal":tomTemp,
				"tomWindFlowVal":tomWindFlow
			}
		}

        ts = ', "ts": '+getTimeMillis();
		console.log("Uploading Value to Cloud");

        var payload = '{"sdid":"'+device_id_todayData+'"'+ts+', "data": '+JSON.stringify(uploadVal.todayWData)+', "cid":"'+getTimeMillis()+'"}';
        //uncomment below line to view payload of your data
	    console.log('Sending payload ' + payload);
        ws.send(payload, {mask: true});

		var payload = '{"sdid":"'+device_id_tomData+'"'+ts+', "data": '+JSON.stringify(uploadVal.tomorrowWData)+', "cid":"'+getTimeMillis()+'"}';
        console.log('Sending payload ' + payload);
        ws.send(payload, {mask: true});

    } catch (e) {
        console.error('Error in sending a message: ' + e.toString());
    }

}

/**
 * All start here
 */
start(); // create websocket connection

//Function repeats its execution after set interval of time
setInterval(function(){

	combined.query('India/Mumbai')
	  .then(function (result) {
			  //console.log(result);


			  var json_data = JSON.stringify(result);
			  var jsondata = JSON.parse(json_data);

			  //today's current weather data
			  todayTemp = jsondata.current_observation.temp_c;
			  todayRelHum = jsondata.current_observation.relative_humidity;
			  todayWindFlow = jsondata.current_observation.wind_mph;

			  //tomorrow's predicted  weather data
			  tomTemp = jsondata.forecast.simpleforecast.forecastday[0].high.celsius;
			  tomRelHum = jsondata.forecast.simpleforecast.forecastday[0].avehumidity;
			  tomWindFlow = jsondata.forecast.simpleforecast.forecastday[0].avewind.mph;
			  var tomforcast = jsondata.forecast.txt_forecast.forecastday[0].fcttext;

			  console.log("\n\n****************  Weather Forcast by WeatherBotTweet messenger  ****************");

			  console.log("\n\tObservation Time: "+jsondata.current_observation.observation_time);
			  console.log("\n\t|-------------- Today's Weather Report --------------|\n");
			  console.log("\tTemperature      : "+todayTemp+"C");
			  console.log("\tRelativeHumidity : "+todayRelHum);
			  console.log("\tWindFlow         : "+todayWindFlow+"mph");
			  console.log("\n");

			  console.log("\n\t|------------- Tomorrow's Weather Report ------------|\n");
			  console.log("\tTemperature      : "+tomTemp+"C");
			  console.log("\tRelativeHumidity : "+tomRelHum+"%");
			  console.log("\tWindFlow         : "+tomWindFlow+"mph");

			  console.log("\n"+tomforcast);

			  rainPredictFunction(tomRelHum);
			  if(predict){
				//indicate chane of rain
				redLed.writeSync(1);
				greenLedLed.writeSync(1);
				blueLed.writeSync(0);
				console.log("\n\tMax possiblity of Rain Tomorrow");
			  }
			  console.log("\n********************************************************************************");


		  })
	  .fail(function (err) {console.dir(err)})
	  .done();


	if (!isWebSocketReady){
		console.log("Websocket is not ready. Skip sending data to ARTIK Cloud");
		return;
	}

	sendData(); //calling function to upload avialable data on cloud
	redLed.writeSync(0);
	greenLed.writeSync(0);
	blueLed.writeSync(0);

},10000);		//repeat after every 10 sec

Credits

Brijesh Singh

23 projects • 38 followers

Utilizing the spare time to Make and Share DIY Electronics and IoT projects with the online maker community.

RPi WeatherTwitter

Things used in this project

Hardware components

Software apps and online services

Hand tools and fabrication machines

Story

Project

Background

Step 1: Setting up Weather Service (wunderground) ->

Step 2: Setting up Raspberry Pi ->

Wunderground API test:

Step 3: ARTIK cloud setup process ->

Demonstration of Project:

Schematics

Connection Diagram of Raspberry pi and RGB led

Code

wundergroundAPITest.js

testCode.js

weatherTweetCode.js

WeatherBotTweet-Messenger-Project

Credits

Brijesh Singh

Comments

Embed the widget on your own site

RPi WeatherTwitter

RPi WeatherTwitter

Things used in this project

Hardware components

Software apps and online services

Hand tools and fabrication machines

Story

Project

Background

Step 1: Setting up Weather Service (wunderground) ->

Step 2: Setting up Raspberry Pi ->

Wunderground API test:

Step 3: ARTIK cloud setup process ->

Demonstration of Project:

Schematics

Connection Diagram of Raspberry pi and RGB led

Code

wundergroundAPITest.js

testCode.js

weatherTweetCode.js

WeatherBotTweet-Messenger-Project

Credits

Brijesh Singh

Comments

Related channels and tags