The use_topic_as_fieldname option worked. (Nevertheless, I find it confusing to set the option to "true" to _not_ using the topic as field name in WeeWX.)
Unfortunately it does not cache. If I see the value for one archive interval, it is gone for the next. It shows the parameter name enclosed in question marks then, only. bell...@gmail.com schrieb am Samstag, 30. Januar 2021 um 22:39:47 UTC+1: > The subscription to the ‘wind’ topic is just some code that needs to be > cleaned up. Tracking via #119 > <https://github.com/bellrichm/WeeWX-MQTTSubscribe/issues/119>. > > You also need the ‘use_topic_as_fieldname = True’ option. Additional > information is here > <https://github.com/bellrichm/WeeWX-MQTTSubscribe/wiki/Configuring-additional-options#use_topic_as_fieldname>. > > So it would look something like this. > [[topics]] > unit_system=METRIC > use_server_datatime=True > ignore_start_time=True > ignore_end_time=True > use_topic_as_fieldname = True > [[[pegel/567470/W_cm]]] > name=W567470v > conversion_type=float > expires_after=4000 > > I think “archive_field_cache_dict is None" is some errant logging. The > cache is at the archive record level, not the loop. So, you need to wait > for at least one archive record that has no loop packets with the data (and > of course a previous archive record had to have the value, cache can’t have > expired, etc). On the second archive record, there should be some logging > about updating the archive record. > > On Saturday, 30 January 2021 at 11:48:11 UTC-5 kk44...@gmail.com wrote: > >> I want to receive data from MQTT, I tried lots of options by now, but to >> no success. >> >> Special: Data are published to MQTT once in a quarter of an hour, only. >> >> When data is published through MQTT and received by the MQTTSubscribe >> service, the first loop packet after that contains the data. So I guess the >> configuration is not completely wrong. >> >> But subsequent loop records do not. >> >> There seems to be noch caching. >> >> I see in the log: "archive_field_cache_dict is None". Maybe that has >> some importance. I did not find an option to set it. >> >> And it ignores the name I set for the field. >> >> Additionally I see something "winddir-windgust" in the log. I did not >> subscribe to such messages. >> >> weewx.conf contains: >> >> [[topics]] >> unit_system=METRIC >> use_server_datatime=True >> ignore_start_time=True >> ignore_end_time=True >> [[[pegel/567470/W_cm]]] >> name=W567470v >> conversion_type=float >> expires_after=4000 >> etc. >> >> The log says: >> >> Jan 30 17:08:02 LokalWiki weewx[1004756] DEBUG user.MQTTSubscribe: >> (Service) TopicManager data-> outgoing accumulated pegel/567470/W_cm: >> dateTime: 1612022883, usUnits: 1, W_cm: 130.0 >> >> Jan 30 17:08:02 LokalWiki weewx[1004756] DEBUG user.MQTTSubscribe: >> (Service) data-> final packet is 2021-01-30 17:08:03 CET (1612022883): >> dateTime: 1612022883, Q: 62.6, rain: 0.0, rainRate: 0.0, usUnits: 1, W_cm: >> 130.0, windDir: 46, windSpeed: 2.0 >> Jan 30 17:08:05 LokalWiki weewx[1004756] DEBUG user.MQTTSubscribe: >> (Service) data-> final packet is 2021-01-30 17:08:05 CET (1612022885): >> dateTime: 1612022885, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 46, >> windSpeed: 2.0 >> >> If I look to the start section of the log it says (tried again some >> minutes later): >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Using weewx version 4.2.0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Using Python 3.8.5 (default, Jul 28 2020, 12:59:40) #012[GCC >> 9.3.0] >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Platform Linux-5.4.0-60-generic-x86_64-with-glibc2.29 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Locale is 'de_DE.UTF-8' >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Version is 1.6.2 >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Log level: 10 >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Log debug setting: 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Log console: False >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Log file: None >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) sanitized configuration removed ['password'] >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSUBscriber sanitized_service_dict is {'host': 'xxxxxxxxx', >> 'log': 'True', 'username': 'pegel', 'enable': 'True', 'message_callback': >> {'type': 'individual'}, 'logging_level': 'DEBUG', 'binding': 'loop', >> 'keepalive': '60', 'port': '1883', 'topics': {'unit_system': 'METRIC', >> 'use_server_datatime': 'True', 'ignore_start_time': 'True', >> 'ignore_end_time': 'True', 'pegel/566055/W_cm': {'name': 'W566055v', >> 'conversion_type': 'float', 'expires_after': '4000'}, 'pegel/566055/Q': >> {'name': 'Q566055v', 'conversion_type': 'float', 'expires_after': '4000'}, >> 'pegel/567470/W_cm': {'name': 'W567470v', 'conversion_type': 'float', >> 'expires_after': '4000'}, 'pegel/567470/Q': {'name': 'Q567470v', >> 'conversion_type': 'float', 'expires_after': '4000'}}} >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) overlap is 0.0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) TopicManager self.subscribed_topics is {'pegel/566055/W_cm': >> {'type': 'normal', 'unit_system': 16, 'msg_id_field': None, 'qos': 0, >> 'use_server_datetime': False, 'ignore_start_time': True, 'ignore_end_time': >> True, 'adjust_start_time': 1.0, 'adjust_end_time': 0.0, 'datetime_format': >> None, 'offset_format': None, 'ignore': False, 'max_queue': >> 9223372036854775807, 'queue': deque([]), 'fields': {}, >> 'ignore_msg_id_field': []}, 'pegel/566055/Q': {'type': 'normal', >> 'unit_system': 16, 'msg_id_field': None, 'qos': 0, 'use_server_datetime': >> False, 'ignore_start_time': True, 'ignore_end_time': True, >> 'adjust_start_time': 1.0, 'adjust_end_time': 0.0, 'datetime_format': None, >> 'offset_format': None, 'ignore': False, 'max_queue': 9223372036854775807, >> 'queue': deque([]), 'fields': {}, 'ignore_msg_id_field': []}, >> 'pegel/567470/W_cm': {'type': 'normal', 'unit_system': 16, 'msg_id_field': >> None, 'qos': 0, 'use_server_datetime': False, 'ignore_start_time': True, >> 'ignore_end_time': True, 'adjust_start_time': 1.0, 'adjust_end_time': 0.0, >> 'datetime_format': None, 'offset_format': None, 'ignore': False, >> 'max_queue': 9223372036854775807, 'queue': deque([]), 'fields': {}, >> 'ignore_msg_id_field': []}, 'pegel/567470/Q': {'type': 'normal', >> 'unit_system': 16, 'msg_id_field': None, 'qos': 0, 'use_server_datetime': >> False, 'ignore_start_time': True, 'ignore_end_time': True, >> 'adjust_start_time': 1.0, 'adjust_end_time': 0.0, 'datetime_format': None, >> 'offset_format': None, 'ignore': False, 'max_queue': 9223372036854775807, >> 'queue': deque([]), 'fields': {}, 'ignore_msg_id_field': []}, >> '1612024338.424195-windGust-windGustDir-windDir-windSpeed': {'type': >> 'collector', 'unit_system': 16, 'qos': 0, 'use_server_datetime': False, >> 'ignore_start_time': True, 'ignore_end_time': True, 'adjust_start_time': >> 1.0, 'adjust_end_time': 0.0, 'datetime_format': None, 'offset_format': >> None, 'max_queue': 9223372036854775807, 'queue': deque([])}} >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) TopicManager self.cached_fields is {} >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) message_callback_provider_name is >> user.MQTTSubscribe.MessageCallbackProvider >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) clientid is MQTTSubscribe-7610 >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) client_session is True >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) host is xxxxxxxxxx >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) port is 1883 >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) keepalive is 60 >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) username is pegel >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) password is set >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Archive topic is None >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MessageCallbackProvider self.fields is {} >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Sending CONNECT (u1, p1, wr0, wq0, wf0, c1, >> k60) client_id=b'MQTTSubscribe-7610' >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) binding is loop >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) archive_field_cache_dict is None >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Starting loop >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Received CONNACK (0, 0) >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Connected with result code 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Connected flags {'session present': 0} >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Sending SUBSCRIBE (d0, m1) >> [(b'pegel/566055/W_cm', 0)] >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Subscribing to pegel/566055/W_cm has a mid 1 and rc 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Sending SUBSCRIBE (d0, m2) >> [(b'pegel/566055/Q', 0)] >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Subscribing to pegel/566055/Q has a mid 2 and rc 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Sending SUBSCRIBE (d0, m3) >> [(b'pegel/567470/W_cm', 0)] >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Subscribing to pegel/567470/W_cm has a mid 3 and rc 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Sending SUBSCRIBE (d0, m4) >> [(b'pegel/567470/Q', 0)] >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Subscribing to pegel/567470/Q has a mid 4 and rc 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Sending SUBSCRIBE (d0, m5) >> [(b'1612024338.424195-windGust-windGustDir-windDir-windSpeed', 0)] >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) Subscribing to >> 1612024338.424195-windGust-windGustDir-windDir-windSpeed has a mid 5 and rc >> 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Received SUBACK >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Subscribed to mid: 1 is size 1 has a QOS of 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Received SUBACK >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Subscribed to mid: 2 is size 1 has a QOS of 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Received SUBACK >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Subscribed to mid: 3 is size 1 has a QOS of 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Received SUBACK >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Subscribed to mid: 4 is size 1 has a QOS of 0 >> Jan 30 17:32:18 LokalWiki weewx[1005876] DEBUG user.MQTTSubscribe: >> (Service) MQTTSubscribe MQTT: Received SUBACK >> Jan 30 17:32:18 LokalWiki weewx[1005876] INFO user.MQTTSubscribe: >> (Service) Subscribed to mid: 5 is size 1 has a QOS of 0 >> >> -- 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 weewx-user+unsubscr...@googlegroups.com. To view this discussion on the web visit https://groups.google.com/d/msgid/weewx-user/36831403-2759-47e5-bb42-7312acf7145an%40googlegroups.com.