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 [email protected].
To view this discussion on the web visit
https://groups.google.com/d/msgid/weewx-user/a2d58678-a9d4-42f9-89b9-248e7a95aee1n%40googlegroups.com.
