免费OPCUA Python多订阅

Question

我正在为 python opcua github 使用最小的示例客户端和服务器，我似乎无法弄清楚如何以不同的时间间隔订阅多个变量。我想做的是以高频率更新某些值，而以低得多的频率更新其他值。

我通过将列表传递给成功

handle = sub.subscribe_data_change(monitoredNodes)

monitoredNodes 是 nodeID 的列表。

但是，如果在 subHandler 中触发数据更改事件，则列表中的任何变量都会发生更改，并且我正在使用 if 语句来确定哪个变量发生了更改。如果我想订阅 1000 个变量，为每个事件运行 100 个 if 语句似乎很麻烦且效率低下。

如果有人对此有任何经验，我很想在这里如何正确处理。下面是我稍微修改的示例客户端的代码。

import sys
sys.path.insert(0, "..")
import re
from IPython import embed


from opcua import Client

def getChildren(node):
 children = extractName(root.get_child(node).get_children_descriptions())
 return children

def extractName(description):
 qualifiedNames = re.findall(r"QualifiedName\(.*?\)", str(description))
 nodeNames = re.findall("\d:[a-z,A-Z_]*", str(qualifiedNames))
 return nodeNames

class SubHandler(object):

def datachange_notification(self, node, val, data):
    pass
    #print("Python: New data change event", node, val)

def event_notification(self, event):
    print("Python: New event", event)


if __name__ == "__main__":

client = Client("opc.tcp://0.0.0.0:4840/freeopcua/server/")
try:
    client.connect()
    # Client has a few methods to get proxy to UA nodes that should always be in address space such as Root or Objects
    root = client.get_root_node()
    print("Objects node is: ", root.get_browse_name())

    # Node objects have methods to read and write node attributes as well       as browse or populate address space
    print("Children of root are: ", root.get_children())

    rootNode = extractName(str(root.get_children_descriptions()))
    print(rootNode)
    print('''
    The following nodes are found on root.
    Press enter the corresponding number to go deeper.
    ''')
    path = ['0:Objects']
    children=[]

    while True:
        for node in enumerate(getChildren(path)):
            print(node[0], ": ", node[1])
        print("Enter 99 to exit or 88 to go back to top")
        sel = int(input('Please make a selection\n' ))
        if sel == 99:
            break
        elif sel == 88:
            path = []
            children = []
        elif sel == 11:
            print(path)
            print(root.get_child(path).get_value())
            print(root.get_child(path))
        else:
            if path == []:
                path.append(rootNode[sel])
                #print(path)
                #print(getChildren(path))
            else:
                children = getChildren(path)
                path.append(children[sel])
                #print(getChildren(path))

    # Now getting a variable node using its browse path
    myvar = root.get_child(["0:Objects", "2:MyObject", "2:MyVariable"])
    obj = root.get_child(["0:Objects", "2:MyObject"])
    print("myvar is: ", myvar.get_value())

    # subscribing to a variable node
    handler = SubHandler()
    sub = client.create_subscription(500, handler)
    handle = sub.subscribe_data_change(myvar)

    embed()
finally:
    client.disconnect()

Answer 1

好的，对于任何尝试做我想做的事情并遇到问题的人。我认为对只想更新特定间隔的变量使用订阅不是正确的方法。似乎通过订阅一个变量，您将获得该变量的每一个变化。如果您的订阅期长于其更改的速率，则更改事件将触发多次，其中包含自上次更新以来的所有历史更改。这不是我想要的。

相反，我建议在 python 的 apscheduler 模块中使用类似的计时器任务，并定期读取变量。这似乎符合我的要求。