00:00
好,同学们,那么这一节呢,我们正式的把瑞向云呢给它对接上,呃,首先呢,我们之前说这个body变量呢,其实就是请求体的意思,呃,接下来呢,我们就可以把这个刚好呢啊,我们的flux里面呢,它支持一个呃类Jason的语法,我们呢直接把它拿过来。把我们之前这个API post里面的啊请求器拿过来。What are you that。然后给它写成body。Body等于好,呃,那么现在呢,可以看到啊,我们现在呢,就是这个报警信息里面呢,还是那个hello word,我们尝试一下,先尝试一下能不能把这个请求呢发出来。呃,我们在这个地方先把屏清一下。哎,重新运行这个HTP服务。然后呢,我们点击submit。好,回到我们的终端里面来看。好可以看到呢,这里面呢是没有数据,没有数据呢,是因为啊,我查询的是过去一小时的,那么我们现在呢,往前多查一点,比如说查询过去24小时的。
01:09
好,点击这个sum,我们再来看这个现在的终端啊,可以可以看到呢,我们现在这个数据呢,已经成功的啊,按照我们想要的一个数据格式呢,发过来了。好,那么接下来呢,我们可以去对我们这里面的一个报警内容呢,啊,不要再是hello word了啊,我们对这个报警内容呢,进行一个丰富,回到我们的。啊,这里呢,首先啊,我们可以来看。呃,首先我们可以给他加一个事件的ID,那么为什么要加事件的ID呢?其实是有利于我们的瑞象云呢啊,自动的去做一个去重的操作啊,防止我们这里呢,一旦出现数据重复啊,或者怎么着呢,导致我们的电话轰炸。我们可以看一下这里面传的这个字段的写法呢,是ID,是驼峰写法。EVENT。
02:02
ID好,然后呢,这个地方呢,我们可以给他一个,呃,把这个时间戳呢,直接给他,呃以时间戳呢来做一个。来做我们的ID,那么这里呢,我们用na。需要注意一个一件事啊,就是now呢,它取的是当前的时间,呃,但是呢,这个当前时间呢,并不是说我们这行代码执行的时间,Now呢,其实是一个option,它呢是我们整个脚本,诶这个脚本执行的一个时间,所以说如果说如果说我这里有多行数据呢,呃,那么不同的这个每一行数据调用na的时候呢,呃,其实得到的是同一个时间。啊,那么比如说呢,我这里面呢,呃,这一次查询啊,这一次任务执行查询出来的数据。啊,我们有十条呢,不合规。比如说我就说第一行啊,它的这个浓度呢为0.06属于危险啊,第二行呢是0.56啊,0.056也属于危险啊,那么第三行呢,是0.041也属于危险啊,那么我这一次脚本调用呢,它其实呢会发出三个请求,这样呢会导致我们打三个电话,呃,如果说呢,你想我这一次检查呢,发现问题之后呢,只打一次电话啊,那么我们使用这个event ID呢,去做一个去重。
03:23
啊,用这个时间窗呢,就可以做到这个我们每一次调用的时候呢,只发出一次告警啊,但是不同的调用次数呢,啊不同的这个呃,时间的窗口上我们就可以发送多次报警,可以看到我们这个瑞向云的文档里面,他说的是呃,可以看到有一个事件ID因ID啊前面呢有一个说自动去重。这个规则呢,就是如果你这个应用里面的ID相同,而且级别相同啊,那么你多次告警呢,就会被当成一条来处理,而且呢,最新的这一条,比如说我先处理的,先发送的请求呢,是这个0.06的,后面发送的请求呢,是这个0.56的,第三次发送的请求呢,是0.41的,那么它呢,只会保留第三次这个最新的啊,那么这是我们的一个报警的驱除策略。
04:10
另外呢,如果你说这个不同的设备呢,我希望它按照呃,在设备内进行驱虫啊,但是但是如果有多个设备的话呢,还是按照设备进行进行报警啊,那么你这里呢,可以把我们的你可以看到,你这里可以访问这个数据啊,你可以把这个数据的。是不是可以把数据的字段直接给他加上。啊,比如说这里呢,这个字段就要扣的啊,是完全可以的啊,不过呢,我们这里呢,是出于演示的方便呢,就不加这个了,我们直接呢,以当前的时间作为ID啊之后呢,我们去调整一下这个报警的名称,就叫一氧化碳浓度报警。一氧化碳。浓度大于0.04,然后这个报警的内容呢,我们就可以根据这一行的数据呢,来进行一个动态的调整,比如说。
05:05
嗯,叫二取它的这个code的,哎,当然设备的编号加一个空一个字符串啊,你就说这个设备的检测值是再加二。然后我们把这个值呢,就传进来。充到加平哈。Value好啊,这里还需要注意呢,这个value呢,它是一个数值型的,那我们需要把它转成字符串。好,那么现在呢,我们就有一个符合我们要求的请求体了,呃,现在呢,可以去试一下,现在我们去把这个任务呢调整一下。首先呢是我们的筛选时间,之前呢是跟着这个窗口走啊,跟着我们这个下拉菜单走,现在呢,我们直接给他写死,我们可以看到这个任务呢,是每15秒呢去执行一次,于是呢,我们查询的时间呢,查询数据的这个范围呢,啊也是最近的15秒,这里呢改成负15S。
06:11
好,那么现在我们就可以去尝试的跑一下这个任务了啊,另外我们现在这个报警呢,没有设报警级别,其实我们的瑞象云里面呢,也是支持你设报警级别的。啊,可以看到啊,这个有提醒一警告二,严重三通知四,致命五,但是这个呢,是一个可选的字段啊,所以这里呢,我们就不加这个内容了,如果你要加的话呢,你应该写一个呃,If else,把这个我们的报警级别,把这个if DB里面的报警级别呢,跟这个瑞象原理的映射一下。好,现在我们就可以尝试去插入一条,先去插入一条数据啊。我们去这个load data里面。来上传一个行瀣页的数据,我现在手动上传一个,比如说这个啊,我们去Vs code里面复制一下这个数据的格式啊。
07:02
啊,先选中这个存储桶,选对存储桶,我这里呢,把这个值改成0.08。好直接提交,然后立刻啊快速去submit一下。现在我们去终端里面看一下,可以看到啊,这里面呢有一个呃,报警内容就是零一设备的检测值是0.08啊,然后报警的名称呢,报警的题目就叫一氧化碳浓度大于0.04啊,另外呢,这里还有我们的事件ID,可以看到是一个当前的时间戳。另外呢,可以看到这里面又出来一条数据啊,那么这这条数据怎么来的呢?这条数据是我们之前在这个呃UI上,在这个aler特斯里面的,哎,去做的一些什么终端呀,还有包括这个检查规则,哎,包括我们的这个通知规则,诶他们去发送一条数据,所以说这个呢,跟我们刚才写的脚本呢没有关系啊,现在只看这一条,现在数据呢,已经符合我们的要求了。呃,接下来呢,我们把这个脚本复制一下啊,把这脚本复制一下。
08:00
好,我们现在呢,就去创建这个任务。呃,首先呢,点击我们左侧的这个任务,诶,可以看到这个按钮呢,就是tasks。然后现在呢,点击create task。哎,把我们刚才的脚本呢,直接粘进来,在这里呢,可以给我们的定时任务起个名字,另外需要注意第十行的这个option需要删掉啊,在这里面去创建任务的话,这一行不能加。啊,否则的话会起冲突。呃,这一行删掉。或者呢,直接把我们这个name呢,直接粘进来吧。好,往这一粘。那么这个local,然后下划线什么什么什么,其实我们notebook的名字之前呢,我们没有对这个啊notebook呢进行一个重命名,这里呢,是我们的一个呃,实现的时候不好的地方啊,啊这个地方应该对我们的notebook呢做做一个啊有意义的命名。15秒也拿来。好,可以看到我这个15秒一输入啊,右边就变成这个C呢,就变成蓝的了,可以点击了,把这一行一删,删干净,好点击save。
09:03
好的,现在呢,那么我们就有了一个用来做报警的定时任务,接下来我们去再插入一条违规数据啊,我们看这个瑞向云呢,能不能收到啊,说起来刚刚想起来呢,刚才好像有个地方忘了改啊呃,回去编辑一下我们的任务。呃,去编辑这个任务,我们看这个URL是不是没改呢,还真是啊,我们把这个URL给它换掉啊。是这个我们的接口在这不是local host了啊,不是一了。现在呢,去。修改一下。好,然后呢,保存save。啊,现在呢,我们再去输入一个违规数据呢,去看呃,瑞向云呢,能不能收到。好,现在呢,我们去洛地塔,然后呢,插入一个行协议的数据。哎,先选对存储桶,然后呢,这里就输入我们的呃数据,我把这个Vs code再开启一下啊。
10:03
稍等。好把这个数据呢粘过来。然后呢,我们给它改一下值,比如说这次呢,是0.09吧。好直接呢,点击,呃,点击这个把数据写进去。呃,接下来呢,我们来看一下这个手机的页面。看看这个能不能顺利的收到我们的电话。好的同学们,哎,可以看到呢,这个电话打过来了,我们接听一下,看看里里面呢有什么内容。01:52:00发生提醒级别,报警报警对象,报警编号,105905206主机告警标题,一氧化碳浓度大于0.04,告警内容,零幺设备的检测值是0.09推荐解决方案。
11:11
病领请按一好,那么现在呢,我们可以看到我们的这个报警呢,已经成功的配置好了啊,那么这就是我们用这个in Fla DB呢,呃,去监听啊,监控指标,并且跟我们的报警系统相结合的一个,呃,操作。
我来说两句