Domoticz

havnegata wrote: ↑Friday 24 July 2020 14:20 US shipping is not a problem. You can use services as Jetcarrier and circumvent shipping challenges:-) Problem is to get it working with Domoticz...

Installation

This requires installing the paho mqtt and influxdb python libraries.
On a debian(ish) system that can be done by:

# for python3

Code: Select all

sudo apt-get install -y python3-pip && sudo pip3 install paho-mqtt influxdb

# for python2

Code: Select all

sudo apt-get install -y python-pip  && sudo pip  install paho-mqtt influxdb

b'<?xml version="1.0" encoding="UTF-8" ?><root><Time_Epoch>1618391739</Time_Epoch><Wind_Lull>0.0</Wind_Lull><Wind_Avg>0.0</Wind_Avg><Wind_Gust>0.0</Wind_Gust><Wind_Direction>0</Wind_Direction><Wind_Sample_Interval>3</Wind_Sample_Interval><Station_Pressure>1032.16</Station_Pressure><Air_Temperature>6.59</Air_Temperature><Relative_Humidity>64.78</Relative_Humidity><Illuminance>72422</Illuminance><UV>4.39</UV><Solar_Radiation>604</Solar_Radiation><Precip_Accumulated>0.0</Precip_Accumulated><Precipitation_Type>0</Precipitation_Type><Lightning_Strike_Distance>0</Lightning_Strike_Distance><Lightning_Strike_Count>0</Lightning_Strike_Count><Battery>2.714</Battery><Report_Interval>1</Report_Interval></root>'

Spoiler: show

Traceback (most recent call last):
obj_test1 = json.loads(content_test1)
File "/usr/lib/python2.7/json/__init__.py", line 339, in loads
return _default_decoder.decode(s)
File "/usr/lib/python2.7/json/decoder.py", line 364, in decode
obj, end = self.raw_decode(s, idx=_w(s, 0).end())
File "/usr/lib/python2.7/json/decoder.py", line 382, in raw_decode
raise ValueError("No JSON object could be decoded")
ValueError: No JSON object could be decoded

Spoiler: show

#!/usr/bin/python
# -*- coding = utf-8 to enable reading by simple editors -*-
# (c)2021 script compiled by Toulon7559 from various material from forums, version 01_210516
# --------------------------------------------------
# Line005 = PREPARATION & SETTING
# --------------------------------------------------
# Imports for script-operation
import json
import urllib # with this import the script will run under python2.x, NOT under python3.x!!!

# --------------------------------------------------
# Line012 = EXTRACT CONTENTs BY JSON-CALLs
# --------------------------------------------------
# Python-script weatherflow_listener.py generates file Tempest_Sensor.json
# which is local source file for general meteo-info out of UDPTempest
page = urllib.urlopen('/home/pi/Tempest_Sensor.json') # reading from local folder
# page = urllib.urlopen('http://127.0.0.1:8080/home/pi/Tempest_Sensor.json')
# page = urllib.urlopen('http://192.168.1.7:8080/home/pi/Tempest_Sensor.json')
content_test = page.read()
obj_test1 = json.loads(content_test)
# Tempest_RWind.json is source file for Rapid Wind info [= high rate info]
page = urllib.urlopen('/home/pi/Tempest_RWind.json') # reading from local folder
content_test = page.read()
obj_test2 = json.loads(content_test)
# Tempest_SORain.json is source file for Start-Of-Rain Event info
page = urllib.urlopen('/home/pi/Tempest_SORain.json')
content_test = page.read()
obj_test3 = json.loads(content_test)
# Tempest_SInfo.json is source file for Lightning_Strike Event info
# page = urllib.urlopen('/home/pi/Tempest_SInfo.json')
# content_test = page.read()
# obj_test4 = json.loads(content_test)

# --------------------------------------------------
# Line035 = SURVEY for compilation for virtual devices
# --------------------------------------------------
# Extraction is aimed at subsequent recompilation for JSON-calls for update of virtual devices in Domoticz.
# As reference for inventory the general layouts of applicable json-strings acc. to API/JSON Domoticz:
# THB = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=TEMP;HUM;HUM_STAT;BAR;BAR_FOR -- Type THB
# with HUM_STAT = Humidity status: 0 = Normal, 1 = Comfortable, 2 = Dry, 3 = Wet
# with BAR_FOR = Barometer forecast: 0 = No info, 1 = Sunny, 2 = Partly cloudy, 3 = Cloudy, 4 = Rain
# Wind = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=WB;WD;10WS;10WG;WTemp;WChill -- Type Wind, WD is text as subset from catalogue NWES
# Rain = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=100RAINRATE_Hour;RAINCOUNTER -- Type Rain
# RainType = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE -- Type Custom Sensor with 1 numeric value, or inserted in Rain as rainrate
# Light = /json.htm?type=command&param=udevice&idx=IDX&svalue=VALUE -- Type Lux
# UVI = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=UV;TEMP -- Type UVI, Temp must be 0 for compatibility
# SolarRad = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE -- Type Solar Radiation
# LightningD = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE -- Type Custom Sensor with 1 numeric value [Distance]
# LightningC = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE -- Type Custom Sensor with 1 numeric value [Count]
# SOR_Event = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE -- Type Custom Sensor with 1 value [Time of event]
# LS_Event = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE;VALUE1;VALUE2 -- Type Custom Sensor with 3 values [Time of event, Distance, Energy]

# --------------------------------------------------
# Line054 = EXTRACTION of DATA & scaling of values
# --------------------------------------------------
print(obj_test1) # Contents of original UDP-package Observations
print
epoch = obj_test1['Time Epoch']
print('epoch = ',epoch)
was = obj_test1['Wind Avg']
print('was = ',was)
ws10 = was * 10 # scaling for virtual device
wgs = obj_test1['Wind Gust']
print('wgs = ',wgs)
wg10 = wgs * 10 # scaling for virtual device
wb = obj_test1['Wind Direction']
print('wb = ',wb)
# Line068 = Translation of wb into wd
# wd is result of translation of numeric value to wind_direction_text
wd = "NW" # placeholder for testing
if wb >= 11.25 and wb < 33.75:
wd = "NNO";
elif wb >= 33.75 and wb < 56.25:
wd = "NO";
elif wb >= 56.25 and wb < 78.75:
wd = "ONO";
elif wb >= 78.75 and wb < 101.25:
wd = "O";
elif wb >= 101.25 and wb < 123.75:
wd = "OZO";
elif wb >= 123.75 and wb < 146.25:
wd = "ZO";
elif wb >= 146.25 and wb < 168.75:
wd = "ZZO";
elif wb >= 168.75 and wb < 191.25:
wd = "Z";
elif wb >= 191.25 and wb < 213.75:
wd = "ZZW";
elif wb >= 213.75 and wb < 236.25:
wd = "ZW";
elif wb >= 236.25 and wb < 258.75:
wd = "WZW";
elif wb >= 258.75 and wb < 281.25:
wd = "W";
elif wb >= 281.25 and wb < 303.75:
wd = "WNW";
elif wb >= 303.75 and wb < 326.25:
wd = "NW";
elif wb >= 326.25 and wb < 348.75:
wd = "NNW";
else:
wd = "N";

print('wd = ',wd)
# Line105 = Air pressure
spa = obj_test1['Station Pressure'] # spa = "Station Pressure Absolute"
# correction required for calibration & translation to MSL-value
relpress = 1
biaspress = 0
spa = spa * relpress + biaspress # Correction for calibration
print('spa = ',spa)
station_altitude = 17 # pressure_sensor is at +17 m relative to MSL => MSL-pressure is higher than station pressure
bar = spa + (station_altitude/8.5) # correction of Station_Pressure into MSL_pressure
print('bar = ',bar)
bar_for = 0 # default to 'Stable'
print('bar_for = ',bar_for)
# Line = Temperatures
temp = obj_test1['Air Temperature'] # to be corrected for calibration
reltemp = 1
biastemp = 0
temp = temp * reltemp + biastemp # correction of air temperature for calibration
print('temp = ',temp)
wtemp = 22 # default for testing, alternative: windtemp = airtemp?
wchill = 24 # default for testing, calculation to be added. For high temperatures fill-in by heat-index?
# Line125 = Humidity
rhum = obj_test1['Relative Humidity'] # to be corrected for calibration
relhum = 1
biashum = 0
rhum = rhum * relhum + biashum # Correction of humidity for calibration
print('rhum = ',rhum)
hum_stat = 0 # default to 'No Info'
print('hum_stat = ',hum_stat)
# Line133 = Rain
raintoday = obj_test1['Precip Accumulated']
print('raintoday = ',raintoday)
rtype = obj_test1['Precipitation Type']
print('rtype = ',rtype)
rtype100 = rtype * 100 # scaling taking place of rainrate in virtual rain-device
# Line139 = Light & UV
light = obj_test1['Illuminance']
print('light = ',light)
solrad = obj_test1['Solar Radiation']
print('solrad = ',solrad)
uvi = obj_test1['UV']
print('uvi = ',uvi)
uvt = 0 # Temp must be 0, unless UV-sensor is type TFA3
# Line147 = LightningStrikes
ls_distance = obj_test1['Lightning Strike Distance']
print('lsdistance = ',ls_distance)
ls_count = obj_test1['Lightning Strike Count']
print('lscount = ',ls_count)
print('End of Observations')

# Line154 = RapidWind
print(obj_test2) # Contents of original UDP-message RapidWind
print('Reservation for Rapid Wind')
RWTime = obj_test2['Time Epoch']; print(RWTime)
RWDirection = obj_test2['Wind Direction']; print(RWDirection)
RWSpeed = obj_test2['Wind Speed']; print(RWSpeed)
print('End of RapidWind')

# Line162 = StartOfRainEvent
print(obj_test3) # Contents of original UDP-message Start-Of-Rain-Event
print('Reservation for SOR_Event')
SORTime = obj_test3; print(SORTime)
print('End of SOR_Event')

#Line168 = LightningStrikeEvent
# print(obj_test4) # Contents of original UDP-message Lightning-Strike-Event
print('Reservation for LS_Event')
# LSTime = obj_test4['Time Epoch']; print(LSTime)
# LSDistance = obj_test4['Distance']; print(LSDistance)
# LSEnergy = obj_test4['Energy']; print(LSEnergy)
print('End of LS_Event')

# -------------------------------------------------
# Line177 = SETTINGS FOR UPLOAD at Domoticz3
# -------------------------------------------------
# Define the ip, port, base-url, idx & type of your virtual sensors
domoticz3_host = '127.0.0.1' # local host
domoticz3_port = '8080'
domoticz3_url = 'json.htm'
domoticz3_idx1 = '27' #idx of new device THB
domoticz3_idx2 = '28' #idx of new device Wind
domoticz3_idx3 = '29' #idx of new device Rain
domoticz3_idx4 = '30' #idx of new device Lux
domoticz3_idx5 = '31' #idx of new device UVI
domoticz3_idx6 = '32' #idx of new device SolarRad
domoticz3_idx7 = '33' #idx of new device Custom for LightningD
domoticz3_idx8 = '34' #idx of new device Custom for LightningC
# domoticz3_idx9 = Raintype #idx of new device Text for Rain_type
# domoticz3_idx10 = SORain #idx of new device Text for Start-Of_Rain event
# domoticz3_idx11 = LSInfo #idx of new device Text for Lightning_Strike event

# -------------------------------------------------
# Line196 = URLs for ACTUAL UPLOAD to Domoticz3
# -------------------------------------------------
#
# THB = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=TEMP;HUM;HUM_STAT;BAR;BAR_FOR -- Type THB
url = ("http://" + domoticz3_host + ":" + domoticz3_port + "/" + domoticz3_url+ "?type=command&param=udevice&idx=" + domoticz3_idx1 + "&svalue=" + str(temp) + ";" + str(rhum) + ";" + str(hum_stat) + ";" + str(bar) + ";" + str(bar_for))
urllib.urlopen(url)
# Line 202
# Wind = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=WB;WD;10WS;10WG;WTemp;WChill -- Type Wind
url = ("http://" + domoticz3_host + ":" + domoticz3_port + "/" + domoticz3_url+ "?type=command&param=udevice&idx=" + domoticz3_idx2 + "&nvalue=0&svalue=" + str(wb) + ";" + str(wd) + ";" + str(ws10) + ";" + str(wg10) + ";" + str(wtemp) + ";" + str(wchill))
urllib.urlopen(url)
# Line 206
# Rain = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=100RAINRATE_Hour;RAINCOUNTER -- Type Rain
url = ("http://" + domoticz3_host + ":" + domoticz3_port + "/" + domoticz3_url+ "?type=command&param=udevice&idx=" + domoticz3_idx3 + "&nvalue=0&svalue=" + str(rtype100) + ";" + str(raintoday))
urllib.urlopen(url)
# Line 210
# Light = /json.htm?type=command&param=udevice&idx=IDX&svalue=VALUE -- Type Lux
url = ("http://" + domoticz3_host + ":" + domoticz3_port + "/" + domoticz3_url+ "?type=command&param=udevice&idx=" + domoticz3_idx4 + "&svalue=" + str(light))
urllib.urlopen(url)
# Line 214
# UVI = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=UV;TEMP -- Type UVI, Temp must be 0
url = ("http://" + domoticz3_host + ":" + domoticz3_port + "/" + domoticz3_url+ "?type=command&param=udevice&idx=" + domoticz3_idx5 + "&nvalue=0&svalue=" + str(uvi) + ";" + str(uvt))
urllib.urlopen(url)
# Line 218
# SolarRad = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE -- Type Solar Radiation
url = ("http://" + domoticz3_host + ":" + domoticz3_port + "/" + domoticz3_url+ "?type=command&param=udevice&idx=" + domoticz3_idx6 + "&nvalue=0&svalue=" + str(solrad))
urllib.urlopen(url)
# Line 222
# LightningD = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE -- Type Custom Sensor with 1 numeric value [Distance]
url = ("http://" + domoticz3_host + ":" + domoticz3_port + "/" + domoticz3_url+ "?type=command&param=udevice&idx=" + domoticz3_idx7 + "&svalue=" + str(ls_distance))
urllib.urlopen(url)
# Line 226
# LightningC = /json.htm?type=command&param=udevice&idx=IDX&nvalue=0&svalue=VALUE -- Type Custom Sensor with 1 numeric value [Count]
url = ("http://" + domoticz3_host + ":" + domoticz3_port + "/" + domoticz3_url+ "?type=command&param=udevice&idx=" + domoticz3_idx8 + "&nvalue=0&svalue=" + str(ls_count))
urllib.urlopen(url)

# -------------------------------------------------
# Line232 = End of script
# -------------------------------------------------
print ('End of script')

Spoiler: show

for temp in range(-35,15,5):
# print 'temperature is %d' % temp
for wind in range(0,85,5):
wchill = 13.12 + (.6215 * temp) - (11.37 * wind ** 770.16) + (.3965 * temp * wind **0.16)
# print 'wind is %d calculated wind chill is: %d' % (wind, wchill)

Spoiler: show

import math
# wind = float(input("Enter wind speed in kilometers/hour: ")) but Domoticz handles speed as m/s => scaling required 1m/s = 3.6 kmh
was_wc = 3.6 * was
# temperature = float(input("Enter air temperature in degrees Celsius: "))
wchill = 13.12 + 0.6215*temp - 11.37*math.pow(was_wc , 0.16) + 0.3965*temp*math.pow(was_wc , 0.16)
print('wchill = ',wchill)

Toulon7559 wrote: ↑Thursday 08 April 2021 17:44 An effectively working frontend is the start for reading of the UDP-messages.
_______________________________________

Many thanks for posting, very helpful!

I was wondering if the Tempest API supports a more rapid polling of the wind sensor data?
And if anyone has a working python implementation of this?

From what I've been able to gather, the Tempest internally pre-averages the wind samples and provides the average (of however many internal samples it is), to the UDP stream roughly every 3 seconds. Assuming this is correct, a high wind gust could easily be averaged to something much lower, and effectively missed.

For anyone who knows the inner workings of the Tempest API, is there a way to directly poll -just the wind speed value- on-demand at a rate of at least once per second ? (2 or 3 per second preferred)

Thanks in advance