weewx_extensions/windguru.py at master · mKainzbauer/weewx_extensions · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
# -*- coding: utf-8 -*-
#    See the file LICENSE.txt for your rights.
#    Author: Michael Kainzbauer (github: mkainzbauer)

"""How to upload your weather data to windguru.cz

*******************************************************************************

To use this extension, add the following somewhere in your configuration file
weewx.conf:

[Windguru]
    url = http://www.windguru.cz/upload/upload_custom.php
    uid = YOUR_WINDGURU_UID
    barometer = barometer # the pressure reading you want to upload, windguru expects pressure normalized to sea level, possible values are baromter, pressure, altimeter


Relevant data (winguru doesn't store all possible values) will be uploaded to windugu.cz every achive interval

*******************************************************************************

To enable this service:

1) copy this file to the user directory

2) modify the weewx configuration file by adding this service to the option
"report_services", located in section [Engine][[Services]].

[Engine]
  [[Services]]
    ...
    data_services = user.windguru.UploadWindguru # other services can be appended separated with a comma

*******************************************************************************
"""
import weewx, urllib.request, urllib.error, time, logging
from weewx.engine import StdService

log = logging.getLogger(__name__)

class UploadWindguru(StdService):

    inHgmBarFactor = 33.8638
    mphKnotFactor = 0.868976558176657
    inmmFactor = 25.4
    cmmmFactor = 10
    kmhKnotFactor = 0.539957
    mpsKnotFactor = 1.94384

    def __init__(self, engine, config_dict):

      # Initialize my superclass first:
      super(UploadWindguru, self).__init__(engine, config_dict)

      # Bind to any new archive record events:
      self.bind(weewx.NEW_ARCHIVE_RECORD, self.new_archive_record)

    def new_archive_record(self, event):
      try:
        wind_avg = float(event.record['windSpeed'])
        wind_max = float(event.record['windGust'])
        wind_direction = event.record['windDir']
        temperature = float(event.record['outTemp'])
        rh = event.record['outHumidity']
        mslp = float(event.record['pressure'])
        if self.config_dict['Windguru']['barometer'] in event.record:
          mslp = float(event.record[self.config_dict['Windguru']['barometer']])
        precip = float(event.record['rain'])

        log.debug("event.record: %s" % event.record)
        #Windguru only takes current values, so only values from close to now are taken (in case of backfilling values)
        if (time.time() - int(event.record['dateTime'])) < int(self.config_dict['StdArchive']['archive_interval']):
          if int(event.record['usUnits']) == weewx.US:
            wind_avg = wind_avg * UploadWindguru.mphKnotFactor
            wind_max = wind_max * UploadWindguru.mphKnotFactor
            precip = precip * UploadWindguru.inmmFactor
            temperature = (temperature - 32) * 5 / float(9)
            mslp = mslp * UploadWindguru.inHgmBarFactor
          elif int(event.record['usUnits']) == weewx.METRIC:
            wind_avg = wind_avg * UploadWindguru.kmhKnotFactor
            wind_max = wind_max * UploadWindguru.kmhKnotFactor
            precip = precip * UploadWindguru.cmmmFactor
          elif int(event.record['usUnits']) == weewx.METRICWX:
            wind_avg = wind_avg * UploadWindguru.mpsKnotFactor
            wind_max = wind_max * UploadWindguru.mpsKnotFactor
          request = self.config_dict['Windguru']['url'] + '?uid=' + self.config_dict['Windguru']['uid'] + '&wind_avg=' + str(wind_avg) + '&wind_max=' + str(wind_max) + '&wind_direction=' + str(wind_direction) + '&temperature=' + str(temperature) + '&rh=' + str(rh) + '&mslp=' + str(mslp) + '&precip=' + str(precip)
          log.info("Uploading Windguru data: %s" % request)
          try:
            result = urllib.request.urlopen(request, timeout = 1)
            httpStatusCode = result.getcode()
            if int(httpStatusCode) != 200:
              log.error("Failed to upload data: Winguru answer: %s"  % httpStatusCode)
            else:
              log.debug("Winguru answer: %s"  % httpStatusCode)
          except urllib.error.URLError as e:
            log.error("Error uploading data: %r" % e)
          except:
            log.error("Unexpected error:")
      except:
        log.error("Unexpected error:")