让PLC数据飞到数据库中 plc如何将数据写入sql数据库
xsobi 2024-12-17 17:06 2 浏览
前 言:
近年来。随着工业生产现场数据采集需求的增多,客户对于数据采集的方式也提出了多种要求。将PLC数据直接采集到数据库便是其中一种。
伟联科技WL-320E-M边缘计算模块支持对MySQL/SQLServer/Influxdb等数据库的增、删、查、改等基本操作。本文以MySQL为例介绍如何通过伟联科技边缘计算网关将PLC/仪表/DCS等现场生产设备的数据直接采集后存储到数据库中。这种采集和存储不会影响到生产现场PLC及SCADA系统。无需编写PLC程序和SCADA软件脚本。
MySQL数据库可以部署在边缘计算模块内,也可以位于局域网或云端。如果MySQL数据库不在边缘计算模块内部署,需要MySQL数据库开放局域网用户访问的权限。本文以MySQL 8.0为例。
在边缘计算模块中,有专门用于连接MySQL数据库的节点,在边缘计算模块左侧节点选择区域内,找到存储分组,拖拽mysql节点到流程图上,双击配置mysql连接信息。本文中已经在局域网内192.168.2.47/24地址的计算机上安装好了MySQL数据库,并且对root用户配置了局域网设备访问的权限,直接连接即可。
边缘计算模块除了可以将内部数据写入到数据库外,还可以将外部读取回来的PLC数据写入到数据库,该功能可作为数据采集利器实现多远数据采集后依次写入到数据库中,便于后期查看和利用。
在PLC数据写入数据库之前,需要设计数据库表的存储格式,一般对于PLC数据来说,可以存储为行表格式或列表格式。
行表格式:以时间、标签名、标签值最为字段,每个标签及数值作为记录存储到数据库表中。如下:
列表格式:以时间、每个标签名为字段,每个标签及数值作为记录存储到数据库表中。如下:
用户可根据自己实际需要选择数据存储方式,两种方式在读取数据库时SQL语句不同,其余无实质差异。本文中以列表格式举例说明。
在名为wiscada的数据库中创建一个名为PLCData的表
create table wiscada.PLCData (id bigint not null
auto_increment,RecordTime datetime,TestFloat_0 real,TestFloat_1
real,TestFloat_2 real,TestFloat_3 real,TestFloat_4 real,primary key(id))
ENGINE = innodb default charset=utf8mb4;
该语句意思为在wiscada数据库内创建名为PLCData的表,该表包含字段id(bigint数据类型,不允许空值,自动增加)、字段RecordTime(datetime类型,不允许空值)、字段TestFloat_0-TestFloat_4(real类型,不允许空值),另外该表的主键为字段id。
特别注意:本文中只创建了以上几个字段示例,更多的字段需要手动增加到创建表的语句中,在使用列表格式记录时,务必要提前规划好字段名称和字段数量,提前将使用到的字段都添加进去,后期增加会影响之前的数据记录。
也可以使用MySQL Workbench软件通过图形化方式创建数据表。
执行完毕后可以看到已经创建了数据表
数据表创建完成后,可以使用边缘计算模块向该表内写数据。
本例中以Rockwell L33ERM型号PLC为数据采集节点,将PLC内数据采集后插入到MySQL数据库中,实现连续稳定插入。
PLC IP地址为192.168.2.250/24,使用eth ip in节点先将PLC内数据读取回来。
配置ETH-ip in节点读取数据,本文读取100个标签。
使用debug节点可以看到读取回来的数据
读回来的数据为对象类型,每一个PLC标签都是一个对象元素。
注意:在使用边缘计算模块向数据库内写数据的时候,需要注意写入的频率,这个频率一方面会影响到数据库的记录量,另一方面,太快的频率有可能会导致数据库响应缓慢。因此,需要使用一种方法控制写入数据库的节奏。
使用inject节点的周期性触发并输出自定义信号功能和function节点自定义JS函数的功能以及WiEdge系统内全局变量特性,配合起来可实现任意时间周期触发数据记录到数据库。
节点排布如下:
其中,读取PLC数据节点配置参考本文不在赘述。
写数据控制为inject节点,周期性输出方式,本文定义周期输出RecordStart字符串:
Function节点为整理接收的PLC数据为到SQL语句内,本文使用代码如下:
var CurTime //定义当前时间变量
var strSQL //定义变量
//定义全局变量存储标签值,有多少向数据库写的标签就需要定义多少这种全局变量
var TestFloat_0 = context.get('TestFloat_0')
var TestFloat_1 = context.get('TestFloat_1')
var TestFloat_2 = context.get('TestFloat_2')
var TestFloat_3 = context.get('TestFloat_3')
var TestFloat_4 = context.get('TestFloat_4')
//判断当前接受的消息是否是记录触发消息
if(msg.payload == "RecordStart")
{
msg.payload = null; //如果是记录触发消息,则清除该消息,不返回任何结果
RecordTag() //调用记录子函数
return msg; //函数节点输出
}
else //如果接收的消息不是记录触发消息,为正常的数据,将消息传递给全局变量
{
TestFloat_0 = msg.payload["TsetFloat[0]"]; //获取上一节点读取到的标签值
TestFloat_1 = msg.payload["TsetFloat[1]"]; //获取上一节点读取到的标签值
TestFloat_2 = msg.payload["TsetFloat[2]"]; //获取上一节点读取到的标签值
TestFloat_3 = msg.payload["TsetFloat[3]"]; //获取上一节点读取到的标签值
TestFloat_4 = msg.payload["TsetFloat[4]"]; //获取上一节点读取到的标签值
context.set('TestFloat_0',TestFloat_0) //将获取的消息传递给全局变量
context.set('TestFloat_1',TestFloat_1)
context.set('TestFloat_2',TestFloat_2)
context.set('TestFloat_3',TestFloat_3)
context.set('TestFloat_4',TestFloat_4)
}
//定义数据记录子函数
function RecordTag()
{
CurTime = getCurrentDate(2) //取精确到秒的日期时间
strSQL="insert into PLCData (RecordTime,TestFloat_0,TestFloat_1,TestFloat_2,TestFloat_3,TestFloat_4) values ( '" + CurTime + "'," + TestFloat_0 + "," + TestFloat_1 + "," + TestFloat_2 + "," + TestFloat_3 + "," + TestFloat_4 + ")" //举例SQL语句
msg.payload = strSQL //将SQL语句返回给节点输出函数
}
function getCurrentDate(format) //获取当前日期时间函数
{
var now = new Date();
var year = now.getFullYear(); //得到年份
var month = now.getMonth();//得到月份
var date = now.getDate();//得到日期
var day = now.getDay();//得到周几
var hour = now.getHours();//得到小时
var minu = now.getMinutes();//得到分钟
var sec = now.getSeconds();//得到秒
month = month + 1;
if (month < 10) month = "0" + month;
if (date < 10) date = "0" + date;
if (hour < 10) hour = "0" + hour;
if (minu < 10) minu = "0" + minu;
if (sec < 10) sec = "0" + sec;
var time = "";
//精确到天
if(format==1){
time = year + "-" + month + "-" + date;
}
//精确到分
else if(format==2){
time = year + "-" + month + "-" + date+ " " + hour + ":" + minu + ":" + sec;
}
return time;
}
传递SQL语句节点为change节点
最后为MySQL连接节点。
注意,读取其他PLC时,与本文类似,主要判断其他PLC节点读取后输出的结果类型。
在MySQL数据库里面查看写入的数据,本文以5秒周期记录PLC数据到数据库。
在实际使用中,需要估算数据库存储一定时间后占用计算机硬盘的大小,数据库本身会压缩数据,所以,以测试记录一定时间后查看实际占用硬盘的数据估算最为准确。
//以下代码在MySQL管理器里面运行即可,注意单引号类型,必须为英文格式
查看MySQL内数据库占用硬盘大小
SELECT CONCAT(TRUNCATE(SUM(data_length)/1024/1024,2),'MB') AS data_size,
CONCAT(TRUNCATE(SUM(max_data_length)/1024/1024,2),'MB') AS max_data_size,
CONCAT(TRUNCATE(SUM(data_free)/1024/1024,2),'MB') AS data_free,
CONCAT(TRUNCATE(SUM(index_length)/1024/1024,2),'MB') AS index_size
FROM information_schema.tables WHERE TABLE_SCHEMA = 'wiscada'
代码中,wiscada为MySQL数据库名
查看MySQL内某个表占用硬盘大小
//以下代码在MySQL管理器里面运行即可,注意单引号类型,必须为英文格式
SELECT CONCAT(TRUNCATE(SUM(data_length)/1024/1024,2),'MB') AS data_size,
CONCAT(TRUNCATE(SUM(max_data_length)/1024/1024,2),'MB') AS max_data_size,
CONCAT(TRUNCATE(SUM(data_free)/1024/1024,2),'MB') AS data_free,
CONCAT(TRUNCATE(SUM(index_length)/1024/1024,2),'MB') AS index_size
FROM information_schema.tables WHERE TABLE_NAME = 'plcdata'
代码中,plcdata为MySQL内数据库表名称
获取表或者数据库在一定时间内占用硬盘情况后,可计算机几年内总共会占用多少硬盘。
未完待续
相关推荐
- 好用的云函数!后端低代码接口开发,零基础编写API接口
-
前言在开发项目过程中,经常需要用到API接口,实现对数据库的CURD等操作。不管你是专业的PHP开发工程师,还是客户端开发工程师,或者是不懂编程但懂得数据库SQL查询,又或者是完全不太懂技术的人,通过...
- 快速上手:Windows 平台上 cURL 命令的使用方法
-
在工作流程中,为了快速验证API接口有效性,团队成员经常转向直接执行cURL命令的方法。这种做法不仅节省时间,而且促进了团队效率的提升。对于使用Windows系统的用户来说,这里有一套详细...
- 使用 Golang net/http 包:基础入门与实战
-
简介Go的net/http包是构建HTTP服务的核心库,功能强大且易于使用。它提供了基本的HTTP客户端和服务端支持,可以快速构建RESTAPI、Web应用等服务。本文将介绍ne...
- #小白接口# 使用云函数,人人都能编写和发布自己的API接口
-
你只需编写简单的云函数,就可以实现自己的业务逻辑,发布后就可以生成自己的接口给客户端调用。果创云支持对云函数进行在线接口编程,进入开放平台我的接口-在线接口编程,设计一个新接口,设计和配置好接口参...
- 极度精神分裂:我家没有墙面开关,但我虚拟出来了一系列开关
-
本内容来源于@什么值得买APP,观点仅代表作者本人|作者:iN在之前和大家说过,在iN的家里是没有墙面开关的。...
- window使用curl命令的注意事项 curl命令用法
-
cmd-使用curl命令的注意点前言最近在cmd中使用curl命令来测试restapi,发现有不少问题,这里记录一下。在cmd中使用curl命令的注意事项json不能由单引号包括起来json...
- Linux 系统curl命令使用详解 linuxctrl
-
curl是一个强大的命令行工具,用于在Linux系统中进行数据传输。它支持多种协议,包括HTTP、HTTPS、FTP等,用于下载或上传数据,执行Web请求等。curl命令的常见用法和解...
- Tornado 入门:初学者指南 tornados
-
Tornado是一个功能强大的PythonWeb框架和异步网络库。它最初是为了处理实时Web服务中的数千个同时连接而开发的。它独特的Web服务器和框架功能组合使其成为开发高性能Web...
- PHP Curl的简单使用 php curl formdata
-
本文写给刚入PHP坑不久的新手们,作为工具文档,方便用时查阅。CURL是一个非常强大的开源库,它支持很多种协议,例如,HTTP、HTTPS、FTP、TELENT等。日常开发中,我们经常会需要用到cur...
- Rust 服务器、服务和应用程序:7 Rust 中的服务器端 Web 应用简介
-
本章涵盖使用Actix提供静态网页...
- 我给 Apache 顶级项目提了个 Bug apache顶级项目有哪些
-
这篇文章记录了给Apache顶级项目-分库分表中间件ShardingSphere提交Bug的历程。说实话,这是一次比较曲折的Bug跟踪之旅。10月28日,我们在GitHub上提...
- linux文件下载、服务器交互(curl)
-
基础环境curl命令描述...
- curl简单使用 curl sh
-
1.curl--help#查看关键字2.curl-A“(添加user-agent<name>SendUser-Agent<name>toserver)”...
- 常用linux命令:curl 常用linux命令大全
-
//获取网页内容//不加任何选项使用curl时,默认会发送GET请求来获取内容到标准输出$curlhttp://www.baidu.com//输出<!DOCTYPEh...
- 三十七,Web渗透提高班之hack the box在线靶场注册及入门知识
-
一.注册hacktheboxHackTheBox是一个在线平台,允许测试您的渗透技能和代码,并与其他类似兴趣的成员交流想法和方法。它包含一些不断更新的挑战,并且模拟真实场景,其风格更倾向于CT...
- 一周热门
- 最近发表
-
- 好用的云函数!后端低代码接口开发,零基础编写API接口
- 快速上手:Windows 平台上 cURL 命令的使用方法
- 使用 Golang net/http 包:基础入门与实战
- #小白接口# 使用云函数,人人都能编写和发布自己的API接口
- 极度精神分裂:我家没有墙面开关,但我虚拟出来了一系列开关
- window使用curl命令的注意事项 curl命令用法
- Linux 系统curl命令使用详解 linuxctrl
- Tornado 入门:初学者指南 tornados
- PHP Curl的简单使用 php curl formdata
- Rust 服务器、服务和应用程序:7 Rust 中的服务器端 Web 应用简介
- 标签列表
-
- grid 设置 (58)
- 移位运算 (48)
- not specified (45)
- patch补丁 (31)
- strcat (25)
- 导航栏 (58)
- context xml (46)
- scroll (43)
- element style (30)
- dedecms模版 (53)
- vs打不开 (29)
- nmap (30)
- webgl开发 (24)
- parse (24)
- c 视频教程下载 (33)
- paddleocr (28)
- listview排序 (33)
- firebug 使用 (31)
- transactionmanager (30)
- characterencodingfilter (33)
- getmonth (34)
- commandtimeout (30)
- hibernate教程 (31)
- label换行 (33)
- curlpost (31)