求助！关于使用Blinker-py库发送实时数据时出现的问题

yinbing

各位大神，我在树莓派4B上运行blinker-py库自带的实时数据示例（代码见图1）时，出现了图2所示报错，然后虽然程序仍能连上服务器，但无法响应APP实时数据请求（key已经检查过，设置正确）。我对python还不是非常熟悉，请大神们帮帮忙看看该如何解决这个问题。


环境：树莓派4B、raspberrypi os 32bit lite（debian11 bullseye）、python3.9。

图1  示例代码（文件名：blinker_realtime_test.py）：

1. # -*- coding: utf-8 -*-
   
2. 
   
3. """
   
4. 实时数据
   
5. """
   
6. 
   
7. __author__ = 'stao'
   
8. 
   
9. import random
   
10. 
    
11. from blinker import Device
    
12. 
    
13. 
    
14. def generate_data():
    
15.    return random.randint(1, 100)
    
16. 
    
17. 
    
18. async def realtime_func(keys):
    
19.    print("realtime func received {0}".format(keys))
    
20.    for key in keys:
    
21.        if key == "num-hid":
    
22.            await device.sendRtData(key, generate_data)
    
23.        elif key == "num-tid":
    
24.            await device.sendRtData(key, generate_data)
    
25. 
    
26. 
    
27. device = Device("xxxxxxxxx", realtime_func=realtime_func)
    
28. 
    
29. if __name__ == '__main__':
    
30.    device.run()
    

复制代码

图2  bash shell 报错：

1. pi@raspberrypi:~/ydyp_dir/src_pi $ python blinker_realtime_test.py
   
2. Exception in thread Thread-5:
   
3. Traceback (most recent call last):
   
4. File "/usr/lib/python3.9/threading.py", line 954, in _bootstrap_inner
   
5.    self.run()
   
6. File "/usr/lib/python3.9/threading.py", line 892, in run
   
7.    self._target(*self._args, **self._kwargs)
   
8. File "/usr/local/lib/python3.9/dist-packages/blinker/device.py", line 170, in scheduler_run
   
9.    self.scheduler.start()
   
10. File "/usr/local/lib/python3.9/dist-packages/apscheduler/schedulers/background.py", line 35, in start
    
11.    BaseScheduler.start(self, *args, **kwargs)
    
12. File "/usr/local/lib/python3.9/dist-packages/apscheduler/schedulers/base.py", line 150, in start
    
13.    self.add_executor(self._create_default_executor(), 'default')
    
14. File "/usr/local/lib/python3.9/dist-packages/apscheduler/schedulers/base.py", line 762, in _create_default_executor
    
15.    return ThreadPoolExecutor()
    
16. File "/usr/local/lib/python3.9/dist-packages/apscheduler/executors/pool.py", line 53, in __init__
    
17.    pool = concurrent.futures.ThreadPoolExecutor(int(max_workers), **pool_kwargs)
    
18. File "/usr/lib/python3.9/concurrent/futures/__init__.py", line 49, in __getattr__
    
19.    from .thread import ThreadPoolExecutor as te
    
20. ImportError: cannot import name 'ThreadPoolExecutor' from partially initialized module 'concurrent.futures.thread' (most likely due to a circular import) (/usr/lib/python3.9/concurrent/futures/thread.py)
    
21. 2022-06-20 20:17:16.690 | SUCCESS  | blinker.device:device_init:225 - Device auth successful...
    
22. 2022-06-20 20:17:16.692 | INFO     | blinker.device:_cloud_heartbeat:248 - Send cloud heartbeat
    
23. 2022-06-20 20:17:16.703 | INFO     | blinker.httpclient:cloud_heartbeat:128 - http cloud heartbeat
    
24. 2022-06-20 20:17:16.990 | INFO     | blinker.mqttclient:_on_connect:46 - Connect to broker from mqtt
    
25. 2022-06-20 20:17:16.991 | SUCCESS  | blinker.mqttclient:_on_connect:48 - Broker connected...
    
26. 2022-06-20 20:17:16.993 | SUCCESS  | blinker.device:_receiver:384 - Receiver ready...
    

复制代码