asyncua模块实现OPC UA通讯

2024-08-21 03:36
文章标签 模块 实现 通讯 ua opc asyncua

本文主要是介绍asyncua模块实现OPC UA通讯，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

asyncua是OPCUA的python实现，使用起来非常方便，其github地址是https://github.com/FreeOpcUa/opcua-asyncio

UaExpert是OPC UA Client的GUI工具，当编写好server代码后并运行，我们可以使用UaExpert去和server进行通信。UaExpert使用教程参考：https://blog.csdn.net/watsoncheung/article/details/124268979

1. OPCUA的两种工作方式

客户端/服务器模式：在这种模式下，OPC UA 客户端向 OPC UA 服务器请求数据，服务器接收请求并向客户端发送数据。

发布/订阅模式：在这种模式下，OPC UA 服务器将数据“发布”到网络上，而客户端可以“订阅”特定的数据。当服务器更新数据时，客户端会收到更新的数据。

这两种模式可以根据应用场景的需要进行选择。例如，客户端/服务器模式适用于客户端需要向服务器请求单个数据项的情况，而发布/订阅模式则适用于客户端需要定期接收大量数据的情况。

OPC UA Server示例代码：

import logging
import asyncio
from asyncua import Serverlogging.basicConfig(level=logging.INFO)
_logger = logging.getLogger('asyncua')async def main():# 创建serverserver = Server()# 初始化serverawait server.init()# 设置server的endpoint地址server.set_endpoint('opc.tcp://192.168.5.86:4840/freeopcua/server/')# 设置server的名字server.set_server_name('MyOPCUAServer')# 设置自己的namespace，也可以不做uri = 'http://examples.freeopcua.github.io'idx = await server.register_namespace(uri)# 在上面的namespace下添加一个对象，名叫MyObjectmyobj = await server.nodes.objects.add_object(idx, 'MyObject')# 在MyObject下添加一个变量，名叫MyVariable，初始值是6.7myvar = await myobj.add_variable(idx, 'MyVariable', 6.7)# 设置改变量为可写await myvar.set_writable()_logger.info('Starting server!')# 让server一直运行async with server:while True:await asyncio.sleep(1)if __name__ == '__main__':asyncio.run(main())

OPC UA Client示例代码：

import asyncio
from asyncua import Clientasync def main():url = 'opc.tcp://192.168.5.86:4840/freeopcua/server/'async with Client(url=url) as client:uri = 'http://examples.freeopcua.github.io'idx = await client.get_namespace_index(uri)var = await client.nodes.root.get_child(['0:Objects', f'{idx}:MyObject', f'{idx}:MyVariable'])print('My Variable', var, await var.read_value())if __name__ == '__main__':asyncio.run(main())

在asyncua模块中添加OPC UA（OLE for Process Control Unified Architecture）的发布订阅模式，通常涉及几个关键步骤：

  1. 创建OPC UA客户端：
  • 使用asyncua.Client类创建一个OPC UA客户端实例，并指定OPC UA服务器的URL。
  1. 创建订阅处理器：
  • 定义一个类作为订阅处理器，该类将处理从OPC UA服务器接收到的数据变化通知。
  • 在类中实现datachange_notification方法，该方法将在数据变化时被调用。
  1. 创建订阅：
  • 使用客户端实例的create_subscription方法创建一个订阅。
  • 传递订阅的发布间隔（以毫秒为单位）和之前定义的订阅处理器实例作为参数。
  1. 订阅节点：
  • 获取要订阅的OPC UA节点的引用。
  • 使用订阅实例的subscribe_data_change方法订阅这些节点。
  1. 处理订阅：
  • 在主循环中，使用await asyncio.sleep(some_interval)来保持程序运行，并允许异步事件（如数据变化通知）被处理。
  1. 异常处理和关闭：
  • 确保在退出程序时妥善处理任何异常，并正确关闭客户端和订阅。

发布/订阅模式，Client订阅数据改变代码示例：

from asyncua import Client, ua, Node  
import asyncio  class SubscriptionHandler:  def datachange_notification(self, node: Node, val, data):  print(f"Node '{node.nodeid}' value changed to {val}")  async def main():  url = 'opc.tcp://[OPC_UA_SERVER_IP]:[PORT]'  async with Client(url=url) as client:  handler = SubscriptionHandler()  subscription = await client.create_subscription(500, handler)  # 500ms 发布间隔  # 假设我们要订阅的节点ID  node_to_subscribe = "ns=2;s=SomeNodeToSubscribe"  node = client.get_node(node_to_subscribe)  await subscription.subscribe_data_change([node])  # 保持程序运行以接收通知  while True:  await asyncio.sleep(1)  if __name__ == "__main__":  asyncio.run(main())

2. OPC UA的一些基本概念

OPC UA地址空间中具有八种基本的节点类型，分别是数据节点、变量节点、对象节点、方法节点、引用节点、视图节点、变量类型和对象类型。每种节点对应的含义如图1所示。

数据类型节点(DataType)。数据类型节点描述了变量节点中变量的数据类型。在OPC UA信息模型在命名空间0中定义了多种内置的数据类型，包括整型、浮点型、字符串等多个类型，能对变量的数据进行准确的描述。也可以自定义数据类型，比如描述二维坐标的2DPoint，描述设备运行模式的MachieMode等类型，获得更符合数据本身的描述。

变量节点(Variable)。该节点是变量类型节点的实例，也是使用的最多的节点。客户端访问设备数据有3种方式。第一种是手动将设备多模态数据写入对应的变量节点，然后客户端读取对应节点内保存的数值。方式一缺点在于如果客户端要获取设备最新的值，需要一直手动去触发对设备数据源的读取请求。第二种方式通过给变量节点添加回调函数，在客户端发起读取请求后再由服务器向设备数据源发起读取请求，将取得的数据写入节点，再从节点读取数据发送到客户端中。方式二节省了无谓的读取消耗。第三种方式将客户端的读取请求直接重定向到设备的数据源中，即客户端直接从数据源获取数据，变量节点不存储数据。方式三缩减了数据先写入变量节点再进行读取的过程，但多个客户端连接访问同一数据时会增大服务器与设备之间的传输负载，而方式二中服务器可对时间戳进行判断后直接返回节点中保存的数据。在实际连接服务器与设备数据源的过程中，可以灵活结合方法二和方法三，方法一仅适用于极少数情况。

对象节点(Object)。将对象类型实例化即可得到对象节点，该节点是设备在数字空间的映射。所有对设备数据的访问都能在该模型中访问到对应的数据节点。所有对设备的控制都转换为方法节点的触发。设备产生的消息在节点对象中将触发对应的事件。

方法节点(Method)。方法节点是对设备控制方法在数字模型中的映射。方法节点可以通过服务器或客户端进行调用，然后将会对设备的控制器发送指令，使得设备执行对应的操作。常见的方法节点有，电机的正反转、点动、设备返回原点、伺服通断电等。

引用类型节点(ReferenceType)。引用类型描述了引用的语义，而引用用于定义引用两端的节点之间的关系。最常用的引用类型如层次结构引用节点(Organize)，表示节点之间的层级关系，如同文件夹与文件夹内的文件；数据层级复杂的设备，需要通过多种引用类型对设备信息节点之间的关系进行描述。

视图节点(View)。视图节点可将地址空间中感兴趣的节点提取出来，作为一个子集，视图节点作为该子集的入口，方便客户端浏览。
变量类型节点(VariableType)。该节点提供了对变量节点的定义，是设备中各种数据的抽象。常用引用中的对象类型定义引用节点(HasTypeDefinition)连接数据类型节点，对数据类型进行描述。用属性引用节点(HasProperty)对数据的语义进行描述。也可以使用自定义的数据类型节点对变量的数据进行描述，具有灵活性。

对象类型节点(ObjectType)。提供对象的定义，即对象的抽象，与类相当，且子类可以继承父类的特征，方便模型的扩充。该节点包括对象的各种数据类型，数据的语义，以及控制方式。OPC UA命名空间0中规定了多个基础的对象类型节点。如使用最广的基础对象类型(BaseObjectType)，所有对象类型节点都需要继承该节点再进行扩充。在对具体设备建模的过程中，应该将设备组成的各部分分解为不同的对象分别建模，再用引用节点将各部分按照实际设备中的关系相关联，从而得到完整设备的对象类型节点。

在这里插入图片描述

上述内容引用自专利《基于OPCUA协议的制造装备多模态数据智能解析方法》

OPC UA的建模实际上是节点与节点之间的引用，节点可以根据不同的用途归属于不同的节点类别。在OPC UA中，最重要的节点类别是对象、变量和方法。对象可以拥有变量和方法，而且可以触发事件。 （引用自专利《基于轨道交通的综合监控系统的事件存储方法及其设备》）

2.1 OPC UA的地址空间模型中，节点属性、变量和数据的区别

在OPC UA（OLE for Process Control Unified Architecture）的地址空间模型中，节点属性、变量和数据各自扮演着不同的角色，它们共同构成了OPC UA信息模型的基础。以下是关于这三者区别的详细解释：

  1. 节点属性（Attributes）：
  • 定义：属性用于描述节点的基本信息和特性。它们提供了关于节点类型、名称、描述、访问级别等的元数据。
  • 特点：
    • 是节点的基本组成部分之一，每个节点都可以有多个属性。
    • 属性的值可以是各种数据类型，如字符串、整数、浮点数等。
    • 属性是静态的，即它们的值在节点创建时确定，并且通常不会在节点的生命周期内改变。
  • 作用：属性帮助客户端理解和使用节点，提供了关于节点功能和行为的上下文信息。
  1. 变量（Variables）：
  • 定义：变量节点代表地址空间中的一个值，这个值可以被客户端读取、写入和订阅变化。
  • 特点：
    • 变量节点具有数据类型和值，数据类型定义了值的类型和格式。
    • 变量的值可以是简单的（如单个数值），也可以是复杂的（如结构体或数组）。
    • 变量的值在节点生命周期内是可以变化的，客户端可以实时获取这些变化。
  • 作用：变量用于表示工业自动化系统中的实时数据，如传感器读数、设备状态等。通过读取和写入变量值，客户端可以与服务器进行交互，实现数据的监控和控制。
  1. 数据（Data）：
  • 定义：在OPC UA中，“数据”通常指的是存储在变量节点中的值。这些数据可以是任何类型的信息，包括实时测量值、配置参数、事件通知等。
  • 特点：
    • 数据是动态的，可以随着工业自动化系统的运行而实时变化。
    • 数据的类型和格式由变量节点的数据类型决定。
    • 数据可以被客户端读取、写入和订阅变化，以实现数据的实时处理和响应。
  • 作用：数据是工业自动化系统的核心组成部分，它反映了系统的实时状态和运行情况。通过处理和分析这些数据，可以实现系统的监控、控制、优化和决策等功能。

总结：

  • 节点属性提供了关于节点的静态信息，用于描述节点的特性和行为。
  • 变量是地址空间中的动态元素，用于表示实时数据，并允许客户端与服务器进行交互。
  • 数据是存储在变量节点中的值，反映了工业自动化系统的实时状态和运行情况。

这三者共同构成了OPC UA地址空间模型的基础，为工业自动化系统中的通信和数据处理提供了强大的支持。

2.2 opcua节点类型枚举

opcua预定义的8种节点类型：
ObjectNode
ObjectTypeNode
VariableNode
VariableTypeNode
MethodNode
ReferenceTypeNode
DataTypeNode
ViewNode

2.3 opcua数据类型枚举

1. Null = 0
2. Boolean = 1
3. SByte = 2
4. Byte = 3
5. Int16 = 4
6. UInt16 = 5
7. Int32 = 6
8. UInt32 = 7
9. Int64 = 8
10. UInt64 = 9
11. Float = 10
12. Double = 11
13. String = 12
14. DateTime = 13
15. Guid = 14
16. ByteString = 15
17. XmlElement = 16
18. NodeId = 17
19. ExpandedNodeId = 18
20. StatusCode = 19
21. QualifiedName = 20
22. LocalizedText = 21
23. ExtensionObject = 222
4. DataValue = 23
25. Variant = 24
26. DiagnosticInfo = 25

#实例
1. ua.VariantType.Boolean
2. ua.VariantType.String
3. ua.VariantType.Int16
4. ua.VariantType.Int32
5. ua.VariantType.UInt32
6. ua.VariantType.Float
7. ua.VariantType.Byte

2.4 opcua节点规则

NodeId节点规则：ns=<命名空间索引>;<标识符类型>=<标识符>
命名空间索引：
ns表示命名空间索引，一般为2；通常，Namespace 0用于标准节点，Namespace 1用于服务器特定的节点 
标识符类型枚举:
i-数值
s-字符串
g-全局唯一标识符 (GUID) 
b-不透明值（ByteString 中的命名空间特定格式）

2.5 OPC UA的事件

OPC UA中的事件通常是通过订阅（Subscription）和监视项（MonitoredItem）来处理的，而不是通过直接的Event类。
以下是一个简化的步骤，展示了如何在OPC UA客户端中设置订阅和监视项以接收服务器上的事件。

  1. 连接到OPC UA服务器。
  2. 创建一个订阅（Subscription）。
  3. 在订阅中创建一个或多个监视项（MonitoredItem），指定要监视的节点（通常是事件源节点）。
  4. 等待并处理从服务器发送的事件通知。

2.6 OPC UA的监控项、订阅和通知

学习链接：https://www.cnblogs.com/jiyuqi/p/9639034.html

学习资料：https://github.com/FreeOpcUa/opcua-asyncio
OPCUA的Client监控Server的界面：https://github.com/FreeOpcUa/opcua-client-gui

这篇关于asyncua模块实现OPC UA通讯的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1092009。

相关文章

Qt使用QSqlDatabase连接MySQL实现增删改查功能

Qt使用QSqlDatabase连接MySQL实现增删改查功能

《Qt使用QSqlDatabase连接MySQL实现增删改查功能》这篇文章主要为大家详细介绍了Qt如何使用QSqlDatabase连接MySQL实现增删改查功能,文中的示例代码讲解详细,感兴趣的小伙伴... 目录一、创建数据表二、连接mysql数据库三、封装成一个完整的轻量级 ORM 风格类3.1 表结构
阅读更多...
基于Python实现一个图片拆分工具

基于Python实现一个图片拆分工具

《基于Python实现一个图片拆分工具》这篇文章主要为大家详细介绍了如何基于Python实现一个图片拆分工具,可以根据需要的行数和列数进行拆分,感兴趣的小伙伴可以跟随小编一起学习一下... 简单介绍先自己选择输入的图片，默认是输出到项目文件夹中，可以自己选择其他的文件夹，选择需要拆分的行数和列数，可以通过
阅读更多...
Python中将嵌套列表扁平化的多种实现方法

Python中将嵌套列表扁平化的多种实现方法

《Python中将嵌套列表扁平化的多种实现方法》在Python编程中,我们常常会遇到需要将嵌套列表（即列表中包含列表）转换为一个一维的扁平列表的需求,本文将给大家介绍了多种实现这一目标的方法,需要的朋... 目录python中将嵌套列表扁平化的方法技术背景实现步骤1. 使用嵌套列表推导式2. 使用itert
阅读更多...
Python使用pip工具实现包自动更新的多种方法

Python使用pip工具实现包自动更新的多种方法

《Python使用pip工具实现包自动更新的多种方法》本文深入探讨了使用Python的pip工具实现包自动更新的各种方法和技术,我们将从基础概念开始,逐步介绍手动更新方法、自动化脚本编写、结合CI/C... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核
阅读更多...
在Linux中改变echo输出颜色的实现方法

在Linux中改变echo输出颜色的实现方法

《在Linux中改变echo输出颜色的实现方法》在Linux系统的命令行环境下,为了使输出信息更加清晰、突出,便于用户快速识别和区分不同类型的信息,常常需要改变echo命令的输出颜色,所以本文给大家介... 目python录在linux中改变echo输出颜色的方法技术背景实现步骤使用ANSI转义码使用tpu
阅读更多...
Python使用python-can实现合并BLF文件

Python使用python-can实现合并BLF文件

《Python使用python-can实现合并BLF文件》python-can库是Python生态中专注于CAN总线通信与数据处理的强大工具,本文将使用python-can为BLF文件合并提供高效灵活... 目录一、python-can 库：CAN 数据处理的利器二、BLF 文件合并核心代码解析1. 基础合
阅读更多...
Python使用OpenCV实现获取视频时长的小工具

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文
阅读更多...
golang版本升级如何实现

golang版本升级如何实现

《golang版本升级如何实现》：本文主要介绍golang版本升级如何实现问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录golanwww.chinasem.cng版本升级linux上golang版本升级删除golang旧版本安装golang最新版本总结gola
阅读更多...
SpringBoot中SM2公钥加密、私钥解密的实现示例详解

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具
阅读更多...
Mysql实现范围分区表(新增、删除、重组、查看)

Mysql实现范围分区表(新增、删除、重组、查看)

《Mysql实现范围分区表(新增、删除、重组、查看)》MySQL分区表的四种类型（范围、哈希、列表、键值）,主要介绍了范围分区的创建、查询、添加、删除及重组织操作,具有一定的参考价值,感兴趣的可以了解... 目录一、mysql分区表分类二、范围分区（Range Partitioning1、新建分区表：2、分
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2