Domoticz

Code: Select all

IF devicechanged [NameOfSensor]
os.execute(curl http://thingspeak.com?value=1234)

Code: Select all

subtype       = P1 Smart Meter Power
powerusage1 = 1599.491 kWh
powerusage2 = 1367.110 kWh
powerdeliv1 = 0.000 kWh
powerdeliv2 = 0.000 kWh
current usage = 684 Watt
current deliv = 000 Watt
2016-02-09 20:36:31.086  (P1) P1 Smart Meter (P1 Electricity)

Code: Select all

# Load required libraries
import requests
import json
import time

from datetime import datetime

### STEP 1: connect to the EvoHome and get user credentials
# Set your EvoHome login details in the 2 fields below
USERNAME = 'my user name'
PASSWORD = 'my password'
#seconds_between_logpoints = 600
current_temp = [0,0,0,0]
current_setpoint = [0,0,0,0]

# Initial JSON POST to the website to return your userdata
url = 'https://rs.alarmnet.com/TotalConnectComfort/WebAPI/api/Session'
postdata = {'Username':USERNAME, 'Password':PASSWORD,'ApplicationId':'91db1612-73fd-4500-91b2-e63b069b185c'}
headers = {'content-type':'application/json'}
response = requests.post(url,data=json.dumps(postdata),headers =headers)
userinfo = json.loads((response.content).decode(encoding="utf-8"))

# DV Now, we have downloaded the userinfo from the first HTTP request.
# Note that in python3 we have to use decode as bytes are handled differently 
# within python3 compared to python2. After the decoding, all works
# 
# The object "userinfo" is a dictionary and contains as one item the 
# key "userInfo"-- which holds all our userinfo.
# To access this:
# myUserInformation = userinfo["userInfo"]
# myUserInfoDetails = myUserInformation["streetAddress"]
#
# to print all information, do 
print("\nThe userinfo that is returned: ", userinfo)
print("\nFinished the initial JSON request")

### STEP 2: Connect to the EvoHome website for a single time, to get initial data 
###         and to figure out how many devices there are present
# Extract the sessionId and your userid from the response
userid = userinfo['userInfo']['userID']
sessionId = userinfo['sessionId']
print("The userid and sessionId are:", userid, sessionId)

# Next, using your userid, get all the data back about your site
url = 'https://rs.alarmnet.com/TotalConnectComfort/WebAPI/api/locations?userId=%s&allData=True' % userid
headers['sessionId'] = sessionId
response = requests.get(url,data=json.dumps(postdata),headers =headers)
fullData = json.loads((response.content).decode(encoding="utf-8"))[0]

### STEP 3: Connect to the EvoHome website for every defined number of seconds
###         and send the data to Thingspeak
# We need to store the data for all our devices, and send them in one go to Thingspeak
# The data is stored as a list (I assume here that there are 4 devices)

# Next, using your userid, get all the EvoHome data back about your site
url = 'https://rs.alarmnet.com/TotalConnectComfort/WebAPI/api/locations?userId=%s&allData=True' % userid
headers['sessionId'] = sessionId
response = requests.get(url,data=json.dumps(postdata),headers =headers)
fullData = json.loads((response.content).decode(encoding="utf-8"))[0]

# Get current time and temperature information
device_nr = 0
for device in fullData['devices']:
	tijd = datetime.now().strftime('%Y-%m-%d %H:%M:%S.%f')
	temperatuur = device['thermostat']['indoorTemperature']
	setpoint = device['thermostat']['changeableValues']['heatSetpoint']['value']
	naam = device["name"]
	current_temp[device_nr] = temperatuur
	current_setpoint[device_nr] = setpoint
	print("Device='{0}'\tTemp={1}\tSetpoint={2}\tTime={3}".format(naam, temperatuur, setpoint, tijd))
	device_nr = device_nr + 1

### STEP 4: now sending to Thingspeak:
payload = {"field1":current_temp[0], "field2":current_setpoint[0], "field3":current_temp[1], "field4":current_setpoint[1],"field5":current_temp[2], "field6":current_setpoint[2], "field7":current_temp[3], "field8":current_setpoint[3]}
url_TS = "https://api.thingspeak.com/update?key=JZRZ6MFJNXY70VHQ"
requests.get(url_TS, params=payload)

Code: Select all

local aanvoer_dv = 'CV Boiler Water Temperature'

commandArray = {}

if devicechanged[aanvoer_dv] then
        aanvoer = otherdevices_svalues[aanvoer_dv]
		print('send to thingspeak' .. aanvoer)
		conn=net.createConnection(net.TCP, 0)
		conn:on("receive", function(conn, payload) print(payload) end)
		conn:connect(80,'184.106.153.149')
		conn:send("GET /update?key=<1Z2ZVxxxxxxxxVAY>&field1="..aanvoer.." HTTP/1.1\r\n")
		conn:send("Host: api.thingspeak.com\r\n")
		conn:send("Accept: */*\r\n")
		conn:send("User-Agent: Mozilla/4.0 (compatible; esp8266 Lua; Windows NT 5.1)\r\n")
		conn:send("\r\n")
		conn:on("sent",function(conn) print("Closing connection") conn:close() end)
		conn:on("disconnection", function(conn) print("Got disconnection...") end)
		conn = nil
end
return commandArray