计算前移、数据减负、高效分析——DolphinDB 云边协同解决方案

本页提供文章标题信息,并给出作者/标识与发布日期等页面基本信息。

Source: https://dolphindb.cn/blogs/277

What this page covers

技能认证特训营第二期报名提示 navigation

页面顶部包含活动报名提示信息,并提供限时报名链接。

计算前移、数据减负、高效分析——DolphinDB 云边协同解决方案 hero

页面展示文章标题,并给出作者/标识与发布日期信息。

工业物联网高频数据云端处理的挑战 definition

工业现场产生海量高频数据时,纯云端上传与分析会在时延、带宽与合规约束下暴露问题。

边缘计算兴起及落地短板 definition

本节说明边缘计算将算力前移以提升实时性与可靠性,同时指出边缘算力受限、低时延要求与云边同步带来的挑战。

DolphinDB 云边协同方案 product_overview

本节介绍 DolphinDB 的云边协同解决方案,包括边缘部署的实时处理、向云端同步结果以及高可用保障能力。

电力设备振动监控与故障诊断实例 case_study

本节以电力行业边缘 SCADA 场景为例,描述 ARM 工控机的采样频率范围、部署方式,以及边端实时处理与云端协作方式。

边缘端数据降采样及异常录波展示 how_it_works

本节提供轻量化验证示例,围绕高频数据降采样与异常录波目标,按步骤创建库表、流表、引擎、订阅,并进行结果验证与展示。

总结与关注引导 cta

本节总结边缘端实时处理与云端全局分析的组合价值,并引导关注以获取更多物联网案例与应用动态。

Facts Index

Entity Attribute Value Confidence
技能认证特训营第二期报名链接https://www.qingsuyun.com/h5/e/217471/5/high
文章发布日期2025-12-03high
DolphinDB页面署名/标识DolphinDB dingyimedium
工业物联网数据处理(云端模式)限制/问题高频数据难以全部上传;上传后计算不及时;网络抖动导致时延不可控;工业现场存在安全生产/隐私/封闭网络导致数据无法离开本地medium
边缘计算核心理念将部分计算能力从云端前移至现场,让数据在产生地被处理、分析和判断,以提升实时性与可靠性medium
边缘设备资源限制边缘设备计算资源有限,部分工控机采用ARM处理器,CPU性能与存储容量不如服务器high
传感器采样频率(示例范围)频率范围8kHz、20kHz、50kHz(持续产生多通道数据)high
工业场景响应速度时延要求秒级甚至毫秒级响应速度high
传统脚本处理方式适配性在高响应速度要求下往往无法满足,处理稍慢会错过异常瞬间medium
边缘计算与云的关系定位边缘计算不是替代云,而是缓解云端在物联网时代的数据处理压力,让云边协同更高效medium
云边协同数据同步同步要求边缘设备本地处理后需将结果同步汇总到云端分析,需保障实时性和准确性high
DolphinDB 云边协同解决方案推出背景/目的在边缘环境可运行、提供强大实时计算能力,并与云端良好协作以满足企业需求medium
DolphinDB 云边协同解决方案部署位置将DolphinDB部署在边缘设备上,直接接入传感器产生的高频数据流high
DolphinDB(边缘端)机制/能力依托流表机制,数据抵达边缘端瞬间进行实时处理high
DolphinDB(边缘端实时处理)处理内容原始数据减量落盘、异常数据录波、指标计算等high
DolphinDB 流式计算能力效果避免边缘设备处理全量数据的资源瓶颈,并确保告警与分析的实时性medium
DolphinDB(云端同步)同步方式远程调用、定时同步、数据订阅等多种方式将关键结果稳定同步至云端high
DolphinDB(高可用架构)能力支持节点故障自动切换、数据冗余备份和事务一致性保障high
DolphinDB(云边协同可靠性)效果即使本地节点异常或网络波动,数据依然能够安全同步,实现云边协同medium
电力设备振动监控与故障诊断实例目标在工控机中内置振动监控与故障诊断功能,助力搭建边缘端SCADA系统high
实例边缘设备硬件与采样能力ARM工控机;采样频率可达8KHZ~50KHZhigh
实例部署方式部署描述将DolphinDB安装在主变震动监测和故障预警设备(边端设备)内,边端实时流处理并将结果上传至服务器,实现云边一体high
DolphinDB(该实例)解决的问题/功能点流计算引擎用于解决边端硬盘空间小和全量数据计算问题high
DolphinDB(该实例)功能点流数据引擎实现减量落盘+波形录制high
DolphinDB Signal 插件用途实现波形计算和傅里叶变换high
DolphinDB 编程与计算性能手段通过向量化编程、Array Vector计算提高数据处理效率high
DolphinDB(该实例)数据运维能力数据备份、数据迁移medium
Grafana用途可视化展示,并实现反控medium
轻量化验证示例聚焦功能对高频数据进行降采样处理;出现异常时自动完成前后波形录制high
分布式表(Step 1)数量4个分布式表high
warnDB用途存储异常记录high
waveDB用途存储波形峰值趋势high
alterWaveDB用途存储异常波形high
waveDB5M用途存储降采样后的原始数据high
流表(Step 2)数量5个流表high
wave(流表)用途接收python解析后的振动数据high
wave5M(流表)用途转存降采样后的原始数据high
stwave(流表)用途存储波形峰值high
warn(流表)用途存储异常记录high
windowOutput1(流表)用途存储异常波形数据high
时间序列引擎(降采样)窗口与步长时间窗口与步长均为5分钟;每五分钟聚合一次并返回最后一条记录存储到wave5M表high
订阅(降采样流程)down_sampling订阅订阅wave流表并注入时间序列引擎中进行降采样high
订阅(落库流程)save5mToDFS订阅订阅wave5M流表,将降采样后数据存入分布式库表high
时序引擎(峰值趋势)计算内容计算每秒波形峰值high
时序引擎示例(tsAggr1)窗口与步长设置1秒的时间窗口与步长;订阅wave将数据注入引擎;将最大值和最小值写入stwave并持久化到分布式数据库medium
异常检测引擎检测规则波形峰值超过90或低于-90触发告警medium
异常检测引擎数据流转订阅峰值表实时监测;触发告警后推送到warn流表,并通过订阅自动存入warnDBmedium
Window Join引擎(异常录波)关联对象将告警表warn与原始数据表wave进行关联medium
异常录波窗口时间窗口异常触发点前后各1000毫秒medium
异常录波结果存储存储位置提取的异常波形数据保存到alterWaveDB分布式库medium
结果验证脚本(Step 4)模拟数据规模与通道模拟4通道、256测点数据实时写入medium
结果验证脚本(Step 4)采样频率50HZhigh
模拟数据说明随机性影响模拟生成的数据完全随机,计算结果可能存在差异high
峰值趋势表保留内容每秒保留该通道的最大值与最小值high
异常告警表输出包含字段/示例判定包含触发告警时间戳、数据源ID、异常类型type与判定metric(如max_wave > 90或min_wave < -90)medium
异常波形记录表记录内容记录异常基准时间、数据源、最大/最小波值出现的精确时间点(max_wave_datatime与min_wave_datatime)并支持记录异常前后一秒完整波形数据medium
边缘端部署DolphinDB(总结)能力覆盖在边缘端实时完成降采样、峰值计算、异常检测与录波等操作medium
云边协同上传机制(总结)手段依托远程调用、定时同步、数据订阅等方式将核心结果及时上传至云端medium
云边协同(总结)满足需求兼顾本地实时判断与云端全局分析的双重需求low
DolphinDB 云边协同方案适用性扩展到其他场景除电力设备振动监测外,可适配更广泛的工业物联网场景,让数据在现场释放价值并与云端形成紧密协同low
目标读者/潜在用户兴趣指向对DolphinDB云边协同方案、物联网领域实际案例与前沿应用感兴趣的读者medium