【Python】OPC UA 服务器与客户端的实现_python的opcua通讯源码

 在工业自动化领域，OPC UA已经成为了一种广泛采用的通信协议。它提供了一种标准化、跨平台的通信方式，允许不同厂商的设备和系统之间进行数据交换。本文将介绍如何使用Python的opcua库来创建一个简单的OPC UA服务器和客户端。

OPC UA服务器

 首先，我们创建一个OPC UA服务器。这个服务器会在本地端口4840上监听连接请求。它定义了一个名为“Sinumerik”的对象，并在该对象下添加了三个变量（RandomValue1、RandomValue2和RandomValue3）。这些变量的值会每5秒更新一次，取值为0到100的随机整数。

from opcua import Server
import random
import time
# 创建并配置服务器
server = Server()
server.set_endpoint("opc.tcp://0.0.0.0:4840")
idx = server.register_namespace("http://examples.sinumerik")
# 添加对象和变量
objects_node = server.get_objects_node()
myobj = objects_node.add_object(idx, "Sinumerik")
var1 = myobj.add_variable(idx, "RandomValue1", 0)
var2 = myobj.add_variable(idx, "RandomValue2", 0)
obj = myobj.add_object(idx, "Test")
var3 = obj.add_variable(idx, "RandomValue3", 0)
# 启动服务器
server.start()
print("Server started at opc.tcp://0.0.0.0:4840")
# 无限循环，更新变量值
try:
    while True:
        var1.set_value(random.randint(0, 100))
        var2.set_value(random.randint(0, 100))
        var3.set_value(random.randint(0, 100))
        print("Variables updated")
        time.sleep(5)
except KeyboardInterrupt:
    server.stop()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

OPC UA客户端

 接下来，我们实现一个OPC UA客户端。这个客户端会连接到我们刚刚创建的服务器，并读取“Sinumerik”对象下的所有变量。读取到的数据会被写入到一个CSV文件中，每5秒更新一次。

import csv
from datetime import datetime
import os
import time
from opcua import Client, ua
# 创建客户端并连接到服务器
client = Client("opc.tcp://localhost:4840/")
client.connect()
# 获取服务器对象节点
objects = client.get_objects_node()
sinumerik_node = objects.get_child(["2:Sinumerik"])
# 遍历所有子节点并返回变量节点的路径和数值
def get_variables(node, path=""):
    variables = {}
    children = node.get_children()
    for child in children:
        new_path = f"{path}/{child.get_browse_name().Name}"
        if child.get_node_class() == ua.NodeClass.Variable:
            value = child.get_value()
            variables[new_path] = value
        else:
            variables.update(get_variables(child, new_path))
    return variables
# 处理CSV文件
filename = 'opcua_data.csv'
if os.path.exists(filename):
    modification_time = os.path.getmtime(filename)
    modification_time_str = datetime.fromtimestamp(modification_time).strftime('%Y%m%d%H%M%S')
    new_filename = f"{filename}_{modification_time_str}"
    os.rename(filename, new_filename)
# 写入数据到CSV文件
with open(filename, mode='w', newline='') as csvfile:
    first_run = True
    try:
        while True:
            variables = get_variables(sinumerik_node)
            if first_run:
                fieldnames = variables.keys()
                writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
                writer.writeheader()
                first_run = False
            if writer:
                writer.writerow(variables)
                csvfile.flush()
            time.sleep(5)
    except KeyboardInterrupt:
        client.disconnect()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

 通过以上代码，我们创建了一个简单的OPC UA服务器和客户端。服务器定期更新变量的值，而客户端则定期读取这些值并保存到CSV文件中。这只是一个起点，你可以根据实际需求对代码进行扩展和优化。希望这篇文章能帮助你快速入门OPC UA的Python编程。