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] <javascript:>> > 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] <javascript:>. >> 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.
