I opened an issue for this feature. It is here https://github.com/bellrichm/WeeWX-MQTTSubscribe/issues/15 It should be the next feature I work on. But I do need to do some additional code cleanup around bad data, edge cases, etc. Rich
On Friday, 26 April 2019 02:42:27 UTC-4, Eugen66 wrote: > > Thank you again, that did it :) > Yes, that's what I meant, because I have different sensors and they do not > publish to Weather/, for instance I have a barometer that publish > to SPA/Barometer_SPA, this one I can change but it is used for something > else so I'd rather not. But I think this service is great to add different > sensor and have the flexibility to subscribe to different topics. > I actually would like to use the SDR-RTL to publish everything to MQTT > and let Weewx subscribe to that, along with other home automation. > best regards > Atle > > fredag 26. april 2019 01.42.54 UTC+2 skrev Rich Bell følgende: >> >> It’s software, so almost anything is possible :) >> Is the use case that the same “field name” might be in different topics? >> Something like this, topic indoor/temp maps to inTemp and outdoor/temp maps >> to outTemp. If so, I’d probably add an option to concatenate the topic >> into the field name and use the current mapping functionality. This would >> mean that all input would need a mapping, because all “field names” would >> be prepended with the higher/parent topic. >> But, with that said, my focus is on adding tests to the test suite before >> adding more functionality. >> - rich >> >> On Thu, Apr 25, 2019 at 4:42 PM Eugen66 <[email protected]> wrote: >> >>> I was missing ' at the unit selection... >>> >>> Thank you so much :) >>> I was wondering, is it possible for instance to have a "mapping" in the >>> conf file to map values to specific and different topics, inTemp = >>> sensor/inTemp , outTemp= Weather/outTemp as an example? >>> >>> best regards >>> Atle >>> >>> >>> torsdag 25. april 2019 21.45.54 UTC+2 skrev [email protected] følgende: >>>> >>>> I was just going to ask about the password. After the problem with >>>> keepalive, I was afraid this bug would show up. My guess is that I need to >>>> convert the payload to float. If you want to try patching it, around line >>>> 208 change from >>>> >>>> data[self.label_map.get(key,key)] = msg.payload >>>> >>>> to >>>> >>>> data[self.label_map.get(key,key)] = to_float(msg.payload) >>>> >>>> >>>> Right now I don’t have a great environment for the “individual” >>>> payload type, so it will take a bit to really dig in on this. >>>> >>>> Thanks for your help. Rich >>>> >>>> On Thu, Apr 25, 2019 at 3:30 PM Eugen66 <[email protected]> wrote: >>>> >>>>> Sorrry :( My bad...Found the mqtt disconnected with result code 5... >>>>> Wrong passwd i conf. >>>>> So now it connect and find the data, but Weewx exit's with this: >>>>> >>>>> Apr 25 21:27:51 weewx-hyggebu weewx[30607]: MQTTSS: Processing >>>>> interval: 1556220434.000000 1556220467.000000 >>>>> Apr 25 21:27:51 weewx-hyggebu weewx[30607]: MQTTSS: Queue size is: 6 >>>>> Apr 25 21:27:51 weewx-hyggebu weewx[30607]: MQTTSS: Processing: >>>>> dateTime: 1556220439.64, extraTemp2: 13.5, usUnits: 1 >>>>> Apr 25 21:27:51 weewx-hyggebu weewx[30607]: engine: Main loop exiting. >>>>> Shutting engine down. >>>>> Apr 25 21:27:51 weewx-hyggebu weewx[30607]: restx: Shut down MQTT >>>>> thread. >>>>> Apr 25 21:27:51 weewx-hyggebu weewx[30607]: MQTTSS: Disconnected with >>>>> result code 0 >>>>> Apr 25 21:27:51 weewx-hyggebu weewx[30607]: sdr: MainThread: shutdown >>>>> process rtl_433 -M utc -F json -G >>>>> Apr 25 21:27:51 weewx-hyggebu weewx[30607]: sdr: MainThread: waiting >>>>> for stdout-thread >>>>> Apr 25 21:27:52 weewx-hyggebu weewx[30607]: sdr: MainThread: waiting >>>>> for stderr-thread >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: sdr: MainThread: timed out >>>>> waiting for stderr-thread >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: sdr: MainThread: close >>>>> stdout >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: sdr: MainThread: close >>>>> stderr >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: engine: Caught >>>>> unrecoverable exception in engine: >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** accum: >>>>> ScalarStats.addHiLo expected float or int, got 13.5 >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** Traceback (most >>>>> recent call last): >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** File >>>>> "/usr/share/weewx/weewx/engine.py", line 890, in main >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** engine.run() >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** File >>>>> "/usr/share/weewx/weewx/engine.py", line 191, in run >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** >>>>> self.dispatchEvent(weewx.Event(weewx.NEW_LOOP_PACKET, packet=packet)) >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** File >>>>> "/usr/share/weewx/weewx/engine.py", line 224, in dispatchEvent >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** >>>>> callback(event) >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** File >>>>> "/usr/share/weewx/user/MQTTSubscribe.py", line 309, in new_loop_packet >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** target_data >>>>> = self._process_data(start_ts, self.end_ts, event.packet) >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** File >>>>> "/usr/share/weewx/user/MQTTSubscribe.py", line 289, in _process_data >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** >>>>> accumulator.addRecord(archive_data) >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** File >>>>> "/usr/share/weewx/weewx/accum.py", line 256, in addRecord >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** func(self, >>>>> record, obs_type, add_hilo, weight) >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** File >>>>> "/usr/share/weewx/weewx/accum.py", line 314, in add_value >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** >>>>> self[obs_type].addHiLo(val, record['dateTime']) >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** File >>>>> "/usr/share/weewx/weewx/accum.py", line 77, in addHiLo >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** raise >>>>> ValueError("accum: ScalarStats.addHiLo expected float or int, got %s" % >>>>> val) >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** ValueError: >>>>> accum: ScalarStats.addHiLo expected float or int, got 13.5 >>>>> Apr 25 21:28:02 weewx-hyggebu weewx[30607]: **** Exiting. >>>>> >>>>> rgds >>>>> Atle >>>>> >>>>> >>>>> >>>>> torsdag 25. april 2019 19.47.23 UTC+2 skrev Rich Bell følgende: >>>>>> >>>>>> I think i am not handling the options correctly and the keepalive is >>>>>> a string and not an integer. For now, leave it out of weewx.conf and let >>>>>> it >>>>>> default to 60. >>>>>> - rich >>>>>> >>>>>> On Thu, Apr 25, 2019 at 11:14 AM Eugen66 <[email protected]> wrote: >>>>>> >>>>> Thank you so much for helping :) >>>>>>> I have used the apt.. >>>>>>> >>>>>>> When I run, in folder etc/weewx, I get this : >>>>>>> :/etc/weewx# PYTHONPATH=/usr/share/weewx python >>>>>>> /usr/share/weewx//user/MQTTSubscribe.py --type service --binding >>>>>>> archive >>>>>>> --interval 300 --delay 15 --records 2 weewx.conf >>>>>>> Simulation is service >>>>>>> Creating 2 archive records >>>>>>> Interval is 300 seconds >>>>>>> Delay is 15 seconds >>>>>>> Traceback (most recent call last): >>>>>>> File "/usr/share/weewx//user/MQTTSubscribe.py", line 557, in >>>>>>> <module> >>>>>>> main() >>>>>>> File "/usr/share/weewx//user/MQTTSubscribe.py", line 479, in main >>>>>>> simulate_service(engine, config_dict, binding, record_count, >>>>>>> interval, delay, units) >>>>>>> File "/usr/share/weewx//user/MQTTSubscribe.py", line 523, in >>>>>>> simulate_service >>>>>>> service = MQTTSubscribeService(engine, config_dict) >>>>>>> File "/usr/share/weewx//user/MQTTSubscribe.py", line 263, in >>>>>>> __init__ >>>>>>> self.thread = MQTTSubscribeServiceThread(self, self.client, >>>>>>> self.queue, self.archive_queue, label_map, unit_system, payload_type, >>>>>>> host, >>>>>>> keepalive, por t, username, password, topic, >>>>>>> archive_topic) >>>>>>> File "/usr/share/weewx//user/MQTTSubscribe.py", line 326, in >>>>>>> __init__ >>>>>>> MQTTSubscribe.__init__(self, client, queue, archive_queue, >>>>>>> label_map, unit_system, payload_type, host, keepalive, port, username, >>>>>>> password, topic, arc hive_topic) >>>>>>> File "/usr/share/weewx//user/MQTTSubscribe.py", line 135, in >>>>>>> __init__ >>>>>>> self.client.connect(host, port, keepalive) >>>>>>> File "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", >>>>>>> line 839, in connect >>>>>>> return self.reconnect() >>>>>>> File "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", >>>>>>> line 1009, in reconnect >>>>>>> return self._send_connect(self._keepalive, self._clean_session) >>>>>>> File "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", >>>>>>> line 2361, in _send_connect >>>>>>> keepalive)) >>>>>>> struct.error: cannot convert argument to integer >>>>>>> >>>>>>> And trying with 60 >>>>>>> >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: MQTTSS: Keep alive is 60 >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: MQTTSS: Username is >>>>>>> openhabian >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: MQTTSS: Password is set >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: MQTTSS: Topic is Weather/ >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: MQTTSS: Archive topic is >>>>>>> None >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: MQTTSS: Payload type is >>>>>>> individual >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: MQTTSS: Default units is >>>>>>> 1 >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: MQTTSS: Label map is >>>>>>> {'outHumidity': 'outHumidity', 'overlap': '20', 'binding': 'loop'} >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: sdr: MainThread: >>>>>>> shutdown process rtl_433 -M utc -F json -G >>>>>>> Apr 25 17:11:20 weewx-hyggebu weewx[14390]: sdr: MainThread: waiting >>>>>>> for stdout-thread >>>>>>> Apr 25 17:11:24 weewx-hyggebu weewx[14390]: sdr: MainThread: waiting >>>>>>> for stderr-thread >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: sdr: MainThread: timed >>>>>>> out waiting for stderr-thread >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: sdr: MainThread: close >>>>>>> stdout >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: sdr: MainThread: close >>>>>>> stderr >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: engine: Caught >>>>>>> unrecoverable exception in engine: >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** cannot convert >>>>>>> argument to integer >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** Traceback >>>>>>> (most recent call last): >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/share/weewx/weewx/engine.py", line 884, in main >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** engine = >>>>>>> engine_class(config_dict) >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/share/weewx/weewx/engine.py", line 78, in __init__ >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** >>>>>>> self.loadServices(config_dict) >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/share/weewx/weewx/engine.py", line 142, in loadServices >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** >>>>>>> self.service_obj.append(weeutil.weeutil._get_object(svc)(self, >>>>>>> config_dict)) >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/share/weewx/user/MQTTSubscribe.py", line 263, in __init__ >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** >>>>>>> self.thread = MQTTSubscribeServiceThread(self, self.client, self.queue, >>>>>>> self.archive_queue, label_map, unit_system, payload_type, host, >>>>>>> keepalive, >>>>>>> port, username, password, topic, archive_topic) >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/share/weewx/user/MQTTSubscribe.py", line 326, in __init__ >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** >>>>>>> MQTTSubscribe.__init__(self, client, queue, archive_queue, label_map, >>>>>>> unit_system, payload_type, host, keepalive, port, username, password, >>>>>>> topic, archive_topic) >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/share/weewx/user/MQTTSubscribe.py", line 135, in __init__ >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** >>>>>>> self.client.connect(host, port, keepalive) >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", line 839, >>>>>>> in >>>>>>> connect >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** return >>>>>>> self.reconnect() >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", line >>>>>>> 1009, in >>>>>>> reconnect >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** return >>>>>>> self._send_connect(self._keepalive, self._clean_session) >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** File >>>>>>> "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", line >>>>>>> 2361, in >>>>>>> _send_connect >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** keepalive)) >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** error: cannot >>>>>>> convert argument to integer >>>>>>> Apr 25 17:11:34 weewx-hyggebu weewx[14390]: **** Exiting. >>>>>>> >>>>>>> >>>>>>> torsdag 25. april 2019 16.47.02 UTC+2 skrev [email protected] >>>>>>> følgende: >>>>>>>> >>>>>>>> Hi, >>>>>>>> I have only installed via setup.py, but I think the problem with >>>>>>>> running standalone is that after the PYTHONPATH= it should be >>>>>>>> /usr/share/ >>>>>>>> *weewx* >>>>>>>> PYTHONPATH=/usr/share/*weewx* python >>>>>>>> /usr/share/weewx//user/MQTTSubscribe.py --type service --binding >>>>>>>> archive >>>>>>>> --interval 300 --delay 15 --records 2 weewx.conf >>>>>>>> >>>>>>>> As for the real error, it appears that the keepalive value might >>>>>>>> need to be divisible by 60. I can reproduce the error when I set it to >>>>>>>> 70, >>>>>>>> but I am still researching. >>>>>>>> - Rich >>>>>>>> >>>>>>>> >>>>>>>> On Thursday, 25 April 2019 10:08:22 UTC-4, Eugen66 wrote: >>>>>>>>> >>>>>>>>> Hi, >>>>>>>>> really trying to get your MQTT subscription to work, this is a >>>>>>>>> very useful way of adding values to a great weather software :) >>>>>>>>> I use (for the moment SDR as driver) >>>>>>>>> When I try to run it stand alone I get this: >>>>>>>>> >>>>>>>>> PYTHONPATH=/usr/share/ python >>>>>>>>> /usr/share/weewx//user/MQTTSubscribe.py --type service --binding >>>>>>>>> archive >>>>>>>>> --interval 300 --delay 15 --records 2 weewx.conf >>>>>>>>> Traceback (most recent call last): >>>>>>>>> File "/usr/share/weewx//user/MQTTSubscribe.py", line 75, in >>>>>>>>> <module> >>>>>>>>> import weeutil.weeutil >>>>>>>>> ImportError: No module named weeutil.weeutil >>>>>>>>> >>>>>>>>> and Weewx fail to start when I add MQTTSubscribe.... to >>>>>>>>> weewx.conf >>>>>>>>> >>>>>>>>> Any suggestion? >>>>>>>>> >>>>>>>>> this is the log: >>>>>>>>> Apr 25 15:50:26 weewx-hyggebu systemd[1]: Starting LSB: weewx >>>>>>>>> weather system... >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9314]: engine: Initializing >>>>>>>>> weewx version 3.9.1 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9314]: engine: Using Python >>>>>>>>> 2.7.13 (default, Sep 26 2018, 18:42:22) #012[GCC 6.3.0 20170516] >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9314]: engine: Platform >>>>>>>>> Linux-4.14.98-v7+-armv7l-with-debian-9.8 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9314]: engine: Locale is >>>>>>>>> 'en_GB.UTF-8' >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9314]: engine: pid file is >>>>>>>>> /var/run/weewx.pid >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9303]: Starting weewx weather >>>>>>>>> system: weewx. >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu systemd[1]: Started LSB: weewx >>>>>>>>> weather system. >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: engine: Using >>>>>>>>> configuration file /etc/weewx/weewx.conf >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: engine: Debug is 1 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: engine: Initializing >>>>>>>>> engine >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: engine: Loading station >>>>>>>>> type SDR (user.sdr) >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: sdr: MainThread: driver >>>>>>>>> version is 0.62 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: sdr: MainThread: sensor >>>>>>>>> map is {'inTemp': 'temperature.8:1.AcuriteWT450Packet', 'outTemp': >>>>>>>>> 'temperature.1:1.AcuriteWT450Packet', 'outHumidity': '', >>>>>>>>> 'extraTemp1': >>>>>>>>> 'temperature.4:5.HidekiWindPacket', 'extraHumidity1': '', >>>>>>>>> 'extraTemp2': '', >>>>>>>>> 'extraHumidity3': '', 'rain': 'rain_total.4:0.HidekiRainPacket', >>>>>>>>> 'rainBatteryStatus': 'battery.4:0.HidekiRainPacket', 'UV': >>>>>>>>> 'uv_index.1:137.OSUV800Packet', 'outTempBatteryStatus': >>>>>>>>> 'battery.1:137.OSUV800Packet', 'windDir': >>>>>>>>> 'wind_dir.4:5.HidekiWindPacket', >>>>>>>>> 'windGust': 'wind_gust.4:5.HidekiWindPacket', 'windSpeed': >>>>>>>>> 'wind_speed.4:5.HidekiWindPacket', 'windBatteryStatus': >>>>>>>>> 'battery.4:5.HidekiWindPacket'} >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: sdr: MainThread: deltas >>>>>>>>> is {'strikes': 'strikes_total', 'rain': 'rain_total'} >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: sdr: MainThread: >>>>>>>>> startup process 'rtl_433 -M utc -F json -G' >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: sdr: stdout-thread: >>>>>>>>> start async reader for stdout-thread >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: sdr: stderr-thread: >>>>>>>>> start async reader for stderr-thread >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: engine: Loading service >>>>>>>>> weewx.engine.StdTimeSynch >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: engine: Finished >>>>>>>>> loading service weewx.engine.StdTimeSynch >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: engine: Loading service >>>>>>>>> user.MQTTSubscribe.MQTTSubscribeService >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Client id is >>>>>>>>> weewx >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Binding is loop >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Default units >>>>>>>>> is US 1 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Overlap is 0.0 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Host is >>>>>>>>> 10.0.10.165 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Port is 1883 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Keep alive is 70 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Username is >>>>>>>>> xxxxxx >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Password is set >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Topic is >>>>>>>>> Weather/ >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Archive topic >>>>>>>>> is None >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Payload type is >>>>>>>>> individual >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Default units >>>>>>>>> is 1 >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: MQTTSS: Label map is >>>>>>>>> {'outHumidity': 'outHumidity', 'overlap': '20', 'binding': 'loop'} >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: sdr: MainThread: >>>>>>>>> shutdown process rtl_433 -M utc -F json -G >>>>>>>>> Apr 25 15:50:27 weewx-hyggebu weewx[9318]: sdr: MainThread: >>>>>>>>> waiting for stdout-thread >>>>>>>>> Apr 25 15:50:31 weewx-hyggebu weewx[9318]: sdr: MainThread: >>>>>>>>> waiting for stderr-thread >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: sdr: MainThread: timed >>>>>>>>> out waiting for stderr-thread >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: sdr: MainThread: close >>>>>>>>> stdout >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: sdr: MainThread: close >>>>>>>>> stderr >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: engine: Caught >>>>>>>>> unrecoverable exception in engine: >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** cannot >>>>>>>>> convert argument to integer >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** Traceback >>>>>>>>> (most recent call last): >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/share/weewx/weewx/engine.py", line 884, in main >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** engine = >>>>>>>>> engine_class(config_dict) >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/share/weewx/weewx/engine.py", line 78, in __init__ >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** >>>>>>>>> self.loadServices(config_dict) >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/share/weewx/weewx/engine.py", line 142, in loadServices >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** >>>>>>>>> self.service_obj.append(weeutil.weeutil._get_object(svc)(self, >>>>>>>>> config_dict)) >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/share/weewx/user/MQTTSubscribe.py", line 263, in __init__ >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** >>>>>>>>> self.thread = MQTTSubscribeServiceThread(self, self.client, >>>>>>>>> self.queue, >>>>>>>>> self.archive_queue, label_map, unit_system, payload_type, host, >>>>>>>>> keepalive, >>>>>>>>> port, username, password, topic, archive_topic) >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/share/weewx/user/MQTTSubscribe.py", line 326, in __init__ >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** >>>>>>>>> MQTTSubscribe.__init__(self, client, queue, archive_queue, label_map, >>>>>>>>> unit_system, payload_type, host, keepalive, port, username, password, >>>>>>>>> topic, archive_topic) >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/share/weewx/user/MQTTSubscribe.py", line 135, in __init__ >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** >>>>>>>>> self.client.connect(host, port, keepalive) >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", line >>>>>>>>> 839, in >>>>>>>>> connect >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** return >>>>>>>>> self.reconnect() >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", line >>>>>>>>> 1009, in >>>>>>>>> reconnect >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** return >>>>>>>>> self._send_connect(self._keepalive, self._clean_session) >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** File >>>>>>>>> "/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.py", line >>>>>>>>> 2361, in >>>>>>>>> _send_connect >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** >>>>>>>>> keepalive)) >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** error: cannot >>>>>>>>> convert argument to integer >>>>>>>>> Apr 25 15:50:41 weewx-hyggebu weewx[9318]: **** Exiting. >>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>>> onsdag 24. april 2019 01.36.17 UTC+2 skrev [email protected] >>>>>>>>> følgende: >>>>>>>>>> >>>>>>>>>> After experimenting and developing more, I decided this needs it >>>>>>>>>> own repository. You can now find it here, >>>>>>>>>> https://github.com/bellrichm/WeeWX-MQTTSubscribe >>>>>>>>>> >>>>>>>>>> The service now supports binding to either new loop packets or >>>>>>>>>> new archive records. Since much of the code was similar to my MQTT >>>>>>>>>> driver, >>>>>>>>>> this has been added to the module. It is still a manual install >>>>>>>>>> process, >>>>>>>>>> but some documentation has been added. >>>>>>>>>> -rich >>>>>>>>>> >>>>>>>>> -- >>>>>>> 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 [email protected]. >>>>>> >>>>>> >>>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>>> >>>>>> -- >>>>> 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 [email protected]. >>>>> For more options, visit https://groups.google.com/d/optout. >>>>> >>>> -- >>> 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 [email protected]. >>> For more options, visit https://groups.google.com/d/optout. >>> >> -- 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 [email protected]. For more options, visit https://groups.google.com/d/optout.
