Azure IoT Edge Module中Python交互式输入的方案咨询

一、修复文件检测方案（最简替代） #

你之前的文件检测代码存在两个核心问题：未清理触发文件导致重复触发/误判、无循环延迟导致CPU空转且日志缓冲无法及时刷新。以下是修正后的代码：

import os
import time

break_file_path = "/tmp/break.trigger"
trigger_file_path = "/tmp/action.trigger"

while True:
    # 检测退出信号
    if os.path.isfile(break_file_path):
        os.remove(break_file_path)  # 清理文件，避免下次启动直接退出
        break
    
    # 检测操作触发信号
    if os.path.isfile(trigger_file_path):
        # 执行你的业务逻辑
        print("Executing triggered action...")
        # 执行后删除触发文件，防止重复执行
        os.remove(trigger_file_path)
    
    # 添加1秒延迟，降低CPU占用，同时让日志有机会刷新
    time.sleep(1)

print("Program exited.")

使用方式 #

在IoT Edge设备上通过docker exec进入模块容器，执行以下命令触发操作或退出：

• 触发操作：touch /tmp/action.trigger
• 退出程序：touch /tmp/break.trigger

二、解决日志实时查看问题 #

日志需等循环结束才能查看，是因为Python默认开启了输出缓冲。可以通过两种方式解决：

1. 运行脚本时添加-u参数禁用缓冲：

   python -u your_script.py
   

2. 在代码中手动刷新输出：

   print("Executing triggered action...")
   print.flush()  # 立即刷新输出到日志
   

三、IoT原生交互式方案（更规范） #

如果觉得文件操作不够便捷，可使用Azure IoT Hub的直接方法（Direct Method），无需进入容器，直接在云端发送指令：

from azure.iot.device import IoTHubModuleClient
import threading

# 替换为你的模块连接字符串
CONNECTION_STRING = "YOUR_MODULE_CONNECTION_STRING"

stop_event = threading.Event()

def handle_direct_method(request):
    print(f"Received command: {request.name}")
    if request.name == "t":
        # 执行对应操作
        print("Executing action 't'...")
        print.flush()
        return {"status": 200, "payload": "Action done"}
    elif request.name == "q":
        # 触发退出
        stop_event.set()
        return {"status": 200, "payload": "Exiting"}
    else:
        return {"status": 400, "payload": "Unknown command"}

def main():
    client = IoTHubModuleClient.create_from_connection_string(CONNECTION_STRING)
    client.on_method_request_received = handle_direct_method
    
    print("Waiting for commands from IoT Hub...")
    print.flush()
    stop_event.wait()  # 无限等待直到收到退出指令
    client.shutdown()

if __name__ == "__main__":
    main()

使用方式 #

在Azure Portal或Azure CLI中调用模块的直接方法，传入"t"触发操作、"q"退出程序即可。

内容的提问来源于stack exchange，提问作者JS.