有办法获取净水器的实时工作状态吗？

[mylovexx]

如题，想写一个净水器长时间工作就报警的功能，接水时走开经常忘了关…

[mylovexx]

发现净水器不工作的话tds就是上一次的值，工作的话tds因为是实时测量的会上下跳动，写了个检测tds是否实时变化来判断净水器是否在工作的函数，算是曲线解决这个问题吧

from miio.device import Device
import time
import threading

ip = 'x.x.x.x'
token = 'xxxx'
d = Device(ip=ip, token=token)

last_tds_value = {}
start_working_time = None
is_working = False
error_cnt = 0
status_cnt = 0

def getWaterPurifierInfo():
global last_tds_value, is_working, start_working_time, error_cnt, status_cnt
method = "get_prop" # 方法名
params = ["tds_in", "tds_out"] # 参数列表

while True:
    current_tds_value = {}
    try:
        for param in params:
            response = d.send(method, [param])
            current_tds_value[param] = int(response[0])
    except Exception as e:
        print(f"发生错误: {e}")
        error_cnt += 1
        if error_cnt > 5:  # something maybe the network is wrong
            time.sleep(60)
        else:
            time.sleep(10)
        continue
    error_cnt = 0
    print(time.strftime("%H:%M:%S", time.localtime()))
    print(current_tds_value)

    if not last_tds_value:  # 第一次获取 TDS 值
        last_tds_value["tds_in"] = current_tds_value["tds_in"]
        last_tds_value["tds_out"] = current_tds_value["tds_out"]

    if current_tds_value["tds_in"] != last_tds_value["tds_in"] or \
            current_tds_value["tds_out"] != last_tds_value["tds_out"]:  # TDS 值发生变化
        last_tds_value["tds_in"] = current_tds_value["tds_in"]
        last_tds_value["tds_out"] = current_tds_value["tds_out"]
        if not is_working:
            is_working = True
            start_working_time = time.time()
        status_cnt = 0
    else:
        if is_working:
            status_cnt += 1
            if status_cnt > 1:
                is_working = False
                status_cnt = 0

    time.sleep(10)

thread1 = threading.Thread(target=getWaterPurifierInfo)
thread1.start()

try:
while True:
if is_working:
current_time = time.time()
print(f"working_time: {current_time-start_working_time}")
time.sleep(1) # 避免 CPU 占用过高
except (KeyboardInterrupt, SystemExit):
# 关闭调度器
print("exit success")