search

bellrichm / WeeWX-MQTTSubscribe

A WeeWX service and driver that receives data from MQTT.
GNU General Public License v3.0
54 stars 13 forks source link

Support subscribing to multiple topics #18

Closed bellrichm closed 5 years ago

bellrichm commented 5 years ago

In individual mode, support subscribing to multiple topics and map to fieldnames.

bellrichm commented 5 years ago

Should probably support qos per topic.

bellrichm commented 5 years ago

If this is supported for payloads other than individual, probably need separate queues for each topic. This is to handle that the fact that the time stamps might get out of order between the different topics.

bellrichm commented 5 years ago

For multiple topics use [[topics]] [[[first/topic]]] [[[second/one]]]

eugen66 commented 5 years ago

Hi, just tested with latest. Please see attached log and conf, was not working, but could be errors with my conf. However, I think there is something wrong with "mapping" values from the mqtt using the previous version, looks like windDir is not accepted, And it looks like I cant have the conversion right, when it comes to wind, its read in m/s and (I think) its showing wrong in the graphs and values. Looks like the windGust maybe reads from windSpeed.. please se old_log. old_log.txt Latest_log.txt weewx_conf.txt

bellrichm commented 5 years ago

@eugen66, First, thanks for your help! Unfortunately, I realized this implementatation will not easily work with wildcard subscriptions, so I will need to redo it. Not sure how yet... In regards to the windDir and windGust, I need to do more research on how WeeWX handles them. But, if it is not too much to ask, could you do another test? In your attached weewx.conf, the payload_type looks to be indented and therefore would not be processed correctly. This won’t fix the wind issues, but should clean up the “not implemented” messages. I’d be interested in the log after this update. Thanks. Rich

eugen66 commented 5 years ago

No problem, I tried , please the the log og new conf. I have done a lot of research on the wind issue and I think there is errors from the RTL-SDR decoding and also in the SDR-Weewx so I need a break :( regards Atle Appreciate your work ;)

tir. 7. mai 2019 kl. 21:45 skrev Rich Bell notifications@github.com:

@eugen66 https://github.com/eugen66, First, thanks for your help! Unfortunately, I realized this implementatation will not easily work with wildcard subscriptions, so I will need to redo it. Not sure how yet... In regards to the windDir and windGust, I need to do more research on how WeeWX handles them. But, if it is not too much to ask, could you do another test? In your attached weewx.conf, the payload_type looks to be indented and therefore would not be processed correctly. This won’t fix the wind issues, but should clean up the “not implemented” messages. I’d be interested in the log after this update. Thanks. Rich

— You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub https://github.com/bellrichm/WeeWX-MQTTSubscribe/issues/18#issuecomment-490228697, or mute the thread https://github.com/notifications/unsubscribe-auth/ACVSGDOLYGXRQ25HPW6K6LDPUHL5PANCNFSM4HJFXW3A .

root@weewx-hyggebu:/home/pi# tail -f /var/log/syslog May 7 22:46:32 weewx-hyggebu weewx[25049]: restx: MQTT: data will be uploaded to mqtt://openhabian:xxx@www.datan.no:1883/ May 7 22:46:32 weewx-hyggebu weewx[25049]: engine: Finished loading service user.mqtt.MQTT May 7 22:46:32 weewx-hyggebu weewx[25049]: engine: Loading service weewx.engine.StdPrint May 7 22:46:32 weewx-hyggebu weewx[25049]: engine: Finished loading service weewx.engine.StdPrint May 7 22:46:32 weewx-hyggebu weewx[25049]: engine: Loading service weewx.engine.StdReport May 7 22:46:32 weewx-hyggebu weewx[25049]: engine: Finished loading service weewx.engine.StdReport May 7 22:46:32 weewx-hyggebu weewx[25049]: engine: Starting up weewx version 3.9.1 May 7 22:46:32 weewx-hyggebu weewx[25049]: engine: Station does not support reading the time May 7 22:46:32 weewx-hyggebu weewx[25049]: engine: Starting main packet loop. May 7 22:46:32 weewx-hyggebu weewx[25049]: manager: Daily summary version is 2.0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:37 weewx-hyggebu weewx[25049]: sdr: MainThread: lines=['{"time" : "2019-05-07 20:46:33", "model" : "HIDEKI Rain sensor", "rc" : 0, "channel" : 4, "battery" : "OK", "rain_mm" : 907.900, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:33", "model" : "HIDEKI Rain sensor", "rc" : 0, "channel" : 4, "battery" : "OK", "rain_mm" : 907.900, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:34", "model" : "HIDEKI Rain sensor", "rc" : 0, "channel" : 4, "battery" : "OK", "rain_mm" : 907.900, "mic" : "CRC"}\n'] May 7 22:46:37 weewx-hyggebu weewx[25049]: sdr: MainThread: packet={'rainBatteryStatus': 0, 'rain_total': 907.9, 'usUnits': 16, 'dateTime': 1557261993} May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 0.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: None, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: sdr: MainThread: packet={'rainBatteryStatus': 0, 'rain_total': 907.9, 'usUnits': 16, 'dateTime': 1557261993} May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261993.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261993, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: sdr: MainThread: packet={'rainBatteryStatus': 0, 'rain_total': 907.9, 'usUnits': 16, 'dateTime': 1557261994} May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261993.000000 1557261994.000000 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:37 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557261994, rain: 0.0, rain_total: 907.9, rainBatteryStatus: 0, usUnits: 16 May 7 22:46:37 weewx-hyggebu weewx[25049]: restx: MQTT: Published record 2019-05-07 22:46:33 CEST (1557261993) May 7 22:46:37 weewx-hyggebu weewx[25049]: restx: MQTT: Published record 2019-05-07 22:46:33 CEST (1557261993) May 7 22:46:38 weewx-hyggebu weewx[25049]: restx: MQTT: Published record 2019-05-07 22:46:34 CEST (1557261994) May 7 22:46:38 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:38 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:40 weewx-hyggebu weewx[25049]: sdr: MainThread: lines=[] May 7 22:46:41 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:41 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:42 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:42 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:44 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:44 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:45 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:47 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:47 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:51 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:51 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: lines=['{"time" : "2019-05-07 20:46:42", "model" : "TFA pool temperature sensor", "id" : 175, "channel" : 1, "temperature_C" : -1.500}\n', '{"time" : "2019-05-07 20:46:43", "model" : "WT450 sensor", "id" : 15, "channel" : 1, "battery" : "OK", "temperature_C" : 1.000, "humidity" : 14, "seq" : 0}\n', '{"time" : "2019-05-07 20:46:43", "model" : "WT450 sensor", "id" : 15, "channel" : 1, "battery" : "OK", "temperature_C" : 1.000, "humidity" : 14, "seq" : 1}\n', '{"time" : "2019-05-07 20:46:43", "model" : "WT450 sensor", "id" : 15, "channel" : 1, "battery" : "OK", "temperature_C" : 1.000, "humidity" : 14, "seq" : 2}\n', '{"time" : "2019-05-07 20:46:45", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:46", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:46", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 0}\n', '{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 2}\n'] May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: parse_json: unknown model TFA pool temperature sensor May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: punt unrecognized line '{"time" : "2019-05-07 20:46:42", "model" : "TFA pool temperature sensor", "id" : 175, "channel" : 1, "temperature_C" : -1.500}#012' May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: unmapped: ['{"time" : "2019-05-07 20:46:43", "model" : "WT450 sensor", "id" : 15, "channel" : 1, "battery" : "OK", "temperature_C" : 1.000, "humidity" : 14, "seq" : 1}\n', '{"time" : "2019-05-07 20:46:43", "model" : "WT450 sensor", "id" : 15, "channel" : 1, "battery" : "OK", "temperature_C" : 1.000, "humidity" : 14, "seq" : 2}\n', '{"time" : "2019-05-07 20:46:45", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:46", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:46", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 0}\n', '{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 2}\n'] ({'sid.15:1.AcuriteWT450Packet': 15, 'battery.15:1.AcuriteWT450Packet': 0, 'humidity.15:1.AcuriteWT450Packet': 14.0, 'temperature.15:1.AcuriteWT450Packet': 1.0, 'dateTime': 1557262003, 'channel.15:1.AcuriteWT450Packet': 1, 'usUnits': 16}) May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: unmapped: ['{"time" : "2019-05-07 20:46:43", "model" : "WT450 sensor", "id" : 15, "channel" : 1, "battery" : "OK", "temperature_C" : 1.000, "humidity" : 14, "seq" : 2}\n', '{"time" : "2019-05-07 20:46:45", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:46", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:46", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 0}\n', '{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 2}\n'] ({'sid.15:1.AcuriteWT450Packet': 15, 'battery.15:1.AcuriteWT450Packet': 0, 'humidity.15:1.AcuriteWT450Packet': 14.0, 'temperature.15:1.AcuriteWT450Packet': 1.0, 'dateTime': 1557262003, 'channel.15:1.AcuriteWT450Packet': 1, 'usUnits': 16}) May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: unmapped: ['{"time" : "2019-05-07 20:46:45", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:46", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:46", "model" : "HIDEKI Wind sensor", "rc" : 5, "channel" : 4, "battery" : "OK", "temperature_C" : -3.500, "wind_speed_mph" : 0.800, "gust_speed_mph" : 0.800, "wind_approach" : 1, "wind_direction" : 315.000, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 0}\n', '{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 2}\n'] ({'sid.15:1.AcuriteWT450Packet': 15, 'battery.15:1.AcuriteWT450Packet': 0, 'humidity.15:1.AcuriteWT450Packet': 14.0, 'temperature.15:1.AcuriteWT450Packet': 1.0, 'dateTime': 1557262003, 'channel.15:1.AcuriteWT450Packet': 1, 'usUnits': 16}) May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: packet={'windBatteryStatus': 0, 'dateTime': 1557262005, 'windDir': 315.0, 'windSpeed': 0.8, 'windGust': 0.8, 'usUnits': 1, 'extraTemp1': -3.5} May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557261994.000000 1557262005.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262005, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: packet={'windBatteryStatus': 0, 'dateTime': 1557262006, 'windDir': 315.0, 'windSpeed': 0.8, 'windGust': 0.8, 'usUnits': 1, 'extraTemp1': -3.5} May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262005.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: packet={'windBatteryStatus': 0, 'dateTime': 1557262006, 'windDir': 315.0, 'windSpeed': 0.8, 'windGust': 0.8, 'usUnits': 1, 'extraTemp1': -3.5} May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262006.000000 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:46:52 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262006, extraTemp1: -3.5, usUnits: 1, windBatteryStatus: 0, windDir: 315.0, windGust: 0.8, windSpeed: 0.8 May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: unmapped: ['{"time" : "2019-05-07 20:46:48", "model" : "WT450 sensor", "id" : 4, "channel" : 3, "battery" : "OK", "temperature_C" : 7.125, "humidity" : 14, "seq" : 2}\n'] ({'humidity.4:3.AcuriteWT450Packet': 14.0, 'temperature.4:3.AcuriteWT450Packet': 7.125, 'dateTime': 1557262008, 'channel.4:3.AcuriteWT450Packet': 3, 'sid.4:3.AcuriteWT450Packet': 4, 'battery.4:3.AcuriteWT450Packet': 0, 'usUnits': 16}) May 7 22:46:52 weewx-hyggebu weewx[25049]: sdr: MainThread: unmapped: [] ({'humidity.4:3.AcuriteWT450Packet': 14.0, 'temperature.4:3.AcuriteWT450Packet': 7.125, 'dateTime': 1557262008, 'channel.4:3.AcuriteWT450Packet': 3, 'sid.4:3.AcuriteWT450Packet': 4, 'battery.4:3.AcuriteWT450Packet': 0, 'usUnits': 16}) May 7 22:46:52 weewx-hyggebu weewx[25049]: restx: MQTT: Published record 2019-05-07 22:46:45 CEST (1557262005) May 7 22:46:52 weewx-hyggebu weewx[25049]: restx: MQTT: Published record 2019-05-07 22:46:46 CEST (1557262006) May 7 22:46:52 weewx-hyggebu weewx[25049]: restx: MQTT: Published record 2019-05-07 22:46:46 CEST (1557262006) May 7 22:46:57 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:57 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:57 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:58 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:46:58 weewx-hyggebu weewx[25049]: sdr: MainThread: lines=['{"time" : "2019-05-07 20:46:54", "model" : "HIDEKI TS04 sensor", "rc" : 12, "channel" : 2, "battery" : "OK", "temperature_C" : 17.100, "humidity" : 40, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:54", "model" : "HIDEKI TS04 sensor", "rc" : 12, "channel" : 2, "battery" : "OK", "temperature_C" : 17.100, "humidity" : 40, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:55", "model" : "HIDEKI TS04 sensor", "rc" : 12, "channel" : 2, "battery" : "OK", "temperature_C" : 17.100, "humidity" : 40, "mic" : "CRC"}\n'] May 7 22:46:58 weewx-hyggebu weewx[25049]: sdr: MainThread: unmapped: ['{"time" : "2019-05-07 20:46:54", "model" : "HIDEKI TS04 sensor", "rc" : 12, "channel" : 2, "battery" : "OK", "temperature_C" : 17.100, "humidity" : 40, "mic" : "CRC"}\n', '{"time" : "2019-05-07 20:46:55", "model" : "HIDEKI TS04 sensor", "rc" : 12, "channel" : 2, "battery" : "OK", "temperature_C" : 17.100, "humidity" : 40, "mic" : "CRC"}\n'] ({'humidity.2:12.HidekiTS04Packet': 40.0, 'battery.2:12.HidekiTS04Packet': 0, 'temperature.2:12.HidekiTS04Packet': 17.1, 'usUnits': 16, 'dateTime': 1557262014}) May 7 22:46:58 weewx-hyggebu weewx[25049]: sdr: MainThread: unmapped: ['{"time" : "2019-05-07 20:46:55", "model" : "HIDEKI TS04 sensor", "rc" : 12, "channel" : 2, "battery" : "OK", "temperature_C" : 17.100, "humidity" : 40, "mic" : "CRC"}\n'] ({'humidity.2:12.HidekiTS04Packet': 40.0, 'battery.2:12.HidekiTS04Packet': 0, 'temperature.2:12.HidekiTS04Packet': 17.1, 'usUnits': 16, 'dateTime': 1557262014}) May 7 22:46:58 weewx-hyggebu weewx[25049]: sdr: MainThread: unmapped: [] ({'humidity.2:12.HidekiTS04Packet': 40.0, 'battery.2:12.HidekiTS04Packet': 0, 'temperature.2:12.HidekiTS04Packet': 17.1, 'usUnits': 16, 'dateTime': 1557262015}) May 7 22:46:58 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:47:00 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:47:02 weewx-hyggebu weewx[25049]: sdr: MainThread: lines=['{"time" : "2019-05-07 20:46:58", "brand" : "OS", "model" : "UV800", "id" : 137, "channel" : 1, "battery" : "OK", "uv" : 0}\n'] May 7 22:47:02 weewx-hyggebu weewx[25049]: sdr: MainThread: packet={'outTempBatteryStatus': 0, 'UV': 0.0, 'usUnits': 16, 'dateTime': 1557262018} May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Processing interval: 1557262006.000000 1557262018.000000 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue size is: 0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Queue was empty May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Packet after update is: dateTime: 1557262018, outTempBatteryStatus: 0, usUnits: 16, UV: 0.0 May 7 22:47:02 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:47:02 weewx-hyggebu weewx[25049]: restx: MQTT: Published record 2019-05-07 22:46:58 CEST (1557262018) May 7 22:47:03 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented May 7 22:47:03 weewx-hyggebu weewx[25049]: MQTTSS: Method 'on_message' not implemented

Units for MQTT payloads without unit value

unit_system = METRIC  # US or 'METRIC' or 'METRICWX'

# The clientid to connect with
clientid = weewx

The topic to subscribe to

# topic = Weather/+

  # The topics to subscribe to
[[topics]]
   [[[Weather/outHumidity]]]
   [[[Weather/outTemp]]]
   [[[Weather/pressure]]]
   [[[Weather/Temperatur_HDC1080]]]
   [[[Weather/Temperature]]]
   [[[Weather/windGust]]]
   [[[Weather/windSpeed]]]
   [[[Weather/windchill]]]
   [[[Weather/WindDir]]]
   [[[Weather/LuxTSL]]]
   [[[Weather/Lux]]]

# The format of the MQTT payload. Currently support 'individual' or 'json'
payload_type = individual
# When True, the full topic (weather/outTemp) is used as the fieldname. When false, the topic
# furthest to the right is used. Only used when payload is 'individual'.
full_topic_fieldname = False 

# Mapping to WeeWX names
[[label_map]]
    outHumidity = outHumidity
    outTemp = inTemp
    pressure = barometer
    Temperatur_HDC1080 = extraTemp2
    Temperature = extraTemp3
    #windGust = windGust
    #windSpeed = windSpeed
    #windchill = windchill
    #WindDir = windDir
    LuxTSL = extraHumid2
    Lux = extraHumid1
# The amount to overlap the start time when processing the MQTT queue
# Only used by the service
overlap = 20

# The binding, loop or archive
# Only used by the service
binding = loop

# The amount of time to wait when the queue of MQTT payload is empty
# Only used by the driver
# wait_before_retry = 2

# Payload in this topic is processed like an archive record
# Only used by the driver
# archive_topic =

###########################################

eugen66 commented 5 years ago

Something went wrong with the attached files so her they are. weewx3.txt log1.txt

bellrichm commented 5 years ago

Thanks for the test. It’s obvious I don’t fully understand how the configuration options work. Sorry about that. The windGust and wind*Dir is definitely something I am doing. I’m going to dig into that and will let you know when I have an update. It may be a bit of time.

bellrichm commented 5 years ago

@eugen66, If you are still interested, the latest update should fix the problem with windDir/windGustDir/windGust.

I think I have a better handle on how configuring subsections work. Subsections need to be at the end. Something like below should work. In the example, some of the options are using default values. If you want to explicitly set them, just make sure it is before the [[topics]] subsection.

I’m curious, are you running in standalone mode? My goal was to use that to make debugging easier, but I know we had some trouble getting it to work. Rich

    
    #The format of the MQTT payload. Currently support 'individual' or 'json'
    payload_type = individual

    # The topics to subscribe to
    [[topics]]
       [[[Weather/outHumidity]]]
       [[[Weather/outTemp]]]
       [[[Weather/pressure]]]
       [[[Weather/Temperatur_HDC1080]]]
       [[[Weather/Temperature]]]
       [[[Weather/windGust]]]
       [[[Weather/windSpeed]]]
       [[[Weather/windchill]]]
       [[[Weather/WindDir]]]
       [[[Weather/LuxTSL]]]
       [[[Weather/Lux]]]

    # The format of the MQTT payload. Currently support 'individual' or 'json'
        payload_type = individual
    # When True, the full topic (weather/outTemp) is used as the fieldname. When false, the topic
    # furthest to the right is used. Only used when payload is 'individual'.
    full_topic_fieldname = False 

    # Mapping to WeeWX names
    [[label_map]]
        outHumidity = outHumidity
        outTemp = inTemp
        pressure = barometer
        Temperatur_HDC1080 = extraTemp2
        Temperature = extraTemp3
        windGust = windGust
        windSpeed = windSpeed
        windchill = windchill
        WindDir = windDir
        LuxTSL = extraHumid2
        Lux = extraHumid1

    # The amount to overlap the start time when processing the MQTT queue
    # Only used by the service
    overlap = 20

    # The binding, loop or archive
    # Only used by the service
    binding = loop

    # The amount of time to wait when the queue of MQTT payload is empty
    # Only used by the driver
    # wait_before_retry = 2

    # Payload in this topic is processed like an archive record
    # Only used by the driver
    # archive_topic =
bellrichm commented 5 years ago

@eugen66, If you are still trying to get this to work, I found this in the WeeWx user guide "The difference between METRICWX, and METRIC is that the former uses mm instead of cm for rain, and m/s instead of km/hr for wind speed." If I understand your comment about windSpeed, it seems that setting units_system to METRICWX should fix it. Rich

eugen66 commented 5 years ago

Hi, thanks for the input 😉, really appreciate it, but I have not had the time to test, will definetly get back to you 😉 Best regards Atle

tir. 14. mai 2019, 19:06 skrev Rich Bell notifications@github.com:

@eugen66 https://github.com/eugen66, If you are still trying to get this to work, I found this in the WeeWx user guide http://www.weewx.com/docs/usersguide.htm#StdConvert "The difference between METRICWX, and METRIC is that the former uses mm instead of cm for rain, and m/s instead of km/hr for wind speed." If I understand your comment about windSpeed, it seems that setting units_system to METRICWX should fix it. Rich

— You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub https://github.com/bellrichm/WeeWX-MQTTSubscribe/issues/18?email_source=notifications&email_token=ACVSGDLVVRFDFFK3WXTZWV3PVLWSXA5CNFSM4HJFXW3KYY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGODVMEP4Y#issuecomment-492324851, or mute the thread https://github.com/notifications/unsubscribe-auth/ACVSGDP2PXMYG5TUVSLVM7DPVLWSXANCNFSM4HJFXW3A .

bellrichm commented 5 years ago

v1.1.0 supports subscribing to multiple topics