OPC-UA订阅网络操作实现：Python客户端读取压力传感器数据问题咨询

问题1：回调中新建连接拉取数据的方案合理性 #

这个方案可以临时解决线程冲突导致的超时问题，但长期使用存在明显缺陷，不推荐作为最终方案：

• 频繁创建、销毁OPC UA连接会产生额外的网络握手开销，服务端也需要为每个连接分配会话资源，高频率触发（比如接近采样周期的就绪通知）下很容易出现服务端会话溢出、连接拒绝的问题
• 连接建立过程存在不确定性，如果就绪标识触发频率高于连接建立耗时，会出现数据漏读、时序错乱的问题
• 你用原有主连接拉取失败的核心原因是python-opcua的客户端实例不是线程安全的：订阅回调运行在独立的接收线程中，直接调用主连接的IO操作会和主线程的轮询操作产生资源竞争，进而触发超时。

问题2：就绪标识触发下的数据读取优化方案 #

推荐以下几种更稳定的实现方式，按优先级从高到低排序：

方案1：队列中转+独立工作线程（改动最小，兼容性最好） #

核心逻辑是回调只做事件通知，不执行任何IO操作，所有数据拉取逻辑放在独立的工作线程中执行，既符合文档要求，也不需要频繁创建连接：

from opcua import Client
import time
import queue
import threading

# 初始化事件队列
data_ready_queue = queue.Queue()

def data_read_worker(client, pressure_nodes):
    """独立工作线程，负责拉取压力数据"""
    while True:
        # 阻塞等待就绪事件
        event = data_ready_queue.get()
        if event == "stop":
            break
        # 直接复用主连接拉取数据
        for node in pressure_nodes:
            pressure_data = node.get_value()
            # 自行处理数据存储/逻辑
            print("pressure data read complete")
        data_ready_queue.task_done()

class ReadyHandler(object):
    def datachange_notification(self, node, val, data):
        # 回调仅发送事件到队列，毫秒级返回，不会阻塞接收线程
        if val: # 仅在就绪位为True时触发，可根据实际逻辑调整
            data_ready_queue.put("ready")

if __name__ == "__main__":
    url = "opc.tcp://localhost:4840"
    client = Client(url)
    client.connect()
    print("Client connected")

    # 预获取所有需要读取的节点
    readiness_node = client.get_node("ns=2;i=6")
    temp_node = client.get_node("ns=2;i=3")
    # 预获取4个压力传感器节点
    pressure_nodes = [
        client.get_node("ns=2;i=4"),
        # 补充剩余3个节点的NodeId
    ]

    # 启动工作线程
    worker_thread = threading.Thread(
        target=data_read_worker,
        args=(client, pressure_nodes),
        daemon=True
    )
    worker_thread.start()

    # 启动就绪位订阅
    handler = ReadyHandler()
    subscription = client.create_subscription(100, handler)
    subscription.subscribe_data_change(readiness_node)

    # 主线程轮询温度
    while True:
        temperature = temp_node.get_value()
        print(".")
        time.sleep(1)

方案2：复用独立长连接 #

如果不想改动现有主连接的逻辑，可以单独创建一个专用的长连接用于压力数据拉取，工作线程复用这个连接即可，仅在连接断开时重连，避免频繁建连断连的开销。

方案3：切换异步OPC UA客户端 #

如果采样频率极高、数据量较大，可以替换为asyncua（python-opcua的异步迭代版本），异步架构天然避免线程安全问题，回调中可以直接发起异步读请求，性能比同步版本高3~5倍，更适合工业高频采样场景。

内容的提问来源于stack exchange，提问作者Alexander Veligorsky