I am running the current version from github. Here is my configuration:
# Options for extension 'MQTTSubscribe'
[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.1.6
# 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
# 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 = US
[[[sensor/living_room/TH]]]
#[[[SECOND/REPLACE_ME]]]
I am subscribed to one topic. Here is the JSON payload:
{"dateTime":1561139832.0,"inTemp":70.9,"inHumidity":53.3}
I noticed that MQTTSubscribe is converting the temp to Celsius when it
appends the loop data. Is that normal? The skin displayed data is
correct.
I contacted WeatherFlow about the out of order timestamps and the response
was that the WeatherFlow hub could back fill buffered data with older
timestamps. Weewx seems to be digesting them OK. I then tried some
experiments. I disabled the MQTT sensor topic in the MQTT broker acl file
and restarted the broker and Weewx. The out of order data from the
weatherflowudp driver eventually showed up and MQTTSubscribe caused weewx
to exit without any subscribed MQTT data. I then disabled MQTTSubscribe in
weewx.conf and restarted Weewx. It has been running all night without
issue or data gaps.
I think ignoring the out of order driver data would solve the problem.
Weewx seems to be digesting the out of order data OK.
-Patrick
On Thursday, June 20, 2019 at 11:32:30 AM UTC-7, Patrick Mendiuk wrote:
>
> I am trying to setup Weewx 3.9.1 with WeatherflowUDP, MQTTSubscribe, MQTT
> and the Belchertown 1.0 skin. The platform is Ubuntu 18.04 LTS running on
> an Atom D2700 with 4G RAM and 256G OCZ SSD. The MQTT Mosquitto broker is
> running on the same machine.
>
> Previously, I was running Weewx, WeatherflowUDP and MQTT for 2 or 3
> months. I occasionally would have small gaps in data, but weewx would
> continue to run. A couple of days ago I installed MQTTSubscribe to add
> some indoor data from a Sonoff TH10 flashed with Tasmota. I have the
> Tasmota publishing temp and humidity once a minute.
>
> Weewx has been stopping due to time stamp error with MQTTSubscribe. I am
> wondering if the small gaps in the database I was observing previously is
> due to this out of order data just being ignored prior to installing
> MQTTSubscribe?
>
> Jun 20 07:48:02 MITX-6930 weewx[8675]: engine: Main loop exiting. Shutting
>> engine down.
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: engine: Shutting down StdReport
>> thread
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: engine: Caught unrecoverable
>> exception in engine:
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** start time (1561042080)
>> is greater than stop time (1561042079)
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** Traceback (most recent
>> call last):
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 890, in main
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** engine.run()
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 191, in run
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: ****
>> self.dispatchEvent(weewx.Event(weewx.NEW_LOOP_PACKET, packet=packet))
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 224, in dispatchEvent
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** callback(event)
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 609, in new_loop_packet
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** target_data =
>> self.subscriber.get_accumulated_data(topic, start_ts, self.end_ts,
>> event.packet['usUnits'])
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 529, in get_accumulated_data
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** return
>> self.manager.get_accumulated_data(topic, start_ts, end_ts, units)
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 277, in get_accumulated_data
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** accumulator =
>> weewx.accum.Accum(weeutil.weeutil.TimeSpan(start_ts, end_ts))
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/weeutil/weeutil.py", line 256, in __new__
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** raise
>> ValueError("start time (%d) is greater than stop time (%d)" % (args[0],
>> args[1]))
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** ValueError: start time
>> (1561042080) is greater than stop time (1561042079)
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** Exiting.
>
>
> Jun 20 09:32:42 MITX-6930 weewx[14061]: MQTTSubscribeService: Packet after
>> update is: 2019-06-20 09:32:39 PDT (1561048359) dateTime: 1561048359,
>> usUnits: 17, windDir: 0, windSpeed: 0.0
>> Jun 20 09:32:42 MITX-6930 weewx[14061]: restx: MQTT: Published record
>> 2019-06-20 09:32:39 PDT (1561048359)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Packet
>> prior to update is: 2019-06-20 09:32:42 PDT (1561048362) dateTime:
>> 1561048362, usUnits: 17, windDir: 0, windSpeed: 0.0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Processing
>> interval: 1561048359.000000 1561048362.000000
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribe: TopicManager queue
>> size is: 0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Queue was
>> empty
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Packet
>> after update is: 2019-06-20 09:32:42 PDT (1561048362) dateTime: 1561048362,
>> usUnits: 17, windDir: 0, windSpeed: 0.0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: restx: MQTT: Published record
>> 2019-06-20 09:32:42 PDT (1561048362)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Packet
>> prior to update is: 2019-06-20 09:32:17 PDT (1561048337) dateTime:
>> 1561048337, illuminance: 40134, precipitationType: 0, radiation: 334, rain:
>> 0.0, skyBatteryVoltage: 3.37, usUnits: 17, UV: 3.77, windBatteryStatus:
>> 3.37, windLull: 0.0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Processing
>> interval: 1561048362.000000 1561048337.000000
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: engine: Main loop exiting.
>> Shutting engine down.
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: engine: Shutting down StdReport
>> thread
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: engine: StdReport thread has been
>> terminated
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: restx: Shut down MQTT thread.
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: restx: Shut down Wunderground-RF
>> thread.
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribe: Disconnected with
>> result code 0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: engine: Caught unrecoverable
>> exception in engine:
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** start time (1561048362)
>> is greater than stop time (1561048337)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** Traceback (most recent
>> call last):
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 890, in main
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** engine.run()
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 191, in run
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: ****
>> self.dispatchEvent(weewx.Event(weewx.NEW_LOOP_PACKET, packet=packet))
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 224, in dispatchEvent
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** callback(event)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 609, in new_loop_packet
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** target_data =
>> self.subscriber.get_accumulated_data(topic, start_ts, self.end_ts,
>> event.packet['usUnits'])
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 529, in get_accumulated_data
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** return
>> self.manager.get_accumulated_data(topic, start_ts, end_ts, units)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 277, in get_accumulated_data
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** accumulator =
>> weewx.accum.Accum(weeutil.weeutil.TimeSpan(start_ts, end_ts))
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/weeutil/weeutil.py", line 256, in __new__
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** raise
>> ValueError("start time (%d) is greater than stop time (%d)" % (args[0],
>> args[1]))
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** ValueError: start time
>> (1561048362) is greater than stop time (1561048337)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** Exiting.
>
>
> Jun 20 11:05:35 MITX-6930 weewx[16315]: weatherflowudp: MainThread: raw
>> packet: {'serial_number': 'SK-00015052', 'type': 'rapid_wind', 'ob':
>> [1561053931, 0.98, 342], 'hub_sn': 'HB-00011764'}
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: weatherflowudp: MainThread:
>> parsed packet: {'serial_number.SK_00015052.rapid_wind': 'SK-00015052',
>> 'type.SK_00015052.rapid_wind': 'rapid_wind',
>> 'hub_sn.SK_00015052.rapid_wind': 'HB-00011764',
>> 'time_epoch.SK_00015052.rapid_wind': 1561053931,
>> 'ob.SK_00015052.rapid_wind': [1561053931, 0.98, 342],
>> 'wind_speed.SK_00015052.rapid_wind': 0.98,
>> 'wind_direction.SK_00015052.rapid_wind': 342, 'time_epoch': 1561053931}
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: weatherflowudp: MainThread: Loop
>> packet: {'windDir': 342, 'windSpeed': 0.98, 'usUnits': 17, 'dateTime':
>> 1561053931}
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribeService: Packet
>> prior to update is: 2019-06-20 11:05:31 PDT (1561053931) dateTime:
>> 1561053931, usUnits: 17, windDir: 342, windSpeed: 0.98
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribeService: Processing
>> interval: 1561053928.000000 1561053931.000000
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribe: TopicManager queue
>> size is: 0
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribeService: Queue was
>> empty
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribeService: Packet
>> after update is: 2019-06-20 11:05:31 PDT (1561053931) dateTime: 1561053931,
>> usUnits: 17, windDir: 342, windSpeed: 0.98
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: restx: MQTT: Published record
>> 2019-06-20 11:05:31 PDT (1561053931)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: weatherflowudp: MainThread: raw
>> packet: {'firmware_revision': 43, 'serial_number': 'SK-00015052', 'type':
>> 'obs_sky', 'obs': [[1561053914, 29168, 3.06, 0.0, 0.0, 0.68, 1.52, 7, 3.39,
>> 1, 243, None, 0, 3]], 'hub_sn': 'HB-00011764'}
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: weatherflowudp: MainThread:
>> parsed packet: {'wind_avg.SK_00015052.obs_sky': 0.68,
>> 'type.SK_00015052.obs_sky': 'obs_sky',
>> 'rain_accumulated.SK_00015052.obs_sky': 0.0, 'hub_sn.SK_00015052.obs_sky':
>> 'HB-00011764', 'precipitation_type.SK_00015052.obs_sky': 0,
>> 'uv.SK_00015052.obs_sky': 3.06, 'firmware_revision.SK_00015052.obs_sky':
>> 43, 'wind_gust.SK_00015052.obs_sky': 1.52,
>> 'wind_direction.SK_00015052.obs_sky': 7,
>> 'local_day_rain_accumulation.SK_00015052.obs_sky': None,
>> 'obs.SK_00015052.obs_sky': [[1561053914, 29168, 3.06, 0.0, 0.0, 0.68, 1.52,
>> 7, 3.39, 1, 243, None, 0, 3]], 'wind_sample_interval.SK_00015052.obs_sky':
>> 3, 'illuminance.SK_00015052.obs_sky': 29168,
>> 'report_interval.SK_00015052.obs_sky': 1, 'time_epoch.SK_00015052.obs_sky':
>> 1561053914, 'solar_radiation.SK_00015052.obs_sky': 243, 'time_epoch':
>> 1561053914, 'wind_lull.SK_00015052.obs_sky': 0.0,
>> 'battery.SK_00015052.obs_sky': 3.39, 'serial_number.SK_00015052.obs_sky':
>> 'SK-00015052'}
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: weatherflowudp: MainThread: Loop
>> packet: {'skyBatteryVoltage': 3.39, 'precipitationType': 0,
>> 'windBatteryStatus': 3.39, 'UV': 3.06, 'radiation': 243, 'rain': 0.0,
>> 'dateTime': 1561053914, 'illuminance': 29168, 'windLull': 0.0, 'usUnits':
>> 17}
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: MQTTSubscribeService: Packet
>> prior to update is: 2019-06-20 11:05:14 PDT (1561053914) dateTime:
>> 1561053914, illuminance: 29168, precipitationType: 0, radiation: 243, rain:
>> 0.0, skyBatteryVoltage: 3.39, usUnits: 17, UV: 3.06, windBatteryStatus:
>> 3.39, windLull: 0.0
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: MQTTSubscribeService: Processing
>> interval: 1561053931.000000 1561053914.000000
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: engine: Main loop exiting.
>> Shutting engine down.
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: engine: Shutting down StdReport
>> thread
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: engine: StdReport thread has been
>> terminated
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: restx: Shut down MQTT thread.
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: restx: Shut down Wunderground-RF
>> thread.
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: MQTTSubscribe: Disconnected with
>> result code 0
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: engine: Caught unrecoverable
>> exception in engine:
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** start time (1561053931)
>> is greater than stop time (1561053914)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** Traceback (most recent
>> call last):
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 890, in main
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** engine.run()
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 191, in run
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: ****
>> self.dispatchEvent(weewx.Event(weewx.NEW_LOOP_PACKET, packet=packet))
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 224, in dispatchEvent
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** callback(event)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 609, in new_loop_packet
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** target_data =
>> self.subscriber.get_accumulated_data(topic, start_ts, self.end_ts,
>> event.packet['usUnits'])
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 529, in get_accumulated_data
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** return
>> self.manager.get_accumulated_data(topic, start_ts, end_ts, units)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 277, in get_accumulated_data
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** accumulator =
>> weewx.accum.Accum(weeutil.weeutil.TimeSpan(start_ts, end_ts))
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/weeutil/weeutil.py", line 256, in __new__
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** raise
>> ValueError("start time (%d) is greater than stop time (%d)" % (args[0],
>> args[1]))
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** ValueError: start time
>> (1561053931) is greater than stop time (1561053914)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** Exiting.
>
>
>
> I really would like to able to include other sensor data beyond the
> WeatherFlow sensors.
>
>
On Thursday, June 20, 2019 at 11:32:30 AM UTC-7, Patrick Mendiuk wrote:
>
> I am trying to setup Weewx 3.9.1 with WeatherflowUDP, MQTTSubscribe, MQTT
> and the Belchertown 1.0 skin. The platform is Ubuntu 18.04 LTS running on
> an Atom D2700 with 4G RAM and 256G OCZ SSD. The MQTT Mosquitto broker is
> running on the same machine.
>
> Previously, I was running Weewx, WeatherflowUDP and MQTT for 2 or 3
> months. I occasionally would have small gaps in data, but weewx would
> continue to run. A couple of days ago I installed MQTTSubscribe to add
> some indoor data from a Sonoff TH10 flashed with Tasmota. I have the
> Tasmota publishing temp and humidity once a minute.
>
> Weewx has been stopping due to time stamp error with MQTTSubscribe. I am
> wondering if the small gaps in the database I was observing previously is
> due to this out of order data just being ignored prior to installing
> MQTTSubscribe?
>
> Jun 20 07:48:02 MITX-6930 weewx[8675]: engine: Main loop exiting. Shutting
>> engine down.
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: engine: Shutting down StdReport
>> thread
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: engine: Caught unrecoverable
>> exception in engine:
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** start time (1561042080)
>> is greater than stop time (1561042079)
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** Traceback (most recent
>> call last):
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 890, in main
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** engine.run()
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 191, in run
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: ****
>> self.dispatchEvent(weewx.Event(weewx.NEW_LOOP_PACKET, packet=packet))
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 224, in dispatchEvent
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** callback(event)
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 609, in new_loop_packet
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** target_data =
>> self.subscriber.get_accumulated_data(topic, start_ts, self.end_ts,
>> event.packet['usUnits'])
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 529, in get_accumulated_data
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** return
>> self.manager.get_accumulated_data(topic, start_ts, end_ts, units)
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 277, in get_accumulated_data
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** accumulator =
>> weewx.accum.Accum(weeutil.weeutil.TimeSpan(start_ts, end_ts))
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** File
>> "/usr/share/weewx/weeutil/weeutil.py", line 256, in __new__
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** raise
>> ValueError("start time (%d) is greater than stop time (%d)" % (args[0],
>> args[1]))
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** ValueError: start time
>> (1561042080) is greater than stop time (1561042079)
>> Jun 20 07:48:02 MITX-6930 weewx[8675]: **** Exiting.
>
>
> Jun 20 09:32:42 MITX-6930 weewx[14061]: MQTTSubscribeService: Packet after
>> update is: 2019-06-20 09:32:39 PDT (1561048359) dateTime: 1561048359,
>> usUnits: 17, windDir: 0, windSpeed: 0.0
>> Jun 20 09:32:42 MITX-6930 weewx[14061]: restx: MQTT: Published record
>> 2019-06-20 09:32:39 PDT (1561048359)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Packet
>> prior to update is: 2019-06-20 09:32:42 PDT (1561048362) dateTime:
>> 1561048362, usUnits: 17, windDir: 0, windSpeed: 0.0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Processing
>> interval: 1561048359.000000 1561048362.000000
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribe: TopicManager queue
>> size is: 0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Queue was
>> empty
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Packet
>> after update is: 2019-06-20 09:32:42 PDT (1561048362) dateTime: 1561048362,
>> usUnits: 17, windDir: 0, windSpeed: 0.0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: restx: MQTT: Published record
>> 2019-06-20 09:32:42 PDT (1561048362)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Packet
>> prior to update is: 2019-06-20 09:32:17 PDT (1561048337) dateTime:
>> 1561048337, illuminance: 40134, precipitationType: 0, radiation: 334, rain:
>> 0.0, skyBatteryVoltage: 3.37, usUnits: 17, UV: 3.77, windBatteryStatus:
>> 3.37, windLull: 0.0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribeService: Processing
>> interval: 1561048362.000000 1561048337.000000
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: engine: Main loop exiting.
>> Shutting engine down.
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: engine: Shutting down StdReport
>> thread
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: engine: StdReport thread has been
>> terminated
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: restx: Shut down MQTT thread.
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: restx: Shut down Wunderground-RF
>> thread.
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: MQTTSubscribe: Disconnected with
>> result code 0
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: engine: Caught unrecoverable
>> exception in engine:
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** start time (1561048362)
>> is greater than stop time (1561048337)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** Traceback (most recent
>> call last):
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 890, in main
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** engine.run()
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 191, in run
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: ****
>> self.dispatchEvent(weewx.Event(weewx.NEW_LOOP_PACKET, packet=packet))
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 224, in dispatchEvent
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** callback(event)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 609, in new_loop_packet
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** target_data =
>> self.subscriber.get_accumulated_data(topic, start_ts, self.end_ts,
>> event.packet['usUnits'])
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 529, in get_accumulated_data
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** return
>> self.manager.get_accumulated_data(topic, start_ts, end_ts, units)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 277, in get_accumulated_data
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** accumulator =
>> weewx.accum.Accum(weeutil.weeutil.TimeSpan(start_ts, end_ts))
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** File
>> "/usr/share/weewx/weeutil/weeutil.py", line 256, in __new__
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** raise
>> ValueError("start time (%d) is greater than stop time (%d)" % (args[0],
>> args[1]))
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** ValueError: start time
>> (1561048362) is greater than stop time (1561048337)
>> Jun 20 09:32:45 MITX-6930 weewx[14061]: **** Exiting.
>
>
> Jun 20 11:05:35 MITX-6930 weewx[16315]: weatherflowudp: MainThread: raw
>> packet: {'serial_number': 'SK-00015052', 'type': 'rapid_wind', 'ob':
>> [1561053931, 0.98, 342], 'hub_sn': 'HB-00011764'}
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: weatherflowudp: MainThread:
>> parsed packet: {'serial_number.SK_00015052.rapid_wind': 'SK-00015052',
>> 'type.SK_00015052.rapid_wind': 'rapid_wind',
>> 'hub_sn.SK_00015052.rapid_wind': 'HB-00011764',
>> 'time_epoch.SK_00015052.rapid_wind': 1561053931,
>> 'ob.SK_00015052.rapid_wind': [1561053931, 0.98, 342],
>> 'wind_speed.SK_00015052.rapid_wind': 0.98,
>> 'wind_direction.SK_00015052.rapid_wind': 342, 'time_epoch': 1561053931}
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: weatherflowudp: MainThread: Loop
>> packet: {'windDir': 342, 'windSpeed': 0.98, 'usUnits': 17, 'dateTime':
>> 1561053931}
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribeService: Packet
>> prior to update is: 2019-06-20 11:05:31 PDT (1561053931) dateTime:
>> 1561053931, usUnits: 17, windDir: 342, windSpeed: 0.98
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribeService: Processing
>> interval: 1561053928.000000 1561053931.000000
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribe: TopicManager queue
>> size is: 0
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribeService: Queue was
>> empty
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: MQTTSubscribeService: Packet
>> after update is: 2019-06-20 11:05:31 PDT (1561053931) dateTime: 1561053931,
>> usUnits: 17, windDir: 342, windSpeed: 0.98
>> Jun 20 11:05:35 MITX-6930 weewx[16315]: restx: MQTT: Published record
>> 2019-06-20 11:05:31 PDT (1561053931)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: weatherflowudp: MainThread: raw
>> packet: {'firmware_revision': 43, 'serial_number': 'SK-00015052', 'type':
>> 'obs_sky', 'obs': [[1561053914, 29168, 3.06, 0.0, 0.0, 0.68, 1.52, 7, 3.39,
>> 1, 243, None, 0, 3]], 'hub_sn': 'HB-00011764'}
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: weatherflowudp: MainThread:
>> parsed packet: {'wind_avg.SK_00015052.obs_sky': 0.68,
>> 'type.SK_00015052.obs_sky': 'obs_sky',
>> 'rain_accumulated.SK_00015052.obs_sky': 0.0, 'hub_sn.SK_00015052.obs_sky':
>> 'HB-00011764', 'precipitation_type.SK_00015052.obs_sky': 0,
>> 'uv.SK_00015052.obs_sky': 3.06, 'firmware_revision.SK_00015052.obs_sky':
>> 43, 'wind_gust.SK_00015052.obs_sky': 1.52,
>> 'wind_direction.SK_00015052.obs_sky': 7,
>> 'local_day_rain_accumulation.SK_00015052.obs_sky': None,
>> 'obs.SK_00015052.obs_sky': [[1561053914, 29168, 3.06, 0.0, 0.0, 0.68, 1.52,
>> 7, 3.39, 1, 243, None, 0, 3]], 'wind_sample_interval.SK_00015052.obs_sky':
>> 3, 'illuminance.SK_00015052.obs_sky': 29168,
>> 'report_interval.SK_00015052.obs_sky': 1, 'time_epoch.SK_00015052.obs_sky':
>> 1561053914, 'solar_radiation.SK_00015052.obs_sky': 243, 'time_epoch':
>> 1561053914, 'wind_lull.SK_00015052.obs_sky': 0.0,
>> 'battery.SK_00015052.obs_sky': 3.39, 'serial_number.SK_00015052.obs_sky':
>> 'SK-00015052'}
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: weatherflowudp: MainThread: Loop
>> packet: {'skyBatteryVoltage': 3.39, 'precipitationType': 0,
>> 'windBatteryStatus': 3.39, 'UV': 3.06, 'radiation': 243, 'rain': 0.0,
>> 'dateTime': 1561053914, 'illuminance': 29168, 'windLull': 0.0, 'usUnits':
>> 17}
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: MQTTSubscribeService: Packet
>> prior to update is: 2019-06-20 11:05:14 PDT (1561053914) dateTime:
>> 1561053914, illuminance: 29168, precipitationType: 0, radiation: 243, rain:
>> 0.0, skyBatteryVoltage: 3.39, usUnits: 17, UV: 3.06, windBatteryStatus:
>> 3.39, windLull: 0.0
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: MQTTSubscribeService: Processing
>> interval: 1561053931.000000 1561053914.000000
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: engine: Main loop exiting.
>> Shutting engine down.
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: engine: Shutting down StdReport
>> thread
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: engine: StdReport thread has been
>> terminated
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: restx: Shut down MQTT thread.
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: restx: Shut down Wunderground-RF
>> thread.
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: MQTTSubscribe: Disconnected with
>> result code 0
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: engine: Caught unrecoverable
>> exception in engine:
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** start time (1561053931)
>> is greater than stop time (1561053914)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** Traceback (most recent
>> call last):
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 890, in main
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** engine.run()
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 191, in run
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: ****
>> self.dispatchEvent(weewx.Event(weewx.NEW_LOOP_PACKET, packet=packet))
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/weewx/engine.py", line 224, in dispatchEvent
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** callback(event)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 609, in new_loop_packet
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** target_data =
>> self.subscriber.get_accumulated_data(topic, start_ts, self.end_ts,
>> event.packet['usUnits'])
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 529, in get_accumulated_data
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** return
>> self.manager.get_accumulated_data(topic, start_ts, end_ts, units)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/user/MQTTSubscribe.py", line 277, in get_accumulated_data
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** accumulator =
>> weewx.accum.Accum(weeutil.weeutil.TimeSpan(start_ts, end_ts))
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** File
>> "/usr/share/weewx/weeutil/weeutil.py", line 256, in __new__
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** raise
>> ValueError("start time (%d) is greater than stop time (%d)" % (args[0],
>> args[1]))
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** ValueError: start time
>> (1561053931) is greater than stop time (1561053914)
>> Jun 20 11:05:37 MITX-6930 weewx[16315]: **** Exiting.
>
>
>
> I really would like to able to include other sensor data beyond the
> WeatherFlow sensors.
>
>
--
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/f5568416-0291-4644-bfcc-10c6687c31a8%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
