写点什么

使用数据湖工厂(DLF)搭建数据中心实时告警平台

  • 2020-03-30
  • 本文字数:2387 字

    阅读完需:约 8 分钟

使用数据湖工厂(DLF)搭建数据中心实时告警平台

场景

一个数据中心部署了很多应用,需要建立统一的运维系统,实时接收应用的告警信息,如果告警级别严重以上,给用户发送一条信息,同时每天出一个运维报表,统计各应用各个级别告警的数据。

实现方案

数据中心的告警数据通过 DIS 实时导入 CS 实时流处理,CS 对告警数据进行数据清洗和预处理,当告警级别超过一定级别时实时给用户发送短信。同时清洗过的数据进入 DIS 通道,DIS 根据导入时间将告警数据按日期目录存放到 OBS。



执行 DLI SQL 按天建 DLI 告警表分区,分区添加后统计告警记录到告警统计表。DLI SQL 执行完成后,通过 CDM 统一导出到 MYSQL 数据库。以上操作过程在 DLF 服务上完成。DLF 脚本开发中完成 DLI SQL 的开发。开发完成以后,DLI SQL 节点关联开发的 DLI SQL 脚本。DLI SQL 节点后连接 CDM 节点将数据导出到 MYSQL 数据库。最后配置 DLF 作业的调度周期为天,调度时间为凌晨 2 点。


实施步骤

1.创建 2 个 DIS 通道

①创建 2 个 OBS 目录,一个告警表目录 alarm_info,一个告警统计表目录 alarm_count_info。


②建立 2 个 DIS 通道,dis-alarm-input 和 dis-alarm-output。




③dis-alarm-output 通道配置转储


2.创建 SMN

①创建一个 SMN 主题 alarm_over



②添加订阅,在订阅终端输入要接收通知的手机号码


3.创建 CS 作业

创建一个 FLink SQL 作业,在 SQL 编辑器中输入如下:


CREATE SOURCE STREAM alarm_info (  alarm_id STRING,  alarm_type INT)WITH (  type = "dis",  region = "cn-north-1",  channel = "dis-alarm-input",  partition_count = "1",  encode = "csv",  field_delimiter = ",");CREATE SINK STREAM over_alarm (  alarm_over STRING /* over speed message */)WITH (  type = "smn",  region = "cn-north-1",  topic_urn = "urn:smn:cn-north-1:6f2bf33af5104f45ab85de31d7841f5a:alarm_over",  message_subject = "alarm",  message_column = "alarm_over");INSERT INTO over_alarmSELECT "your alarm over (" || CAST(alarm_type as CHAR(20)) || ") ."FROM alarm_infoWHERE alarm_type > 8;CREATE SINK STREAM alarm_info_output (  alarm_id STRING,  alarm_type INT)WITH (  type ="dis",  region = "cn-north-1",  channel = "dis-alarm-output",  PARTITION_KEY = "alarm_type",  encode = "csv",  field_delimiter = ",");INSERT INTO alarm_info_outputSELECT *FROM alarm_infoWHERE alarm_type > 0;
复制代码


提交购买,运行 CS 作业。


到这一步,使用 DIS 上传数据的工具上传数据,当告警超过级别可以收到短信,上传的全量告警数据在 OBS 上也看到了。OBS 上的转储目录为/alarm_info/2018/08/31/。

4.使用 DLF 创建周期调度任务

①新建 DLI 连接


点击数据管理,在数据连接管理页面创建数据连接,选择数据连接类型为 DLI。PS:已提前建好 DLI 集群。



②新建脚本


点击数据开发,新建脚本。输入脚本名称,脚本类型选择 SQL,数据连接类型选择 DLI。



在左侧选择 DLI 数据连接,资源队列,数据库。在 SQL 编辑框输入 alarm_info 的建表 SQL 语句。



执行脚本,刷新表列表,可以在表列表中看到新建的 alarm_info 表。


同样,新建脚本,执行 alarm_count_info 表建表语句。


alarm_info建表SQLcreate table  alarm_info(alarm_time string, alarm_id string, alarm_type int ) using csv options(path 's3a://obs-fubei/alarm_info')partitioned by(alarm_time)alarm_count_info建表SQLcreate table  alarm_info_count(alarm_time string, alarm_type int, alarm_count int)using csv options(path 's3a://obs-fubei/alarm_info_count')
复制代码


编写定时增加 alarm_info 表分区的 SQL。表分区的键值和 obs 路径目录根据加载日期来获取。DLF 脚本支持参数设置,在编写脚本的右侧点击参数设置,新增一个参数。输入 $联想出目前 DLF 支持的系统函数。



选择 getCurrentTime 函数,getCurrentTime 函数联想出参数:


$getCurrentTime(@@yyyyMMddHHmmss@@,-246060)。第一个参数是输出的格式,第二个参数是当前时间的偏移量,-246060 为当前时间的前一天,60*60 为当前时间加 1 小时。


一个小技巧,保存好的参数,可以直接在 SQL 编辑框,直接 select 参数名,查看执行结果是否为用户想要的值。比如设置 aa=$getCurrentTime(@@yyyyMMdd@@,-246060)



根据用户场景,DIS 实时导入告警数据到 OBS 按天分目录/alarm_info/2018/08/31/。


新建一个周期调度脚本,每天凌晨 2 点在 DIS 导出到 OBS 目录上新建 DLI 分区。分区新增后,按照告警分区时间和告警类别进行统计,将统计结果插入 alarm_info_count 表。


新建两个参数,一个为 alarm_info 表分区值,一个为 OBS 分区目录路径。脚本参数和脚本内容如下:


dayParam:$getCurrentTime(@@yyyyMMdd@@,-24*60*60)obsPathYear:$getCurrentTime(@@yyyy/MM/dd@@,-24*60*60)ALTER TABLE alarm_info  ADD PARTITION (alarm_time = ${dayParam})LOCATION 's3a://obs-fubei/alarm_info/${obsPathYear}';insert into alarm_info_countselect alarm_time,alarm_type,count(alarm_type) from alarm_info where alarm_time = ${dayParam} group by alarm_time,alarm_type;
复制代码


③新建 CDM 作业


在 CDM 集群中新建 CDM 作业从将 OBS 数据迁移到 MYSQL。



④新建 DLF 作业


拖拉一个 DLI SQL 节点,选择要执行的 DLI SQL 脚本。再拖拉一个 CDM 节点,选择要执行的 CDM 作业。



将 DLI SQL 和 CDM 节点连接起来,执行完 DLI SQL 执行 CDM 作业。



配置作业的调度周期,每天凌晨 2 点执行一次。



保存启动调度。


⑤调度启动后,在运维调度的作业监控中可以看到作业正在运行中。



运行成功的作业可以在运行历史记录中看到。



运行失败的作业可以重跑那天的批次作业,查看日志分析失败原因。



一个简易的实时告警分析平台就构建完成了。


本文转载自 华为云产品与解决方案 公众号。


原文链接:https://mp.weixin.qq.com/s/Qw_UGDc7P2FVSvJPkWHZQQ


2020-03-30 10:441000

评论

发布
暂无评论
发现更多内容

尤达 DDD 领域驱动设计思想 第三章作业(识别SmartRM系统货柜机免密支付购物场景里的聚合)

代廉洁

尤达DDD领域驱动设计思想

LabVIEW保存、读取配置文件

不脱发的程序猿

LabVIEW 保存、读取配置文件

OceanBase 在线体验环境,现已上线!

OceanBase 数据库

oceanbase OceanBase 社区版 在线体验站

大型企业SAP集成WMS系统方案流程

源字节1号

开源 解决方案 后端技术

腾讯云COS对象存储攻防

火线安全

云原生 云安全 云原生应用

条码WMS系统与ERP接口实现方法

源字节1号

后端开发 WMS系统 ERP接口

红黑树的原理以及实现

Linux服务器开发

数据结构 B+树 红黑树 Linux服务器开发 Linux后台开发

Cloud RedTeam视角下元数据服务攻防实践

火线安全

云原生 云安全

阿里云 OSS对象存储攻防

火线安全

云安全 阿里云;

golang并发控制设计中的“流式模型”

不登山的小鲁

golang

使用 CachedNetworkImage 实现图片离线缓存

岛上码农

flutter ios Android开发 移动端开发 3月月更

利用Struts拦截器限制上传图片的格式和大小

喀拉峻

网络安全

Redis线程模型

javaadu

redis 面试题

Python 实现 ZeroMQ 的三种基本工作模式,贼好用的Python学习路线集合

程序媛可鸥

Python 程序员 面试

欧拉的奇异之旅·共赴开源时代

脑极体

网络安全 kali Web安全之CSRF攻击

学神来啦

网络安全 CSRF WEB安全 kali kali Linux

低调不了!最佳体验尽在 Erda 2.0 版本

尔达Erda

云计算 云原生 设计 发布 界面改版

《第四期(2021-2022)传统行业云原生技术落地调研报告——金融篇》重磅发布!

York

容器 DevOps 云原生 金融科技 金融行业

微博评论高性能高可用架构设计

随欣所遇

架构训练营5期

一文剖析:LVS/Nginx/HAProxy原理及应用场景

穿过生命散发芬芳

3月月更

Python 实现七大排序算法,面试竟然被这31道Python基础题难倒了

程序媛可鸥

Python 程序员 面试

关于帮助中心,你需要知道的一切

小炮

持续集成引擎篇:K8S与服务自动发布

Docker 架构 k8s 持续集成 jenkins

LabVIEW设计自定义滚动条

不脱发的程序猿

LabVIEW 设计自定义滚动条

OpenHarmony设备开发环境搭建/源码获取/编译/烧录

拓维信息

OpenHarmony 烧录

2021物联之星评选结果重磅出炉!AIoT产业核心玩家已经浮现

dgiot

2022年,人工智能和数据发展呈现哪五大趋势?

澳鹏Appen

人工智能 机器学习 深度学习 训练数据

限时200位免费!网易云信娱乐社交公开课来啦!

网易云信

娱乐社交

微软云对象存储攻防

火线安全

云原生 云原生应用 云安全攻防 云安全研究

低代码如何助力化学材料行业数字化升级?

TOBESOFT特碧软件

低代码 数字化转型 MES系统 制造业 TOBESOFT

使用APICloud平台实现朋友圈功能

YonBuilder低代码开发平台

html5 css3 APP开发 APICloud JavaScrip

使用数据湖工厂(DLF)搭建数据中心实时告警平台_数据库_华为云产品与解决方案_InfoQ精选文章