File attached as rainmachine2.py
On Friday, February 21, 2020 at 4:58:01 PM UTC-5, G Hammer wrote: > > Ok, downloaded the file, took the original expand --tabs=4 rainmachine.py > > temp.txt replaced the .py file with the .txt file resulting in a > rainmachine.py with no tabs. > Ran 2to3 get an error, a lone 'return' on line 67. > > RefactoringTool: There was 1 error: > RefactoringTool: Can't parse rainmachine.py: ParseError: bad input: > type=1, value='return', context=(' ', (67, 4)) > > > > -- You received this message because you are subscribed to the Google Groups "weewx-user" group. To unsubscribe from this group and stop receiving emails from it, send an email to weewx-user+unsubscr...@googlegroups.com. To view this discussion on the web visit https://groups.google.com/d/msgid/weewx-user/d20e4710-3f81-4a5d-85df-1f620609839e%40googlegroups.com.
# Copyright 2018 Green Electronics LLC """ Upload weather data directly to RainMachine smart irrigation controler http://rainmachine.com Based on RainMachine API 4.6 https://rainmachine.docs.apiary.io/ This extension only works on the local network (doesn't work with RainMachine Remote Access service). RainMachine IP address and https port 8080 must be accessible from WeeWX installation. An access token is needed and can be obtained with a POST request: curl -X POST -k -d ' { "pwd": "admin", "remember":1}' https://rainmachine_ip:8080/api/4/auth/login More details can be found here: https://support.rainmachine.com/hc/en-us/articles/228022248-Controlling-RainMachine-through-REST-API By default data is sent to RainMachine hourly. Although is possible to send data more often the RainMachine Mixer (that aggregates data from multiple sources) runs only hourly. Minimal configuration: [StdRESTful] [[RainMachine]] token = ACCESS_TOKEN ip = RAINMACHINE IP usessl = false """ import Queue import syslog import urllib import urllib2 import json import weewx import weewx.restx import weewx.units from weeutil.weeutil import to_bool, accumulateLeaves, startOfDayUTC VERSION = "0.3" if weewx.__version__ < "3": raise weewx.UnsupportedFeature("weewx 3 is required, found %s" % weewx.__version__) def logmsg(level, msg): syslog.syslog(level, 'restx: RainMachine: %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) def _get_day_min_max_temp(dbm, ts): sod = startOfDayUTC(ts) val = dbm.getSql("SELECT MIN(outTemp), MAX(outTemp) FROM %s " "WHERE dateTime>? AND dateTime<=?" % dbm.table_name, (sod, ts)) if val is None: return None, None return val # convert temperature to celsius (we need this from values read from DB) def _convert_temperature(v, from_unit): if from_unit is None or v is None: return None if from_unit != weewx.METRIC: std_type, _ = weewx.units.getStandardUnitType(from_unit, 'outTemp') from_type = (v, std_type, 'group_temperature') v = weewx.units.convert(from_type, 'degree_C')[0] return v class RainMachine(weewx.restx.StdRESTful): def __init__(self, engine, config_dict): super(RainMachine, self).__init__(engine, config_dict) loginf('service version is %s' % VERSION) site_dict = weewx.restx.get_site_dict(config_dict, 'RainMachine', 'token', 'ip') if site_dict is None: logerr("Data will not be posted: Missing configuration options.") return site_dict.setdefault('usessl', False) site_dict['usessl'] = to_bool(site_dict.get('usessl')) site_dict['manager_dict'] = weewx.manager.get_manager_dict( config_dict['DataBindings'], config_dict['Databases'], 'wx_binding') self.archive_queue = Queue.Queue() self.archive_thread = RainMachineThread(self.archive_queue, **site_dict) self.archive_thread.start() self.bind(weewx.NEW_ARCHIVE_RECORD, self.new_archive_record) loginf("Data will be uploaded for RainMachine located at %s ssl: %s" % (site_dict['ip'], site_dict['usessl'])) def new_archive_record(self, event): self.archive_queue.put(event.record) class RainMachineThread(weewx.restx.RESTThread): """ RainMachine POST /api/4/parser/data expected data format (metric units only): { "weather": [ { "mintemp":null, "maxtemp": null, "temperature": null, "wind": null, "solarrad": null, "qpf": null, "rain": null, "minrh": null, "maxrh": null, "condition": 26, "pressure": null, "dewpoint": null }, { "timestamp": 1563362587, "mintemp":null, "maxtemp": null, "temperature": null, "wind": null, "solarrad": null, "qpf": null, "rain": null, "minrh": null, "maxrh": null, "condition": 26, "pressure": null, "dewpoint": null, "et": null } ] } """ _DATA_MAP = { 'timestamp': ('dateTime', 1, 0), # epoch 'wind': ('windSpeed', 0.2777777777, 0.0), # m/s 'temperature': ('outTemp', 1.0, 0.0), # C 'maxrh': ('outHumidity', 1.0, 0.0), # percent 'dewpoint': ('dewpoint', 1.0, 0.0), # C 'pressure': ('barometer', 0.1, 0.0), # kPa 'rain': ('dayRain', 10.0, 0.0), # mm 'mintemp': ('outTempMin', 1.0, 0.0), # C 'maxtemp': ('outTempMax', 1.0, 0.0), # C 'et': ('ET', 10.0, 0), # mm } def __init__(self, queue, token, ip, usessl, manager_dict, skip_upload=False, post_interval=3600, max_backlog=0, stale=None, log_success=True, log_failure=True, timeout=60, max_tries=3, retry_wait=5): super(RainMachineThread, self).__init__(queue, protocol_name='RainMachine', manager_dict=manager_dict, post_interval=post_interval, max_backlog=max_backlog, stale=stale, log_success=log_success, log_failure=log_failure, timeout=timeout, max_tries=max_tries, retry_wait=retry_wait) self.token = token self.ip = ip self.usessl = usessl self.skip_upload = to_bool(skip_upload) def process_record(self, record, dbm): r = self.get_record(record, dbm) data = self.get_data(r) if self.usessl: proto = "https" port = "8080" else: proto = "http" port = "8081" url = "%s://%s:%s/api/4/parser/data?access_token=%s" % (proto, self.ip, port, self.token) if self.skip_upload: loginf("skipping upload") return req = urllib2.Request(url, data) req.get_method = lambda: 'POST' req.add_header("Content-Type", "application/json") req.add_header("User-Agent", "weewx/%s" % weewx.__version__) self.post_with_retries(req) def get_record(self, record, dbm): rec = super(RainMachineThread, self).get_record(record, dbm) # put everything into the right units rec = weewx.units.to_METRIC(rec) rec['outTempMin'], rec['outTempMax'] = _get_day_min_max_temp(dbm, rec['dateTime']) rec['outTempMin'] = _convert_temperature(rec['outTempMin'], record['usUnits']) rec['outTempMax'] = _convert_temperature(rec['outTempMax'], record['usUnits']) return rec def get_data(self, record): # put data into expected scaling, structure, and format entry = {} for _key in self._DATA_MAP: rkey = self._DATA_MAP[_key][0] if rkey in record and record[rkey] is not None: entry[_key] = record[rkey] * self._DATA_MAP[_key][1] + self._DATA_MAP[_key][2] values = {} values['weather'] = [] values['weather'].append(entry) data = json.dumps(values) return data