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