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。

相关文章

Python pyinstaller实现图形化打包工具

Python pyinstaller实现图形化打包工具

《Pythonpyinstaller实现图形化打包工具》：本文主要介绍一个使用PythonPYQT5制作的关于pyinstaller打包工具,代替传统的cmd黑窗口模式打包页面,实现更快捷方便的... 目录1.简介2.运行效果3.相关源码1.简介一个使用python PYQT5制作的关于pyinstall
阅读更多...
使用Python实现大文件切片上传及断点续传的方法

使用Python实现大文件切片上传及断点续传的方法

《使用Python实现大文件切片上传及断点续传的方法》本文介绍了使用Python实现大文件切片上传及断点续传的方法,包括功能模块划分（获取上传文件接口状态、临时文件夹状态信息、切片上传、切片合并）、整... 目录概要整体架构流程技术细节获取上传文件状态接口获取临时文件夹状态信息接口切片上传功能文件合并功能小
阅读更多...
python实现自动登录12306自动抢票功能

python实现自动登录12306自动抢票功能

《python实现自动登录12306自动抢票功能》随着互联网技术的发展,越来越多的人选择通过网络平台购票,特别是在中国,12306作为官方火车票预订平台,承担了巨大的访问量,对于热门线路或者节假日出行... 目录一、遇到的问题？二、改进三、进阶–展望总结一、遇到的问题？1.url-正确的表头：就是首先ur
阅读更多...
C#实现文件读写到SQLite数据库

C#实现文件读写到SQLite数据库

《C#实现文件读写到SQLite数据库》这篇文章主要为大家详细介绍了使用C#将文件读写到SQLite数据库的几种方法,文中的示例代码讲解详细,感兴趣的小伙伴可以参考一下... 目录1. 使用 BLOB 存储文件2. 存储文件路径3. 分块存储文件《文件读写到SQLite数据库China编程的方法》博客中，介绍了文
阅读更多...
Redis主从复制实现原理分析

Redis主从复制实现原理分析

《Redis主从复制实现原理分析》Redis主从复制通过Sync和CommandPropagate阶段实现数据同步,2.8版本后引入Psync指令,根据复制偏移量进行全量或部分同步,优化了数据传输效率... 目录Redis主DodMIK从复制实现原理实现原理Psync: 2.8版本后总结Redis主从复制实
阅读更多...
JAVA利用顺序表实现“杨辉三角”的思路及代码示例

JAVA利用顺序表实现“杨辉三角”的思路及代码示例

《JAVA利用顺序表实现“杨辉三角”的思路及代码示例》杨辉三角形是中国古代数学的杰出研究成果之一,是我国北宋数学家贾宪于1050年首先发现并使用的,：本文主要介绍JAVA利用顺序表实现杨辉三角的思... 目录一：“杨辉三角”题目链接二：题解代码：三：题解思路：总结一：“杨辉三角”题目链接题目链接：点击这里
阅读更多...
Node.js 中 http 模块的深度剖析与实战应用小结

Node.js 中 http 模块的深度剖析与实战应用小结

《Node.js中http模块的深度剖析与实战应用小结》本文详细介绍了Node.js中的http模块,从创建HTTP服务器、处理请求与响应,到获取请求参数,每个环节都通过代码示例进行解析,旨在帮... 目录Node.js 中 http 模块的深度剖析与实战应用一、引言二、创建 HTTP 服务器：基石搭建（一
阅读更多...
基于Python实现PDF动画翻页效果的阅读器

基于Python实现PDF动画翻页效果的阅读器

《基于Python实现PDF动画翻页效果的阅读器》在这篇博客中,我们将深入分析一个基于wxPython实现的PDF阅读器程序,该程序支持加载PDF文件并显示页面内容,同时支持页面切换动画效果,文中有详... 目录全部代码代码结构初始化 UI 界面加载 PDF 文件显示 PDF 页面页面切换动画运行效果总结主
阅读更多...
SpringBoot实现基于URL和IP的访问频率限制

SpringBoot实现基于URL和IP的访问频率限制

《SpringBoot实现基于URL和IP的访问频率限制》在现代Web应用中,接口被恶意刷新或暴力请求是一种常见的攻击手段,为了保护系统资源,需要对接口的访问频率进行限制,下面我们就来看看如何使用... 目录1. 引言2. 项目依赖3. 配置 Redis4. 创建拦截器5. 注册拦截器6. 创建控制器8.
阅读更多...
React实现原生APP切换效果

React实现原生APP切换效果

《React实现原生APP切换效果》最近需要使用Hybrid的方式开发一个APP,交互和原生APP相似并且需要IM通信,本文给大家介绍了使用React实现原生APP切换效果,文中通过代码示例讲解的非常... 目录背景需求概览技术栈实现步骤根据 react-router-dom 文档配置好路由添加过渡动画使用
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2