Looks like a documentation error. Try unit_system = METRIC Sorry about that. -rich
On Thu, Apr 25, 2019 at 5:03 PM Eugen66 <[email protected]> wrote: > Thank you so much :) > > I have tried all the option for Units for MQTT but it seems that it does > not change... > > 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.
