Skip to content

Python3 #4

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
j64bit wants to merge 4 commits into
base: master
Choose a base branch
from
Open

Python3 #4

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
87b6d5f
Update README.md
j64bit Sep 4, 2021
3c65fd9
python3 upgrade
j64bit Sep 4, 2021
bff76f7
added comment on false windspeed change
j64bit Sep 4, 2021
c41adc6
update to python3 and added comment about UV
j64bit Sep 4, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,13 +3,13 @@ Ventus W820 bluetooth driver and weewx connector

The Ventus W820 is a bluetooth enabled weather station. This repository provides a library to read the values of the sensors and a driver for the [weewx](http://www.weewx.com/) weather station software

The library requires [bluepy](https://github.com/IanHarvey/bluepy) for the BLE communication
The library requires [bluepy](https://github.com/IanHarvey/bluepy) for the BLE communication. Pick the python3 version (i.e. pip3 ...).

Project website: [http://daduke.org/coding/ventus.html](http://daduke.org/coding/ventus.html)

How to use it:
* install [bluepy](https://github.com/IanHarvey/bluepy)
* `ventus.py` is the low level library that talks to the weather station, copy it to a standard python library path (e.g. `/usr/local/lib/python2.7/site-packages/`
* install python3 version of [bluepy](https://github.com/IanHarvey/bluepy)
* `ventus.py` is the low level library that talks to the weather station, copy it to a standard python library path (e.g. `/usr/local/lib/python3.9/site-packages/`
* `ventusw820.py` is the weewx driver, it goes into the weewx driver directory
* define your Ventus station in the weewx config file:
```
Expand Down
163 changes: 92 additions & 71 deletions ventus.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,19 @@
import bluepy.btle as btle
import array
import sys
import syslog

def logmsg(level, msg):
syslog.syslog(level, 'ventus.py: %s' % msg)

def logdbg(msg):
logmsg(syslog.LOG_DEBUG, msg)

def loginf(msg):
logmsg(syslog.LOG_INFO, msg)

def logerr(msg):
logmsg(syslog.LOG_ERR, msg)

# read measurements from Ventus W820 weather station via bluetooth
# (c) 2015 Christian Herzog <[email protected]>
Expand Down Expand Up @@ -29,79 +43,86 @@ def __init__(self, hndl):
def handleNotification(self, cHandle, data):
#data = data.encode("hex")
data = array.array('B', data)
# JW adding some output
#loginf('handleNotification started')
#logdbg('data[0] is %s' % data[0])
#logdbg('data: %s' % data.tolist())

if data[0] == 1:
sensorData['degF'] = 0
if data[5] < 127: #temps come in 2's complement
sensorData['indoorTemperature'] = ((data[5] * 256) + data[6])/10.0
else:
sensorData['indoorTemperature'] = -(((255-data[5]) * 256) + (255-data[6]))/10.0
sensorData['indoorHumidity'] = data[7]
if data[12] < 127: #temps come in 2's complement
sensorData['outdoorTemperature'] = ((data[12] * 256) + data[13])/10.0
else:
sensorData['outdoorTemperature'] = -(((255-data[12]) * 256) + (255-data[13]))/10.0
sensorData['outdoorHumidity'] = data[14]
if (data[1] & 2) != 0: # degF
sensorData['indoorTemperature'] = (sensorData['indoorTemperature'] - 32) / 1.8
sensorData['outdoorTemperature'] = (sensorData['outdoorTemperature'] - 32) / 1.8
sensorData['degF'] = 1
if (data[1] & 8) != 0:
sensorData['lowBat'] = 1
else:
sensorData['lowBat'] = 0
sensorData['degF'] = 0
if data[5] < 127: #temps come in 2's complement
sensorData['indoorTemperature'] = ((data[5] * 256) + data[6])/10.0
else:
sensorData['indoorTemperature'] = -(((255-data[5]) * 256) + (255-data[6]))/10.0
sensorData['indoorHumidity'] = data[7]
if data[12] < 127: #temps come in 2's complement
sensorData['outdoorTemperature'] = ((data[12] * 256) + data[13])/10.0
else:
sensorData['outdoorTemperature'] = -(((255-data[12]) * 256) + (255-data[13]))/10.0
sensorData['outdoorHumidity'] = data[14]
if (data[1] & 2) != 0: # degF
sensorData['indoorTemperature'] = (sensorData['indoorTemperature'] - 32) / 1.8
sensorData['outdoorTemperature'] = (sensorData['outdoorTemperature'] - 32) / 1.8
sensorData['degF'] = 1
if (data[1] & 8) != 0:
sensorData['lowBat'] = 1
else:
sensorData['lowBat'] = 0

elif data[0] == 2:
pressureUnit = ((data[1]) & 6) >> 1
if pressureUnit > 2:
pressureUnit = 2
sensorData['airPressure'] = ((data[3] * 256) + data[4])
if pressureUnit == 0: #Pascalish
sensorData['airPressure'] /= 10.0
elif pressureUnit == 1: #mm Hg, but wrong
sensorData['airPressure'] /= 10.0
elif pressureUnit == 2: #inches Hg
sensorData['airPressure'] *= 0.338639
pressureUnit = ((data[1]) & 6) >> 1
if pressureUnit > 2:
pressureUnit = 2
sensorData['airPressure'] = ((data[3] * 256) + data[4])
if pressureUnit == 0: #Pascalish
sensorData['airPressure'] /= 10.0
elif pressureUnit == 1: #mm Hg, but wrong
sensorData['airPressure'] /= 10.0
elif pressureUnit == 2: #inches Hg
sensorData['airPressure'] *= 0.338639
elif data[0] == 3:
rainUnit = data[1] & 16 #0: mm, 16: inches
if rainUnit == 16:
rainFactor = 0.01 * 25.4
else:
rainFactor = 0.1
windUnit = (data[1] & 14) >> 1
if windUnit > 4: #0: km/h, 1: mph, 2: m/s, 3: knots, 4: bft
windUnit = 4
rainUnit = data[1] & 16 #0: mm, 16: inches
if rainUnit == 16:
rainFactor = 0.01 * 25.4
else:
rainFactor = 0.1
windUnit = (data[1] & 14) >> 1
if windUnit > 4: #0: km/h, 1: mph, 2: m/s, 3: knots, 4: bft
windUnit = 4
sensorData['UV'] = data[18]
sensorData['rainDaily'] = ( (data[3] * 256) + data[4] ) * rainFactor
sensorData['rainWeekly'] = ( (data[5] * 256) + data[6] ) * rainFactor
sensorData['rainMonthly'] = ( ((data[7] * 65536) + (data[8] * 256)) + data[9] ) * rainFactor
sensorData['rainTotal'] = ( ((data[15] * 65536) + (data[16] * 256)) + data[17] ) * rainFactor
sensorData['windSpeed'] = (data[11] * 256) + data[12]
sensorData['windChill'] = ((data[13] * 256) + data[14])/10.0
sensorData['windDirection'] = data[10]
if windUnit == 0:
sensorData['windSpeed'] *= 0.1
if windUnit == 1:
sensorData['windSpeed'] = sensorData['windSpeed'] * 0.1 * 1.60934
if sensorData['degF'] == 0: # bug in W820: wind speeds not in km/h depend on temperature unit!!!
sensorData['windSpeed'] *= 0.01313868613138686131
elif windUnit == 2:
sensorData['windSpeed'] = sensorData['windSpeed'] * 0.1 * 3.6
if sensorData['degF'] == 0: # bug in W820: wind speeds not in km/h depend on temperature unit!!!
sensorData['windSpeed'] *= 0.01157742402315484804
elif windUnit == 3:
sensorData['windSpeed'] = sensorData['windSpeed'] * 0.1 * 1.85199539525386
if sensorData['degF'] == 0: # bug in W820: wind speeds not in km/h depend on temperature unit!!!
sensorData['windSpeed'] *= 0.03782505910165484633

sensorData['rainDaily'] = ( (data[3] * 256) + data[4] ) * rainFactor
sensorData['rainWeekly'] = ( (data[5] * 256) + data[6] ) * rainFactor
sensorData['rainMonthly'] = ( ((data[7] * 65536) + (data[8] * 256)) + data[9] ) * rainFactor
sensorData['rainTotal'] = ( ((data[15] * 65536) + (data[16] * 256)) + data[17] ) * rainFactor
sensorData['windSpeed'] = (data[11] * 256) + data[12]
sensorData['windChill'] = ((data[13] * 256) + data[14])/10.0
sensorData['windDirection'] = data[10]
if windUnit == 0:
#JW: i think this should not be changed (i.e. *=1.0), according to my observation/with my ventusw820
# but keeping it as is in the PR as it is on python3 only
sensorData['windSpeed'] *= 0.1
if windUnit == 1:
sensorData['windSpeed'] = sensorData['windSpeed'] * 0.1 * 1.60934
if sensorData['degF'] == 0: # bug in W820: wind speeds not in km/h depend on temperature unit!!!
sensorData['windSpeed'] *= 0.01313868613138686131
elif windUnit == 2:
sensorData['windSpeed'] = sensorData['windSpeed'] * 0.1 * 3.6
if sensorData['degF'] == 0: # bug in W820: wind speeds not in km/h depend on temperature unit!!!
sensorData['windSpeed'] *= 0.01157742402315484804
elif windUnit == 3:
sensorData['windSpeed'] = sensorData['windSpeed'] * 0.1 * 1.85199539525386
if sensorData['degF'] == 0: # bug in W820: wind speeds not in km/h depend on temperature unit!!!
sensorData['windSpeed'] *= 0.03782505910165484633

def connect(mac):
w820 = None
try:
w820 = btle.Peripheral(mac, 'random')
return w820
except:
e = sys.exc_info()[0]
print e
print(e)
finally:
return w820

Expand All @@ -114,23 +135,23 @@ def setTime(w820, time):
def read(w820):
w820.setDelegate(w820Delegate(''))
try:
w820.writeCharacteristic(0x000e, '\x01\x00', True) # Turn on notificiations
w820.writeCharacteristic(0x000b, '\xb0\x01\x00\x00', True) # Request data
w820.waitForNotifications(1) # wait for response
w820.writeCharacteristic(0x000b, '\x40\x01\x00\x00', True) # send ACK for next packet
w820.waitForNotifications(1) # wait for response
w820.writeCharacteristic(0x000b, '\x40\x01\x00\x00', True) # send ACK for next packet
w820.waitForNotifications(1) # wait for response
w820.writeCharacteristic(0x000e, b'\x01\x00', True) # Turn on notificiations
w820.writeCharacteristic(0x000b, b'\xb0\x01\x00\x00', True) # Request data
w820.waitForNotifications(1) # wait for response
w820.writeCharacteristic(0x000b, b'\x40\x01\x00\x00', True) # send ACK for next packet
w820.waitForNotifications(1) # wait for response
w820.writeCharacteristic(0x000b, b'\x40\x01\x00\x00', True) # send ACK for next packet
w820.waitForNotifications(1) # wait for response

except:
e = sys.exc_info()[0]
print e
print(e)
finally:
return sensorData
return sensorData

def disconnect(w820):
try:
w820.disconnect
except:
e = sys.exc_info()[0]
print e
print(e)
Loading