Tasmota no reaction for 10-30sec - occuring every few minutes

[mardigras2020]

Hi,

i'm using this ESP32 and Build

14.4.0 (release-bluetooth)
(ESP32-D0WD-V3 v3.1)

Collecting every 250ms data from a Hall Sensor with a Driver i've written
The hall values are trasmitted via MQT to IoBroker->Influx->grafana

the driver uses the def every_250ms() for the measuring.

in the grafana i see often missing data for 10-30sec
Could you give me some hint how to ensure continous operation?

Thanks for your support:

Details:

In the grafana:

in the logs i can see and suspect the problem starts at "message too large" - what i can't understand. because the message has the same length every time. And there is a scond example from the logs without the message error.

07:08:14.767 BRY: GC from 15794 to 7823 bytes, objects freed 100/103 (in 1 ms) - slots from 180/212 to 93/197
07:08:14.826 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2093,"state":2085,"counter":961235,"delta":0}
07:08:15.047 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2087,"state":2085,"counter":961235,"delta":0}
07:08:15.317 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2099,"state":2085,"counter":961235,"delta":0}
----------issue starts here---------
07:08:25.550 MQT: Message too large
07:08:25.551 RSL: SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2099,"state":2085,"counter":961235,"delta":0}
07:08:35.724 RSL: SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2083,"state":2085,"counter":961235,"delta":0}
07:08:45.839 BRY: GC from 15698 to 7602 bytes, objects freed 100/96 (in 1 ms) - slots from 177/212 to 84/167
07:08:47.114 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2092,"state":2085,"counter":961235,"delta":0}
-------------------
07:08:47.548 RSL: SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2083,"state":2085,"counter":961235,"delta":0}
07:08:47.809 RSL: SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2089,"state":2085,"counter":961235,"delta":0}
07:08:48.051 RSL: SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2088,"state":2085,"counter":961235,"delta":0}
07:08:48.172 MQT: Attempting connection...
07:08:48.197 MQT: Connected
07:08:48.201 MQT: tele/tasmota_C70618/LWT = Online (retained)
07:08:48.204 MQT: cmnd/tasmota_C70618/POWER = 
07:08:48.206 MQT: Subscribe to cmnd/tasmota_C70618/#
07:08:48.209 MQT: Subscribe to cmnd/tasmotas/#
07:08:48.210 MQT: Subscribe to cmnd/DVES_C70618_fb/#
07:08:48.353 BRY: GC from 15296 to 7715 bytes, objects freed 90/98 (in 1 ms) - slots from 173/197 to 85/167
07:08:48.358 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2073,"state":2085,"counter":961235,"delta":0}
07:08:48.404 MQT: tasmota/discovery/142B2FC70618/config = {"ip":"192.168.1.66","dn":"Tasmota","fn":["Tasmota",null,null,null,null,null,null,null],"hn":"tasmota-C70618-1560","mac":"142B2FC70618","md":"ESP32-DevKit","ty":0,"if":0,"ofln":"Offline","onln":"Online","state":["OFF","ON","TOGGLE","HOLD"],"sw":"14.4.0","t":"tasmota_C70618","ft":"%prefix%/%topic%/","tp":["cmnd","stat","tele"],"rl":[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0],"swc":[-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1],"swn":[null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null],"btn":[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0],"so":{"4":0,"11":0,"13":0,"17":0,"20":0,"30":0,"68":0,"73":0,"82":0,"114":0,"117":0},"lk":0,"lt_st":0,"bat":0,"dslp":0,"sho":[],"sht":[],"ver":1} (retained)
07:08:48.446 MQT: tasmota/discovery/142B2FC70618/sensors = {"sn":{"Time":"2024-12-20T07:08:48","Switch1":"OFF","ANALOG":{"A1":1990}},"ver":1} (retained)
07:08:48.595 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2131,"currentHall":2083,"state":2085,"counter":961235,"delta":0}

second log example

08:38:55.802 RSL: SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2067,"state":2085,"counter":961241,"delta":0}
08:38:55.908 BRY: GC from 15653 to 7601 bytes, objects freed 100/96 (in 1 ms) - slots from 176/197 to 84/167
08:39:05.978 RSL: SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2079,"state":2085,"counter":961241,"delta":0}
08:39:26.161 RSL: SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2063,"state":2085,"counter":961241,"delta":0}
08:39:26.187 HTP: Console
08:39:26.483 RSL: SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2063,"state":2085,"counter":961241,"delta":0}
08:39:26.902 RSL: SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2071,"state":2085,"counter":961241,"delta":0}
08:39:27.062 BRY: GC from 15236 to 7735 bytes, objects freed 92/98 (in 1 ms) - slots from 173/197 to 85/167
-----------------issue starts here-------------
08:39:27.064 RSL: SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2081,"state":2085,"counter":961241,"delta":0}
08:39:27.121 MQT: Attempting connection...
08:39:27.141 MQT: Connected
08:39:27.145 MQT: tele/tasmota_C70618/LWT = Online (retained)
08:39:27.148 MQT: cmnd/tasmota_C70618/POWER = 
08:39:27.150 MQT: Subscribe to cmnd/tasmota_C70618/#
08:39:27.152 MQT: Subscribe to cmnd/tasmotas/#
08:39:27.154 MQT: Subscribe to cmnd/DVES_C70618_fb/#
08:39:27.299 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2067,"state":2085,"counter":961241,"delta":0}
08:39:27.353 MQT: tasmota/discovery/<removedMAC>/config = {"ip":"192.168.1.66","dn":"Tasmota","fn":["Tasmota",null,null,null,null,null,null,null],"hn":"tasmota-C70618-1560","mac":"<removedMAC>","md":"ESP32-DevKit","ty":0,"if":0,"ofln":"Offline","onln":"Online","state":["OFF","ON","TOGGLE","HOLD"],"sw":"14.4.0","t":"tasmota_C70618","ft":"%prefix%/%topic%/","tp":["cmnd","stat","tele"],"rl":[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0],"swc":[-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1],"swn":[null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null],"btn":[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0],"so":{"4":0,"11":0,"13":0,"17":0,"20":0,"30":0,"68":0,"73":0,"82":0,"114":0,"117":0},"lk":0,"lt_st":0,"bat":0,"dslp":0,"sho":[],"sht":[],"ver":1} (retained)
08:39:27.395 MQT: tasmota/discovery/<removedMAC>/sensors = {"sn":{"Time":"2024-12-20T08:39:27","Switch1":"ON","ANALOG":{"A1":1857}},"ver":1} (retained)
08:39:27.541 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2063,"state":2085,"counter":961241,"delta":0}
08:39:27.764 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2076,"state":2085,"counter":961241,"delta":0}
08:39:28.036 MQT: tele/tasmota_C70618/SENSOR = {"hallMin":2061,"hallMax":2130,"currentHall":2078,"state":2085,"counter":961241,"delta":0}
08:39:28.288 BRY: GC from 15503 to 7647 bytes, objects freed 98/98 (in 2 ms) - slots from 177/197 to 85/167

Code:

import json
import mqtt
import persist
import string

class WaterCounterDriver
  var counter
  var LOW
  var HIGH
  var MINNOTPLAUSIBLE
  var hallMin
  var hallMax
  var state
  var hall
  var delta

  def init()
    print("INIT WaterCounterDriver")
    # counter was initally persisted by commandline
    # alternative would be fetch counter from influx
    self.counter=0
    self.counter=persist.find("counter")
    self.LOW=2085
    self.HIGH=2120
    # parameter for stability; sensors has spikes towards minValue
    self.MINNOTPLAUSIBLE=2060
    # only for interest - no function attached
    self.hallMin=3000
    self.hallMax=0
    self.state=self.LOW
    self.hall=0
    self.delta=0
    print("INIT WaterCounterDriver finished")
  end

  def setMinMax(hall)
    if self.hall < self.hallMin
      self.hallMin=self.hall
    end
    if self.hall > self.hallMax 
      self.hallMax=self.hall
    end
  end

  # TODO - retrieve topic automatically from tasmota
  def sendMQTT()
    var payload='{"hallMin":'+str(self.hallMin)+',"hallMax":'+str(self.hallMax)+',"currentHall":'+str(self.hall)+',"state":'+str(self.state)+',"counter":'+str(self.counter)+',"delta":'+str(self.delta)+'}'
    # print("State: "+payload)
    if mqtt.connected()
      mqtt.publish("tele/tasmota_C70618/SENSOR", payload)
    end
  end

  # TODO real median
  def hallMedianRead()
    var hall1=json.load(tasmota.read_sensors())['ANALOG']['A1']
    tasmota.delay(10)
    var hall2=json.load(tasmota.read_sensors())['ANALOG']['A1']
    tasmota.delay(10)
    var hall3=json.load(tasmota.read_sensors())['ANALOG']['A1']
    tasmota.delay(10)
    var hallMedian=0
    if hall1 <= hall2 && hall2 <= hall3
      hallMedian=hall2
    end  
    if hall1 >= hall2 && hall2 >= hall3
      hallMedian=hall2
    end  
    if hall2 <= hall1 && hall1 <= hall3
      hallMedian=hall1
    end
    if hall2 >= hall1 && hall1 >= hall3
      hallMedian=hall1
    end  
    if hall1 <= hall3 && hall3 <= hall2
      hallMedian=hall3
    end
    if hall1 >= hall3 && hall3 >= hall2
      hallMedian=hall3
    end
    # print("H1: "+str(hall1)+" H2: "+str(hall2)+" H3: "+str(hall3)+" HM: "+str(hallMedian))  
    return hallMedian
  end

  def sensors_job()
    self.delta=0
    # var sensors=json.load(tasmota.read_sensors())
    # hall=sensors['ANALOG']['A1']
    self.hall=self.hallMedianRead()
    # leaving out the Downspikes of the sensor
    if self.hall > self.MINNOTPLAUSIBLE      
      self.setMinMax(self.hall)
      if self.state==self.LOW
        if self.hall >= self.HIGH
          self.state=self.HIGH
          self.counter=self.counter+1
          persist.counter=self.counter
          persist.save()
          self.delta=0.5
        end
      end
      if self.state==self.HIGH
        if self.hall <= self.LOW
          self.state=self.LOW
          self.delta=0.5
        end
      end
      self.sendMQTT()
    end
  end

  #- display sensor value in the web UI -#
  def web_sensor()
    var msg = string.format(
             "{s}Counter {m}%i liter{e}"..
             "{s}current Hall {m}%i {e}"..
             "{s}minimal Hall {m}%i {e}"..
             "{s}maximal Hall {m}%i {e}",
              self.counter, self.hall, self.hallMin, self.hallMax)
    tasmota.web_send_decimal(msg)
  end

  # check every 250 ms
  def every_250ms()
    self.sensors_job()
  end
end

# add to autexec.be
waterCounter=WaterCounterDriver()
tasmota.add_driver(waterCounter)