python工业互联网监控项目实战5—Collector到opcua服务

　　本小节演示项目是如何从连接器到获取Tank4C9服务上的设备对象的值，并通过Connector服务的url返回给UI端请求的。另外，实际项目中考虑websocket中间可能因为网络通信等原因出现中断情况，我们增加一个“心跳”设计来定时发送连接请求，确保出现冲断的情况下，能够重新连接到服务端。

1. OPCUA-Client读取OPCUA服务Tag值

 　　现在重构Connector APP views文件里的pushCollectorData函数，通过引入OPCUA-Client来读取OPCUA服务端的Tag值，代码如下： 

from django.shortcuts import render
from django.http import HttpResponse
import json
from dwebsocket.decorators import accept_websocket
from opcua import Client #引入 opcua-client
@accept_websocket   
def pushCollectorData(request):

    tank4C9={            
        'DeviceId': 1,
        'DeviceName':'1#反应罐',
        'Status': 0, #设备运行状态
        'OverheadFlow':0 ,#'顶流量',
        'ButtomsFlow': 0, #'低流量'
        'Power': 0, #功率
    }
    Collector={
            'CollectorId': 1,
            'CollectorName':'1#采集器',
            'Status': 0,
            'DeviceList':[tank4C9],
            } 
    Collector={
         'CollectorId': 1,
         'CollectorName':'1#采集器',
         'Status': 0,
         'DeviceList':[tank4C9],
         }  

    if request.is_websocket():
        #创建opcua-client
        client = Client("opc.tcp://localhost:4840/freeopcua/server/") 
        client.connect() #连接服务器
        try:
            while True:  

                root = client.get_root_node() #获取OPCUA服务根节点
                #获取Tank4C9子节点的所有变量
                items = root.get_child(["0:Objects", "2:Tank4C9"]).get_children() 
                for item in items:
                    #给字典赋读取opcua服务tag当前值
                    tank4C9[item.get_display_name().Text]=item.get_value() 

                request.websocket.send(
                    json.dumps( {"rows":[Collector],'total':1}))
                time.sleep(2)
 
        finally:
            client.disconnect()

 　　代码改动并不大，数据获取从原来的OPC DA切换到了OPC UA组件，从前面的章节起笔者就奉行迭代推进的思路，好的代码结构（组织）会让后面的升级重构非常的方便，实际项目中减少很多工作量。 

2. 运行调试

　　首先，我们在集成开发环境VS Community 2019 选择CollectorSvr项目，右键在python环境启动运行CollectorSvr项目，如下图：

 　　然后，F5调试默认服务端项目Tank4C9Svr。我们即可通过浏览器访问监控页面

　　url：http://127.0.0.1:8090/tank4C9/ 运行效果如下图：

 3. 客户端心跳机制

　　本章节我们在UI端增加一个与服务端心跳检测函数，当websocket网络通信故障或其它原因不能正常传输数据时，UI端能够重新创建连接来确保系统可靠性的手段。UI端保存一个最后更新时间的变量，心跳检测时查看当前时间-最后更新时间大于30秒时，就关闭当前连接重新创建一个新得websocket连接获取数据，这样就确保了websocket出现其它原因断开后，保证能够自动重新连接并刷新数据得机制。

　　更多得看代码吧如下

<script>
//JQuery 代码入口
        $(document).ready(function () {
            getData()
            //设置心跳检测时间
            setInterval("heartbeat(window.ws,window.lastUpdateTime)",30000);

 
        });


        function heartbeat(ws,lastUpdateTime) {
            var time = new Date();
            if ((time.getTime() - lastUpdateTime > 30000)) {
                //最后更新时间与当前检查时间大于30秒，关闭连接重新创建并获取数据
                if(ws) 
                    ws.close();//关闭连接

                getData();
            } 
        }



        function getData() {
           if ("WebSocket" in window) {
               //连接server--TagCurValue

                window.ws = new WebSocket("ws://127.0.0.1:8090/pushCollectorData/");
                window.lastUpdateTime = new Date().getTime()
                ws.onmessage = function (evt) {
                    //最后更新时间戳
                    lastUpdateTime = new Date().getTime()
                    // 接收数据
                    d = JSON.parse(evt.data);
                    collector = d.rows[0]
                    tank4C9 = collector.DeviceList[0]

                    $("#OverheadFlow").html(tank4C9.OverheadFlow);
                    $("#ButtomsFlow").html(tank4C9.ButtomsFlow);
                    $("#Power").html(tank4C9.Power);


                };

            } 
    }

    </script>

4. 小结

　　本章节代码的改动不大，一个改动是切换到了OPC UA，另一个是增加了心跳检测函数，这个两个看似不大的改动，尤其心跳函数在实际项目中作用非常大，工业监控画面，如果出现长时间的数据不刷新（仅仅是插拔了一下电脑网线）画面不能自动连接到服务端刷新数据，现场管理员就看不到数据的变化，画面就不能真实的反应设备运行情况，这个在实际项目中是不能被客户接受的。OPC UA 的升级让体系可以逐步演进到新的架构下，却不会导致客户端任何调整，这个就是好的分层架构的优势，早些年笔者经历的很多项目都是从后台改到前台，并测试发布才能更新功能。

5.后记

　　python开发工业监控系列文章到本章节就告以段落了，这个系列带着大家从技术原型的探索到项目实战，从一个简单监控页面开始一步一步的也演示了项目迭代的实际过程，笔者的项目最佳实践准则：敏捷开发，有一个基本的功能蓝图后，从简设计、开发、迭代、重构、单元测试、集成测试和发布等环环相扣。同时，采用一个好的可繁可简的技术体系对持续改进非常重要，笔者转换python体系以来，越发喜欢上开源社区，互联网开发架构也会给传统企业软件开发领域带来新的机遇，尤其国家大力推进的工业互联网时代，期待python开发生态会带给我们更多的惊喜。

　　这里的案例UI比较简单，实际的项目可能还会设计APP UI，或者更发杂的web 3D界面等，但是总体来说服务端的架构思路是不变的，开发设计的分层（逻辑分层）是好的技术架构的重要体现。本序列文章我们更多的着重在监控界面上，没有交代业务逻辑和模型层面的知识，下一个系列笔者计划更多的着重在业务逻辑和模型层。