Thank you for your assistance. Support is great here. bell...@gmail.com schrieb am Mittwoch, 10. Februar 2021 um 22:45:36 UTC+1:
> Unfortunately the message format doesn’t matter. The data is arriving > after the interval has been processed. From a MQTTSubscribe perspective, > the only thing I can think to do is, increase the interval... > > On Wednesday, 10 February 2021 at 13:49:45 UTC-5 kk44...@gmail.com wrote: > >> Ok, so it's no bug, but desired behavior. I was not aware of a thing >> called "archive_delay". There is no such option in my weewx.conf, and I did >> not know that it exists. >> >> In fact, the data received by MQTT are for the passed interval, but they >> come later, sometimes up to 1.5 minutes after. Would it be better to use >> the JSON data, that include a timestamp? >> >> bell...@gmail.com schrieb am Samstag, 6. Februar 2021 um 23:01:08 UTC+1: >> >>> Thanks for the log and configuration information. After working through >>> it and WeeWX, I believe that everything is working as designed. >>> From the log, I will assume your archive_interval is 300 and >>> archive_delay is 15. >>> >>> During this time of the log, MQTTSubscribe is chugging along, but >>> nothing has been received and therefore the loop packet is ‘passed through’. >>> Feb 6 15:44:53 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:44:53 CET (1612622693): >>> dateTime: 1612622693, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 59, >>> windSpeed: 9.0 >>> Feb 6 15:44:56 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:44:56 CET (1612622696): >>> dateTime: 1612622696, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 53, >>> windSpeed: 11.0 >>> Feb 6 15:44:58 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:44:58 CET (1612622698): >>> dateTime: 1612622698, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 65, >>> windSpeed: 12.0 >>> >>> We have now passed the end of archive interval (5 minutes). WeeWX ‘puts >>> aside’ the accumulated loop data for this interval (15:40 to 15:45) and >>> starts accumulating data for the 15:45 to 15:50 archive interval. >>> Feb 6 15:45:01 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:45:01 CET (1612622701): >>> dateTime: 1612622701, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 63, >>> windSpeed: 12.0 >>> Feb 6 15:45:03 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:45:03 CET (1612622703): >>> dateTime: 1612622703, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 61, >>> windSpeed: 12.0 >>> Feb 6 15:45:04 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:45:03 CET (1612622703): >>> altimeter: 29.905, dateTime: 1612622703, dewpoint: 29.2, heatindex: 31.1, >>> inDewpoint: 45.5, inHumidity: 42.4, inTemp: 69.3, outHumidity: 92.4, >>> outTemp: 31.1, pressure: 29.306, radiation: 7, rain: 0.0, rainRate: 0.0, >>> signal1: 0, txBatteryStatus: 0, usUnits: 1, UV: 0.0, windchill: 22.7, >>> windDir: 61, windDir10: 69, windGust: 16.0, windGustDir: 44, windSpeed: >>> 12.0, windSpeed10: 9.87 >>> Feb 6 15:45:06 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:45:06 CET (1612622706): >>> dateTime: 1612622706, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 74, >>> windSpeed: 12.0 >>> Feb 6 15:45:08 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:45:08 CET (1612622708): >>> dateTime: 1612622708, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 74, >>> windSpeed: 12.0 >>> Feb 6 15:45:11 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:45:11 CET (1612622711): >>> dateTime: 1612622711, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 64, >>> windSpeed: 12.0 >>> >>> Incoming MQTT data is received and queued up. >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) MessageCallbackProvider data-> incoming topic: pegel/566055/Q, >>> QOS: 0, retain: 0, payload: b'41.3' >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> incoming pegel/566055/Q: Q566055v: 41.3 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) MessageCallbackProvider data-> incoming topic: pegel/566055/W_cm, >>> QOS: 0, retain: 0, payload: b'156.0' >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> incoming pegel/566055/W_cm: W566055v: 156.0 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) MessageCallbackProvider data-> incoming topic: pegel/567470/Q, >>> QOS: 0, retain: 0, payload: b'87.4' >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> incoming pegel/567470/Q: Q567470v: 87.4 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) MessageCallbackProvider data-> incoming topic: pegel/567470/W_cm, >>> QOS: 0, retain: 0, payload: b'153.0' >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> incoming pegel/567470/W_cm: W567470v: 153.0 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> outgoing pegel/566055/W_cm: dateTime: >>> 1612622713.6558828, usUnits: 16, W566055v: 156.0 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> outgoing accumulated pegel/566055/W_cm: >>> dateTime: 1612622713, usUnits: 1, W566055v: 5.118110236220472 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> outgoing pegel/566055/Q: dateTime: >>> 1612622713.6551414, Q566055v: 41.3, usUnits: 16 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> outgoing accumulated pegel/566055/Q: >>> dateTime: 1612622713, Q566055v: 1458.49711, usUnits: 1 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> outgoing pegel/567470/W_cm: dateTime: >>> 1612622713.6563249, usUnits: 16, W567470v: 153.0 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> outgoing accumulated pegel/567470/W_cm: >>> dateTime: 1612622713, usUnits: 1, W567470v: 5.019685039370079 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> outgoing pegel/567470/Q: dateTime: >>> 1612622713.6561482, Q567470v: 87.4, usUnits: 16 >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) TopicManager data-> outgoing accumulated pegel/567470/Q: >>> dateTime: 1612622713, Q567470v: 3086.50478, usUnits: 1 >>> >>> Loop packet is updated with MQTT data and will be accumulated by WeeWX >>> with other loop packet for the 15:45 to 15:50 interval. >>> Feb 6 15:45:13 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:45:13 CET (1612622713): >>> dateTime: 1612622713, Q566055v: 1458.49711, Q567470v: 3086.50478, rain: >>> 0.0, rainRate: 0.0, usUnits: 1, W566055v: 5.118110236220472, W567470v: >>> 5.019685039370079, windDir: 71, windSpeed: 9.0 >>> Feb 6 15:45:16 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final packet is 2021-02-06 15:45:16 CET (1612622716): >>> dateTime: 1612622716, rain: 0.0, rainRate: 0.0, usUnits: 1, windDir: 73, >>> windSpeed: 10.0 >>> >>> The archive_delay has passed so WeeWX creates the archive record for the >>> interval from 15:40 to 15:45. Since no MQTT data was received between 15:40 >>> an 15:45 it is retrieved from the cache. >>> Feb 6 15:45:16 LokalWiki weewx[153466] DEBUG user.MQTTSubscribe: >>> (Service) data-> final record is 2021-02-06 15:45:00 CET (1612622700): >>> altimeter: 29.905125, appTemp: 21.328939698162554, barometer: >>> 29.940951730031646, beaufort: 3.0833333333333335, cloudbase: >>> 1011.3178296862307, dateTime: 1612622700, dewpoint: 29.15000000000001, >>> heatindex: 31.141666666666676, humidex: 31.141666666666676, inDewpoint: >>> 45.56666666666667, inHumidity: 42.38333333333332, inTemp: >>> 69.38333333333333, interval: 5.0, maxSolarRad: 79.66887450173137, >>> outHumidity: 92.25, outTemp: 31.141666666666676, pressure: >>> 29.30612499999999, Q566055v: 1522.06357, Q567470v: 3128.88242, radiation: >>> 11.041666666666666, rain: 0.0, rainRate: 0.0, signal1: 0.0, >>> txBatteryStatus: 0.0, usUnits: 1, UV: 0.0, W566055v: 5.216535433070866, >>> W567470v: 5.05249343832021, windchill: 22.825000000000003, windDir: >>> 65.28102854956737, windDir10: 69.79166666666667, windGust: 21.0, >>> windGustDir: 70, windSpeed: 10.73611111111111, windSpeed10: 9.68 >>> >>> And the processing continues. >>> >>> >>> On Saturday, 6 February 2021 at 11:10:37 UTC-5 kk44...@gmail.com wrote: >>> >>>> I saved the requested data to the issue on github. >>>> >>>> bell...@gmail.com schrieb am Freitag, 5. Februar 2021 um 16:04:55 >>>> UTC+1: >>>> >>>>> And your MQTTSubscribe config settings, with any sensitive information >>>>> removed. >>>>> >>>>> On Friday, 5 February 2021 at 10:02:20 UTC-5 bell...@gmail.com wrote: >>>>> >>>>>> Interesting. I might have to give you a version with extra logging. >>>>>> In the meantime, could you attach the log. >>>>>> Thanks. -rich >>>>>> >>>>>> On Friday, 5 February 2021 at 09:25:20 UTC-5 kk44...@gmail.com wrote: >>>>>> >>>>>>> There is an issue I observed: >>>>>>> >>>>>>> If the MQTT message is received some little seconds after the >>>>>>> archive interval ends, then the loop record shows the new received >>>>>>> value, >>>>>>> but the archive record shows the old value from the previous interval. >>>>>>> >>>>>>> example: archive interval ends at 15:00:00. MQTT message is received >>>>>>> at 15:00:10. loop record is sent at 15:00:14. archive record is sent at >>>>>>> 15:00:18 (with dateTime set to 15:00:00). >>>>>>> >>>>>>> vince schrieb am Donnerstag, 4. Februar 2021 um 21:34:36 UTC+1: >>>>>>> >>>>>>>> On Thursday, February 4, 2021 at 11:50:29 AM UTC-8 >>>>>>>> kk44...@gmail.com wrote: >>>>>>>> >>>>>>>>> As I did not really know how to update an extension, >>>>>>>>> >>>>>>>> >>>>>>>> Just install the new one. >>>>>>>> >>>>>>>> >>>>>>> -- 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/cad63f7e-b650-4dfd-a596-b6f192b7e0d5n%40googlegroups.com.
