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

How to parse non-json/non-keyword data from MQTT? #90

Closed ituri closed 4 years ago

ituri commented 4 years ago

Hi,

I would like to subscribe to a MQTT topic called templiving/sensor/xiaomi_templiving/state. Here's the relevant part from my weewx.conf:

[MQTTSubscribeService]
    # This section is for the MQTTSubscribe service.

    # Turn the service on and off.
    # Default is: true
    # Only used by the service.
    enable = true

    # The MQTT server.
    # Default is localhost.
    host = 192.168.8.10

    # The port to connect to.
    # Default is 1883.
    port = 1883

    # Maximum period in seconds allowed between communications with the broker.
    # Default is 60.
    keepalive = 60

    # username for broker authentication.
    # Default is None.
    username = None

    # password for broker authentication.
    # Default is None.
    password = None

    # The binding, loop or archive.
    # Default is: loop
    # Only used by the service.
    binding = loop

    # The message handler to use
    [[message_callback]]
        # The format of the MQTT payload.
        # Currently support: individual, json, keyword
        # Must be specified.
        type = json

   # The topics to subscribe to.
    [[topics]]
        # Units for MQTT payloads without unit value.
        # Valid values: US, METRIC, METRICWX
        # Default is: US
        unit_system = METRIC

        [[[[systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state]]]]
        name = extraTemp1
        units = degree_C

The topic simply contains the temperature and is not formatted in any way. I get the following error:

Sep 10 17:32:36 raspberrypi weewx[2133]: ERROR user.MQTTSubscribe: (Service) MessageCallbackProvider on_message_json failed with: 'float' object has no attribute 'items'
Sep 10 17:32:36 raspberrypi weewx[2133]: ERROR user.MQTTSubscribe: (Service) **** MessageCallbackProvider Ignoring topic=systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state and payload=b'23.8'

I guess that I have to change the message_callback to a different type but I don't know which one. Can anyone help me out here?

Thanks!

bellrichm commented 4 years ago

Hi, You want to set type = individual. Also, since you have unit_system = METRIC, you should not need units = degree_C. rich

ituri commented 4 years ago

I've done as you said and set type = individual and removed the units-line. When watching the debug log now, I can't see any activity from the plugin.

bellrichm commented 4 years ago

Please set debug = 1, restart WeeWX and post the log here.

ituri commented 4 years ago 
Sep 10 21:25:12 raspberrypi systemd[1]: Starting LSB: weewx weather system...
Sep 10 21:25:13 raspberrypi weewx[9200] INFO __main__: Initializing weewx version 4.1.1
Sep 10 21:25:13 raspberrypi weewx[9200] INFO __main__: Using Python 3.7.3 (default, Jul 25 2020, 13:03:44) #012[GCC 8.3.0]
Sep 10 21:25:13 raspberrypi weewx[9200] INFO __main__: Platform Linux-5.4.51-v7l+-armv7l-with-debian-10.4
Sep 10 21:25:13 raspberrypi weewx[9200] INFO __main__: Locale is 'en_US.UTF-8'
Sep 10 21:25:13 raspberrypi weewx[9200] INFO __main__: PID file is /var/run/weewx.pid
Sep 10 21:25:13 raspberrypi weewx[9205] INFO __main__: Using configuration file /etc/weewx/weewx.conf
Sep 10 21:25:13 raspberrypi weewx[9205] INFO __main__: Debug is 1
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG __main__: Initializing engine
Sep 10 21:25:13 raspberrypi weewx[9205] INFO weewx.engine: Loading station type SDR (user.sdr)
Sep 10 21:25:13 raspberrypi weewx[9189]: Starting weewx weather system: weewx.
Sep 10 21:25:13 raspberrypi systemd[1]: Started LSB: weewx weather system.
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.sdr: driver version is 0.77
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.sdr: sensor map is {'extraTemp1': 'temperature.1:185.NexusTemperaturePacket', 'outBatteryStatus': 'battery.1:185.NexusTemperaturePacket', 'outTemp': 'temperature.239.Bresser5in1Packet', 'outHumidity': 'humidity.239.Bresser5in1Packet', 'windDir': 'wind_dir.239.Bresser5in1Packet', 'rain_total': 'rain_total.239.Bresser5in1Packet', 'windSpeed': 'wind_speed.239.Bresser5in1Packet', 'windGust': 'gust_speed.239.Bresser5in1Packet'}
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.sdr: deltas is {'rain': 'rain_total'}
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.sdr: startup process 'rtl_433 -M utc -f 868300000 -f 433M -H 60 -F json'
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.sdr: start async reader for stdout-thread
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.sdr: start async reader for stderr-thread
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.engine.StdTimeSynch
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.engine.StdTimeSynch
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service user.MQTTSubscribe.MQTTSubscribeService
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) Using weewx version 4.1.1
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) Using Python 3.7.3 (default, Jul 25 2020, 13:03:44) #012[GCC 8.3.0]
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) Platform Linux-5.4.51-v7l+-armv7l-with-debian-10.4
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) Locale is 'en_US.UTF-8'
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Version is 1.6.1
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Log level: 0
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Log debug setting: 1
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Log console: None
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Log file: None
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) service_dict is {'enable': 'true', 'host': '192.168.8.10', 'port': '1883', 'keepalive': '60', 'username': 'None', 'password': 'None', 'binding': 'loop', 'message_callback': {'type': 'individual'}, 'topics': {'unit_system': 'METRIC', 'systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state': {'name': 'extraTemp1'}}}
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) service_dict is {'enable': 'true', 'host': '192.168.8.10', 'port': '1883', 'keepalive': '60', 'username': 'None', 'password': 'None', 'binding': 'loop', 'message_callback': {'type': 'individual'}, 'topics': {'unit_system': 'METRIC', 'systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state': {'name': 'extraTemp1'}}}
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) overlap is 0.0
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager config is {'unit_system': 'METRIC', 'overlap': 0.0, 'systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state': {'name': 'extraTemp1'}}
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager self.subscribed_topics is {'systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state': {'type': 'normal', 'unit_system': 16, 'msg_id_field': None, 'qos': 0, 'use_server_datetime': False, 'ignore_start_time': False, 'ignore_end_time': False, 'adjust_start_time': 0.0, 'adjust_end_time': 0.0, 'datetime_format': None, 'offset_format': None, 'ignore': False, 'max_queue': 2147483647, 'queue': deque([]), 'fields': {}, 'ignore_msg_id_field': []}, '1599765913.206913-windGust-windGustDir-windDir-windSpeed': {'type': 'collector', 'unit_system': 16, 'qos': 0, 'use_server_datetime': False, 'ignore_start_time': False, 'ignore_end_time': False, 'adjust_start_time': 0.0, 'adjust_end_time': 0.0, 'datetime_format': None, 'offset_format': None, 'max_queue': 2147483647, 'queue': deque([])}}
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager self.cached_fields is {}
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) message_callback_provider_name is user.MQTTSubscribe.MessageCallbackProvider
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) clientid is MQTTSubscribe-9130
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) client_session is True
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) host is 192.168.8.10
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) port is 1883
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) keepalive is 60
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) username is None
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) password is set
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Archive topic is None
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) MessageCallbackProvider config is {'type': 'individual'}
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) MessageCallbackProvider self.fields is {}
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) binding is loop
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) archive_field_cache_dict is None
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) Starting loop
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Connected with result code 0
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Connected flags {'session present': 0}
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) Subscribed to systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state has a mid 1 and rc 0
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) Subscribed to 1599765913.206913-windGust-windGustDir-windDir-windSpeed has a mid 2 and rc 0
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Subscribed to topic mid: 1 is size 1 has a QOS of 0
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) MessageCallbackProvider data-> incoming topic: systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state, QOS: 0, retain: 1, payload: b'21.7'
Sep 10 21:25:13 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> incoming systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: state: 21.7
Sep 10 21:25:13 raspberrypi weewx[9205] INFO user.MQTTSubscribe: (Service) Subscribed to topic mid: 2 is size 1 has a QOS of 0
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service user.MQTTSubscribe.MQTTSubscribeService
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service user.bme280.bme
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service user.bme280.bme
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.engine.StdConvert
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.engine: StdConvert target unit is 0x1
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.engine.StdConvert
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.engine.StdCalibrate
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.engine.StdCalibrate
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.engine.StdQC
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.engine.StdQC
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.wxservices.StdWXCalculate
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.manager: Daily summary version is 2.0
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.wxservices: The following values will be calculated: pressure=prefer_hardware, altimeter=prefer_hardware, appTemp=prefer_hardware, barometer=prefer_hardware, beaufort=prefer_hardware, cloudbase=prefer_hardware, dewpoint=prefer_hardware, ET=prefer_hardware, heatindex=prefer_hardware, humidex=prefer_hardware, inDewpoint=prefer_hardware, maxSolarRad=prefer_hardware, rainRate=prefer_hardware, windchill=prefer_hardware, windrun=prefer_hardware
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.wxservices: The following algorithms will be used for calculations: altimeter=aaASOS, maxSolarRad=RS
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.wxservices.StdWXCalculate
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.engine.StdArchive
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.engine: Archive will use data binding wx_binding
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.engine: Record generation will be attempted in 'hardware'
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.engine: Using archive interval of 300 seconds (specified in weewx configuration)
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Use LOOP data in hi/low calculations: 1
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.engine.StdArchive
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.restx.StdStationRegistry
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.restx: StationRegistry: Registration not requested.
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.restx.StdStationRegistry
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.restx.StdWunderground
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.restx: WU essentials: {}
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.restx: Wunderground-PWS: Data for station XXX will be posted
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.restx.StdWunderground
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.restx.StdPWSweather
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.restx: PWSweather: Posting not enabled.
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.restx.StdPWSweather
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.restx.StdCWOP
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.restx: CWOP: Posting not enabled.
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.restx.StdCWOP
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.restx.StdWOW
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.restx: WOW: Posting not enabled.
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.restx.StdWOW
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.restx.StdAWEKAS
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.restx: AWEKAS: Data will be uploaded for user phk
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.restx.StdAWEKAS
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service user.influx.Influx
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.influx: service version is 0.15
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.influx: database is wetter
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.influx: tags None
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.influx: binding is archive
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.manager: Daily summary version is 2.0
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.manager: Daily summary version is 2.0
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.influx: Data will be uploaded to http://192.168.8.10:8086
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service user.influx.Influx
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service user.mqtt.MQTT
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.mqtt: service version is 0.23
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.mqtt: binding to ['archive', 'loop']
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.mqtt: topic is weathersyslinx
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.mqtt: desired unit system is METRIC
Sep 10 21:25:14 raspberrypi weewx[9205] INFO user.mqtt: data will be uploaded to mqtt://test.mosquitto.org:1883
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service user.mqtt.MQTT
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.engine.StdPrint
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.engine.StdPrint
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Loading service weewx.engine.StdReport
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Finished loading service weewx.engine.StdReport
Sep 10 21:25:14 raspberrypi weewx[9205] INFO __main__: Starting up weewx version 4.1.1
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.engine: Station does not support reading the time
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.engine: Using binding 'wx_binding' to database 'weewx.sdb'
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.manager: Starting backfill of daily summaries
Sep 10 21:25:14 raspberrypi weewx[9205] INFO weewx.engine: Starting main packet loop.
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.manager: Daily summary version is 2.0
Sep 10 21:25:14 raspberrypi weewx[9205] DEBUG weewx.manager: Daily summary version is 2.0
Sep 10 21:25:17 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:25:23 raspberrypi weewx[9205] DEBUG user.sdr: lines=['{"time" : "2020-09-10 19:25:19", "model" : "Bresser-5in1", "id" : 239, "battery_ok" : 1, "temperature_C" : 14.700, "humidity" : 68, "wind_max_m_s" : 0.000, "wind_avg_m_s" : 0.000, "wind_dir_deg" : 337.500, "rain_mm" : 15.200, "mic" : "CHECKSUM"}\n']
Sep 10 21:25:23 raspberrypi weewx[9205] DEBUG user.sdr: packet={'outTemp': 14.7, 'outHumidity': 68.0, 'windDir': 337.5, 'rain_total': 15.2, 'windSpeed': 0.0, 'windGust': 0.0, 'dateTime': 1599765919, 'usUnits': 17}
Sep 10 21:25:23 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> outgoing systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: dateTime: 1599765913.2234466, state: 21.7, usUnits: 16
Sep 10 21:25:23 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> outgoing accumulated systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: dateTime: 1599765919.0, state: 21.7, usUnits: 17
Sep 10 21:25:23 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) data-> final packet is 2020-09-10 21:25:19 CEST (1599765919): dateTime: 1599765919.0, outHumidity: 68.0, outTemp: 14.7, rain: None, rain_total: 15.2, state: 21.7, usUnits: 17, windDir: 337.5, windGust: 0.0, windSpeed: 0.0
Sep 10 21:25:23 raspberrypi weewx[9205] INFO weewx.restx: MQTT: Published record 2020-09-10 21:25:19 CEST (1599765919)
Sep 10 21:25:26 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:25:29 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:25:34 raspberrypi weewx[9205] DEBUG user.sdr: lines=['{"time" : "2020-09-10 19:25:31", "model" : "Bresser-5in1", "id" : 239, "battery_ok" : 1, "temperature_C" : 14.700, "humidity" : 68, "wind_max_m_s" : 0.000, "wind_avg_m_s" : 0.000, "wind_dir_deg" : 337.500, "rain_mm" : 15.200, "mic" : "CHECKSUM"}\n']
Sep 10 21:25:34 raspberrypi weewx[9205] DEBUG user.sdr: packet={'outTemp': 14.7, 'outHumidity': 68.0, 'windDir': 337.5, 'rain_total': 15.2, 'windSpeed': 0.0, 'windGust': 0.0, 'dateTime': 1599765931, 'usUnits': 17}
Sep 10 21:25:34 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) data-> final packet is 2020-09-10 21:25:31 CEST (1599765931): dateTime: 1599765931, outHumidity: 68.0, outTemp: 14.7, rain: 0.0, rain_total: 15.2, usUnits: 17, windDir: 337.5, windGust: 0.0, windSpeed: 0.0
Sep 10 21:25:35 raspberrypi weewx[9205] INFO weewx.restx: MQTT: Published record 2020-09-10 21:25:31 CEST (1599765931)
Sep 10 21:25:37 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:25:40 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:25:42 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) MessageCallbackProvider data-> incoming topic: systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state, QOS: 0, retain: 0, payload: b'21.7'
Sep 10 21:25:42 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> incoming systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: state: 21.7
Sep 10 21:25:43 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:25:47 raspberrypi weewx[9205] DEBUG user.sdr: lines=['{"time" : "2020-09-10 19:25:43", "model" : "Efergy-e2CT", "id" : 0, "battery_ok" : 0, "current" : 0.000, "interval" : 6, "learn" : "NO", "mic" : "CHECKSUM"}\n', '{"time" : "2020-09-10 19:25:43", "model" : "Bresser-5in1", "id" : 239, "battery_ok" : 1, "temperature_C" : 14.700, "humidity" : 68, "wind_max_m_s" : 0.000, "wind_avg_m_s" : 0.000, "wind_dir_deg" : 337.500, "rain_mm" : 15.200, "mic" : "CHECKSUM"}\n']
Sep 10 21:25:47 raspberrypi weewx[9205] DEBUG user.sdr: parse_json: unknown model Efergy-e2CT
Sep 10 21:25:47 raspberrypi weewx[9205] DEBUG user.sdr: punt unrecognized line '{"time" : "2020-09-10 19:25:43", "model" : "Efergy-e2CT", "id" : 0, "battery_ok" : 0, "current" : 0.000, "interval" : 6, "learn" : "NO", "mic" : "CHECKSUM"}#012'
Sep 10 21:25:47 raspberrypi weewx[9205] DEBUG user.sdr: packet={'outTemp': 14.7, 'outHumidity': 68.0, 'windDir': 337.5, 'rain_total': 15.2, 'windSpeed': 0.0, 'windGust': 0.0, 'dateTime': 1599765943, 'usUnits': 17}
Sep 10 21:25:47 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> outgoing systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: dateTime: 1599765942.3434925, state: 21.7, usUnits: 16
Sep 10 21:25:47 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> outgoing accumulated systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: dateTime: 1599765943.0, state: 21.7, usUnits: 17
Sep 10 21:25:47 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) data-> final packet is 2020-09-10 21:25:43 CEST (1599765943): dateTime: 1599765943.0, outHumidity: 68.0, outTemp: 14.7, rain: 0.0, rain_total: 15.2, state: 21.7, usUnits: 17, windDir: 337.5, windGust: 0.0, windSpeed: 0.0
Sep 10 21:25:47 raspberrypi weewx[9205] INFO weewx.restx: MQTT: Published record 2020-09-10 21:25:43 CEST (1599765943)
Sep 10 21:25:49 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) MessageCallbackProvider data-> incoming topic: systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state, QOS: 0, retain: 0, payload: b'21.7'
Sep 10 21:25:49 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> incoming systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: state: 21.7
Sep 10 21:25:50 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:25:53 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:25:58 raspberrypi weewx[9205] DEBUG user.sdr: lines=['{"time" : "2020-09-10 19:25:55", "model" : "Bresser-5in1", "id" : 239, "battery_ok" : 1, "temperature_C" : 14.700, "humidity" : 67, "wind_max_m_s" : 0.000, "wind_avg_m_s" : 0.000, "wind_dir_deg" : 337.500, "rain_mm" : 15.200, "mic" : "CHECKSUM"}\n']
Sep 10 21:25:58 raspberrypi weewx[9205] DEBUG user.sdr: packet={'outTemp': 14.7, 'outHumidity': 67.0, 'windDir': 337.5, 'rain_total': 15.2, 'windSpeed': 0.0, 'windGust': 0.0, 'dateTime': 1599765955, 'usUnits': 17}
Sep 10 21:25:58 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> outgoing systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: dateTime: 1599765949.92181, state: 21.7, usUnits: 16
Sep 10 21:25:58 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> outgoing accumulated systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: dateTime: 1599765955.0, state: 21.7, usUnits: 17
Sep 10 21:25:58 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) data-> final packet is 2020-09-10 21:25:55 CEST (1599765955): dateTime: 1599765955.0, outHumidity: 67.0, outTemp: 14.7, rain: 0.0, rain_total: 15.2, state: 21.7, usUnits: 17, windDir: 337.5, windGust: 0.0, windSpeed: 0.0
Sep 10 21:25:59 raspberrypi weewx[9205] INFO weewx.restx: MQTT: Published record 2020-09-10 21:25:55 CEST (1599765955)
Sep 10 21:26:01 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:26:04 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:26:07 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:26:11 raspberrypi weewx[9205] DEBUG user.sdr: lines=['{"time" : "2020-09-10 19:26:07", "model" : "Bresser-5in1", "id" : 239, "battery_ok" : 1, "temperature_C" : 14.700, "humidity" : 67, "wind_max_m_s" : 0.000, "wind_avg_m_s" : 0.000, "wind_dir_deg" : 337.500, "rain_mm" : 15.200, "mic" : "CHECKSUM"}\n']
Sep 10 21:26:11 raspberrypi weewx[9205] DEBUG user.sdr: packet={'outTemp': 14.7, 'outHumidity': 67.0, 'windDir': 337.5, 'rain_total': 15.2, 'windSpeed': 0.0, 'windGust': 0.0, 'dateTime': 1599765967, 'usUnits': 17}
Sep 10 21:26:11 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) data-> final packet is 2020-09-10 21:26:07 CEST (1599765967): dateTime: 1599765967, outHumidity: 67.0, outTemp: 14.7, rain: 0.0, rain_total: 15.2, usUnits: 17, windDir: 337.5, windGust: 0.0, windSpeed: 0.0
Sep 10 21:26:11 raspberrypi weewx[9205] INFO weewx.restx: MQTT: Published record 2020-09-10 21:26:07 CEST (1599765967)
Sep 10 21:26:14 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:26:17 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
Sep 10 21:26:20 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) MessageCallbackProvider data-> incoming topic: systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state, QOS: 0, retain: 0, payload: b'21.7'
Sep 10 21:26:20 raspberrypi weewx[9205] DEBUG user.MQTTSubscribe: (Service) TopicManager data-> incoming systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state: state: 21.7
Sep 10 21:26:20 raspberrypi weewx[9205] DEBUG user.sdr: lines=[]
bellrichm commented 4 years ago

Ok, I think you need to add use_topic_as_fieldname = True

    [[topics]]
        # Units for MQTT payloads without unit value.
        # Valid values: US, METRIC, METRICWX
        # Default is: US
        unit_system = METRIC

        use_topic_as_fieldname = True

        [[[[systempwohnzimmer/sensor/xiaomi_wohnzimmer_temperature/state]]]]
        name = extraTemp1
        units = degree_C
ituri commented 4 years ago

That's it! All working as expected now. Thank you!

bellrichm commented 4 years ago

Great! Thanks for letting me know!