get_tag_data.py

'''
Print sensor data to the screen. Update interval 2 sec.

Press Ctrl+C to quit.

2017-02-02 13:45:25.233400
Sensor - F4:9D:33:83:30:29
Temperature: 10
Humidity:    28
Pressure:    689
'''

'''
get sensor data from ruuvitag and send data to ThingSpeak

'''

import sys
#from urllib.request import urlopen
import urllib.request
import json
import time
import os
from datetime import datetime

from ruuvitag_sensor.ruuvitag import RuuviTag

# Enter Your API key here
myAPI = 'GPBO64VFP5PRX1BP'
# URL where we will send the data, Don't change it
baseURL = 'https://api.thingspeak.com/update?api_key=%s' % myAPI

writeAPIkey = "GPBO64VFP5PRX1BP" # Replace YOUR-CHANNEL-WRITEAPIKEY with your channel write API key
channelID = "596819" # Replace YOUR-CHANNELID with your channel ID
#url = "https://api.thingspeak.com/channels/"+channelID+"/bulk_update.json" # ThingSpeak server settings
url = "https://api.thingspeak.com/update?api_key=%s" % writeAPIkey
messageBuffer = []
fields = ''

lastConnectionTime = time.time() # Track the last connection time
lastUpdateTime = time.time() # Track the last update time
postingInterval = 15 # Post data once every 2 minutes
updateInterval = 5 # Update once every 15 seconds

# Change here your own device's mac-address
mac = 'F4:9D:33:83:30:29'

print('Starting')

sensor = RuuviTag(mac)

def httpRequest():
    '''Function to send the POST request to
    ThingSpeak channel for bulk update.'''

    # global messageBuffer
    global url
    global fields
    # data = json.dumps({'write_api_key':writeAPIkey,'updates':messageBuffer}) # Format the json data buffer
    url_req = url + fields
    print(url_req)
    req = urllib.request.Request(url = url_req)

    # requestHeaders = {"User-Agent":"mw.doc.bulk-update (Raspberry Pi)","Content-Type":"application/json","Content-Length":str(len(data))}
    # for key,val in requestHeaders.items(): # Set the headers
    #	req.add_header(key,val)
    ## req.add_data(data) # Add the data to the request
    # req.data = data.encode("utf-8")
    # print(req.data)

    # Make the request to ThingSpeak
    try:
        response = urllib.request.urlopen(req) # Make the request
        print(response.getcode()) # A 202 indicates that the server has accepted the request
    except urllib.request.HTTPError as e:
    	print(e.code) # Print the error code
    # messageBuffer = [] # Reinitialize the message buffer

    global lastConnectionTime
    lastConnectionTime = time.time() # Update the connection time

#while True:
def ruuvitag_data():
    data = sensor.update()

    sensor_node = str.format('{0}', mac)
    temperature = str.format('{0}', data['temperature'])
    humidity = str.format('{0}', data['humidity'])
    pressure = str.format('{0}', data['pressure'])
    battery = str.format('{0}', data['battery'])
    return sensor_node, temperature, humidity, pressure, battery

def updatesJson():
    '''Function to update the message buffer
    every 15 seconds with data. And then call the httpRequest
    function every 2 minutes. This examples uses the relative timestamp as it uses the "delta_t" parameter.
    If your device has a real-time clock, you can also provide the absolute timestamp using the "created_at" parameter.
    '''

    global lastUpdateTime
    global fields
    fields = ''
    # message = {}
    # message['delta_t'] = int(round(time.time() - lastUpdateTime))
    sensor_node, temperature, humidity, pressure, battery = ruuvitag_data()
    fields = '&field1=%s' % temperature + '&field2=%s' % humidity + '&field3=%s' % battery

    # message['field1'] = temperature
    # message['field2'] = humidity
    # message['field3'] = battery
    # global messageBuffer
    #messageBuffer.append(message)

    # If posting interval time has crossed 2 minutes update the ThingSpeak channel with your data
    if time.time() - lastConnectionTime >= postingInterval:
    	httpRequest()
    lastUpdateTime = time.time()

while True:
    # Wait for 2 seconds and start over again
    try:
        #sensor_node, temperature, humidity, pressure, battery = ruuvitag_data()
        if time.time() - lastUpdateTime >= updateInterval:
	        updatesJson()

        sensor_node, temperature, humidity, pressure, battery = ruuvitag_data()
        # Clear screen and print sensor data
        # os.system('clear')
        print('Press Ctrl+C to quit.\n\r\n\r')
        print(str(datetime.now()))
        print('sensor node: ' + sensor_node)
        print('temperature: ' + temperature + ' C')
        print('humidity:    ' + humidity + ' %')
        print('pressure:    ' + pressure)
        print('battery:     ' + battery)
        print('\n\r\n\r.......')


        time.sleep(2)
    except KeyboardInterrupt:
        # When Ctrl+C is pressed execution of the while loop is stopped
        print('Exit')
        break