专栏首页Hadoop实操0605-5.16.1-CM告警SNMP中DateAndTime类型解析

0605-5.16.1-CM告警SNMP中DateAndTime类型解析

作者:唐辉

1

文档编写目的

Fayson在前面的文章《如何通过Cloudera Manager配置使用SNMP方式转发告警》和《CM告警SNMP对接补充》介绍了使用SNMP的方式对接,对接SNMP告警时CM提供了告警的MIB文件,对于MIB文件中的每个OID的含义以及如何使用工具查看MIB文件,找到告警的各个指标。本篇文章Fayson主要介绍SNMP 中的DateAndTime 类型的解析

  • 测试环境

1.CM和CDH版本为CDH 5.16.1

2.操作系统版本为RedHat 7.2

2

问题描述

在前面两篇文章中我们已经知道oid 以1.1.2.2 结尾的对应事件发生的时间,如下图所示:

我们获取的时间是一长串16进制的数据,当然这并不是一个以秒或者毫秒数字的时间戳。

通过查看cm.mlib 文件可以看到事件发现时间对应的字段notifEventOccurredTime 类型为DateAndTime, DateAndTime是Snmpv2中的一种数据类型,它主要提供了对日期时间的描述。

下面是RFC中对DateAndTime的定义:

由定义可见,DateAndTime仍然是OCTET STRING类型的数据,只是对每个字节进行了具体的定义。比如前两个字节表示年,第五个字节表示小时等。

3

DateAndTime解析

通过上述对SNMP 中DateAndTime的类型的结构的了解,就可以很轻松的通过代码来解析。

3.1

Java 解析示例

public class Test {
    public static void main(String[] args) {
        String hexString = " 07 E3 04 08 13 10 3B 08 2B 08 00";
        DateAndTimeToString(hexString);
    }

    public static String DateAndTimeToString(String hexString){
        String hexstring = hexString.replace(" ","");
        System.out.println("传入的日期:"+hexstring);
        String yeah = hexstring.substring(0,4);
        String month = hexstring.substring(4,6);
        String day = hexstring.substring(6,8);
        String hours = hexstring.substring(8,10);
        String min = hexstring.substring(10,12);
        String sec = hexstring.substring(12,14);
        String decis = hexstring.substring(14,16);
        String derutc = hexstring.substring(16,18);
        String hourutc = hexstring.substring(18,20);
        String minutc = hexstring.substring(20,22);
        yeah = String.valueOf(Long.parseLong(yeah, 16));
        month = String.valueOf(Long.parseLong(month, 16));
        day = String.valueOf(Long.parseLong(day, 16));
        hours = String.valueOf(Long.parseLong(hours, 16));
        min = String.valueOf(Long.parseLong(min, 16));
        sec = String.valueOf(Long.parseLong(sec, 16));
        decis = String.valueOf(Long.parseLong(decis, 16));
        derutc = String.valueOf(Long.parseLong(derutc, 16));
        hourutc = String.valueOf(Long.parseLong(hourutc, 16));
        minutc = String.valueOf(Long.parseLong(minutc, 16));
//        System.out.println(dec_num);
        String time = yeah+"-"+month+"-"+day+" "+hours+":"+min+":"+sec+"."+decis+asciiToString(derutc)+hourutc+minutc;
        System.out.println("解析后的日期:"+time);
        return time;
    }

    public static String asciiToString(String value)
    {
        StringBuffer sbu = new StringBuffer();
        String[] chars = value.split(",");
        for (int i = 0; i < chars.length; i++) {
            sbu.append((char) Integer.parseInt(chars[i]));
        }
        return sbu.toString();
    }
}

运行测试:

3.2

Python解析示例

# -*-coding:utf-8-*-
# !/usr/bin/env python

def dateAndTimeToString(hexstring):
        #hexstring = "07 E3 04 08 13 10 3B 08 2B 08 00".replace(" ","")
        print("传入的日期:"+hexstring)
        hexstring = hexstring.replace(" ","")
        yeah = hexstring[0:4]
        month = hexstring[4:6]
        day = hexstring[6:8]
        hours = hexstring[8:10]
        mint = hexstring[10:12]
        sec = hexstring[12:14]
        desis = hexstring[14:16]
        derutc = hexstring[16:18]
        hourutc = hexstring[18:20]
        minutc = hexstring[20:22]
        time = str(int(yeah,16))+'-'+str(int(month,16))+'-'+str(int(day,16))+' '+str(int(hours,16))+':'+str(int(mint,16))+':'+str(int(sec,16))+'.'+str(int(desis,16))+chr(int(derutc,16))+str(int(hourutc,16))+str(int(minutc,16))
        print("解析后的日期:"+time)
        return time

dateAndTimeToString("07 E3 04 08 13 10 3B 08 2B 08 00")

运行获取结果

本文分享自微信公众号 - Hadoop实操(gh_c4c535955d0f),作者:Fayson

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-04-19

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Spark2Streaming读非Kerberos环境的Kafka并写数据到Kudu

    在前面的文章Fayson介绍了在Kerberos环境下《Spark2Streaming读Kerberos环境的Kafka并写数据到Kudu》,本篇文章Fayso...

    Fayson
  • 0670-6.2.0-如何获取CDSW中每个Session输出的LiveLog日志

    一些用户为了方便管理和审计,需要将CDSW上所有用户启动Session时运行代码输出的信息获取到。那接下来Fayson主要介绍如何通过获取用户每个Session...

    Fayson
  • 0580-5.16.1-通过CDSW API获取所有用户的Project详细信息

    在正常使用CDSW的情况下,我们也需要对CDSW服务的监控状况进行监控,CDSW默认的工程存储路径是在服务器的/var/lib/cdsw/current/pro...

    Fayson
  • httpclient 爬虫实例——爬取三级中学名

    本人在使用 httpclient 的过程中,突然想起来可以爬取一些数据,比如全国的中学名。当然不是空穴来风,之前也做过这方面的爬虫,不过基于selenium 做...

    FunTester
  • 50亿加密手机号md5快速存储及检索,rocksDB、redis等探索

    首先需求比较简单,将所有的号码段(如130、131、132)的全部手机号的md5和其对应的手机号存起来,将来传入一批手机号的md5,能迅速给出对应的明文手机号。...

    天涯泪小武
  • 【jfinal】扩展JFIANL 支持加载jar包中SQL模板

    扩展 ActiveRecordPlugin 支持加载jar包中SQL模板 jfinal3.1 中新增了IStringSource ,这个接口方便大家扩展SQL...

    冷冷
  • Java重写compare方法实现数组降序排列

    深浅无解
  • Spring Boot 整合 Redis

    实际开发中缓存处理是必须的,不可能我们每次客户端去请求一次服务器,服务器每次都要去数据库中进行查找,为什么要使用缓存?说到底是为了提高系统的运行速度。将用户频繁...

    南风
  • 免费教你使用 git 仓库搭建 maven 私服 | 码云小课堂

    码云Gitee
  • 使用git仓库搭建maven私服

    自己编写的jar,想要通过maven方式进行分发必须发布到maven仓库。如果没有自己的私服,我们可以使用折中的办法来实现。

    pollyduan

扫码关注云+社区

领取腾讯云代金券