添加倒计时和实时数据支持

Author: werewolfst

example/data_read.py

@@ -1,19 +1,19 @@
 # -*- coding: utf-8 -*-
 
 """
-mqtt数据处理
+mqtt其它数据处理
 """
 
 __author__ = 'stao'
 
 from blinker import Device
 
 
-def data_read_func():
+async def ready_func():
     print(device.data_reader.get())
 
 
-device = Device("authKey", protocol="mqtts", ready_func=data_read_func)
+device = Device("authKey", ready_func=ready_func)
 
 if __name__ == '__main__':
     device.run()

example/realtime.py

@@ -0,0 +1,30 @@
+# -*- coding: utf-8 -*-
+
+"""
+实时数据
+"""
+
+__author__ = 'stao'
+
+import random
+
+from blinker import Device
+
+
+def generate_data():
+    return random.randint(1, 100)
+
+
+async def realtime_func(keys):
+    print("realtime func received {0}".format(keys))
+    for key in keys:
+        if key == "humi":
+            await device.sendRtData(key, generate_data)
+        elif key == "temp":
+            await device.sendRtData(key, generate_data)
+
+
+device = Device("authKey", realtime_func=realtime_func)
+
+if __name__ == '__main__':
+    device.run()

example/timing_and_countdown.py

@@ -0,0 +1,19 @@
+# -*- coding: utf-8 -*-
+
+"""
+定时和倒计时
+"""
+
+__author__ = 'stao'
+
+from blinker import Device
+
+
+async def builtin_switch_func(msg):
+    print("received msg: {0}".format(msg))
+
+
+device = Device("authKey", builtin_switch_func=builtin_switch_func)
+
+if __name__ == '__main__':
+    device.run()

requirements.txt

@@ -2,4 +2,9 @@ aiohttp~=3.7.4
 certifi~=2021.10.8
 loguru~=0.5.3
 paho-mqtt~=1.6.1
-Rx~=3.2.0
+Rx~=3.2.0
+websockets~=10.2
+apscheduler~=3.9.1
+getmac~=0.8.3
+zeroconf~=0.38.4
+requests~=2.27.1

setup.cfg

@@ -25,6 +25,11 @@ install_requires =
     loguru~=0.5.3
     paho-mqtt~=1.6.1
     Rx~=3.2.0
+    websockets~=10.2
+    apscheduler~=3.9.1
+    getmac~=0.8.3
+    zeroconf~=0.38.4
+    requests~=2.27.1
 
 [options.packages.find]
 where = src

setup.py

@@ -30,6 +30,11 @@
         'certifi~=2021.10.8',
         'loguru~=0.5.3',
         'paho-mqtt~=1.6.1',
-        'Rx~=3.2.0'
+        'Rx~=3.2.0',
+        "websockets~=10.2",
+        'apscheduler~=3.9.1',
+        'getmac~=0.8.3',
+        'zeroconf~=0.38.4',
+        'requests~=2.27.1',
     ],
 )