Thank you ,
I'm sorry but I did not give a good example, I was thinking of something
similar to sensor map, so "mapping" directly to topic, like in the SDR
driver:
[[sensor_map]]
inTemp = temperature.8:1.AcuriteWT450Packet
outTemp = temperature.1:1.AcuriteWT450Packet
extraTemp1 = temperature.4:5.HidekiWindPacket
rain_total = rain_total.4:0.HidekiRainPacket
example:
[[sensor_map]]
inTemp = Weather/temperatur1
outTemp = SPA/Outtemp
extraTemp1 = sensor/ute/temp
rain_total = outdoor/rain
best regards
Atle
fredag 26. april 2019 15.55.51 UTC+2 skrev [email protected] følgende:
>
> 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.
