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.
