Telemetry获取网络设备CPU信息

交换机配置：

int g1/0/0
un sh
int vlani 1
ip add 192.168.56.177
q

stel s e
user-i v 4
auth aaa
pro in ssh
u p l 3
q
ssh user python
ssh user python auth password
ssh user python ser stel

aaa
local-user python password irreversible-cipher Huawei@123
local-user python service-type ssh
local-user python user-group manage-ug
q
#进入Telemetry视图
telemetry
#配置设备推送目标，目标组Dest1，推送目标IP地址192.168.56.1，端口为20000
destination-group Dest1
ipv4-address 192.168.56.1 port 20000 protocol grpc no-tls
#配置设备采样数据
#当用户配置Telemetry静态订阅采样数据时，需要创建采样传感器组，并指定好采样路径。
#本例中创建采样组Sensor1，采样路径为CPU信息
#采样路径见：telemetry\CloudEngine 16800, 12800, 9800, 8800, 6800, 5800 V200R021C00 Telemetry性能指标集.xlsx
sensor-group Sensor1
sensor-path huawei-devm:devm/cpuInfos/cpuInfo
#创建订阅，将配置好的上送目标组和采样传感器组进行关联，完成数据上送。
#本例中关联目标组Dest1与传感器组Sensor1，并设置采样间隔为1000ms
subscription Sub1
destination-group Dest1
sensor-group Sensor1 sample-interval 1000
commit
q
q

　　

 

配置步骤：
1、搭建环境，完成实验环境准备
2、配置设备Telemetry静态订阅方式想着配置，包括采集内容、推送对象和推送间隔
3、官网下载华为设备对应发布的.proto文件。
华为企业用户下载地址：http://support.huawei.com/enterprise
运营商用户下载地址：http://support.huawei.com/carrier
搜索相应的设备型号及版本号
软件——版本及补丁
采样路径见：telemetry\CloudEngine 16800, 12800, 9800, 8800, 6800, 5800 V200R021C00 Telemetry性能指标集.xlsx
编译proto文件得到服务端调用方法
本例中，使用run_codegen.py脚本编译proto文件。注意将所有.proto文件放入/protos目录
本脚本将一次编译huawei-grpc-dialout.proto、huawei-telemetry.proto和huawei-devm.proto
4、编写服务端代码，监听指定端口获取数据
5、根据上送数据的不同，选择对应的方法对数据内容进行解码

在文件目录下创建一个protos文件夹，将huawei-grpc-dialout.proto、huawei-telemetry.proto和huawei-devm.proto放到protos文件夹下

Generate_codes代码：编译.proto文件

#!/usr/bin
# _*_ coding: UTF-8 _*_
# Copyright (c) 2021 GengYu.All rights reserved
# @Create by gengyu
# @Create Time :2021/12/18
# @File Name : Generate_codes
# 打包命令 pyinstaller -F package\Generate_codes
"""
generates protocol messages and gRPC stubs.
"""
__author__ = 'Administrator'
from grpc_tools import protoc


protoc.main(
    (
        '',
        '-I./protos',
        '--python_out=.',
        '--grpc_python_out=.',
        './protos/huawei-grpc-dialout.proto',#文件路径
    )
)

protoc.main(
    (
        '',
        '-I./protos',
        '--python_out=.',
        '--grpc_python_out=.',
        './protos/huawei-telemetry.proto',#文件路径
    )
)

protoc.main(
    (
        '',
        '-I./protos',
        '--python_out=.',
        '--grpc_python_out=.',
        './protos/huawei-devm.proto',#文件路径
    )
)

 

telemetry_server.py代码：运行即可接收交换机推送的信息

#!/usr/bin
# _*_ coding: UTF-8 _*_
# Copyright (c) 2021 GengYu.All rights reserved
# @Create by gengyu
# @Create Time :2021/12/18
# @File Name : telemetry_server
# 打包命令 pyinstaller -F package\telemetry_server
"""

"""
__author__ = 'Administrator'

import doctest

from concurrent import futures
import time
import importlib
import grpc#pip 安装
import huawei_grpc_dialout_pb2_grpc#generate_codes.py生成
import huawei_telemetry_pb2#generate_codes.py生成

_ONE_DAY_IN_SECONDS = 60 * 60 * 24
def tele_server():
    #创建一个grpc server对象
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    #注册huawei的telemetry 数据监听服务
    huawei_grpc_dialout_pb2_grpc.add_gRPCDataserviceServicer_to_server(
        Telemetry_CPU_Info(),server)
    #设置socket监听端口和PC的IP地址，与交换机中推送目标IP地址一致
    server.add_insecure_port('192.168.56.1:20000')
    #启动 grpc server
    server.start()
    #死循环监听
    try:
        while True:
            time.sleep(_ONE_DAY_IN_SECONDS)
    except KeyboardInterrupt:
        server.stop(0)

#创建类继承huawei_grpc_dialout_pb2_grpc中的Servicer方法
class Telemetry_CPU_Info(huawei_grpc_dialout_pb2_grpc.gRPCDataserviceServicer):
    def __init__(self):
        return
    def dataPublish(self, request_iterator, context):
        for i in request_iterator:
            print('________________________ start ________________________')
            telemetry_data = huawei_telemetry_pb2.Telemetry.FromString(i.data)
            print(telemetry_data)
            for row_data in telemetry_data.data_gpb.row:
                print('________________________')
                print('The proto path is :' + telemetry_data.proto_path)
                print('________________________')
                module_name = telemetry_data.proto_path.split('.')[0]
                root_class = telemetry_data.proto_path.split('.')[1]
#动态加载telemetry 获取数据的对应模块，本例中为：
                decode_module = importlib.import_module(module_name + '_pb2')
                print(decode_module)
#定义解码方法：getattr获取动态加载的模块中的属性值，调用此属性的解码方法FromString
                decode_func = getattr(decode_module,root_class).FromString
                print('________________________ content is ________________________\n')
                #将row_data中的content中的内容使用此方法解码，并输出
                print(decode_func(row_data.content))
                print('________________________ done ________________________')

if __name__ == "__main__":
    tele_server()

 

 

运行结果：

________________________ start ________________________
node_id_str: "HUAWEI"
subscription_id_str: "Sub1"
sensor_path: "huawei-devm:devm/cpuInfos/cpuInfo"
collection_id: 13
collection_start_time: 1639850454743
msg_timestamp: 1639850454847
data_gpb {
row {
timestamp: 1639850454743
content: "*\022\n\020\"\0011\010\201\200\204\010(\n\030Z0K\020\010"
}
row {
timestamp: 1639850454743
content: "*\023\n\021\"\00217\010\201\200\304\010(\013\030Z0K\020\010"
}
}
collection_end_time: 1639850454743
current_period: 10000
except_desc: "OK"
product_name: "CE12800"
proto_path: "huawei_devm.Devm"

________________________
The proto path is :huawei_devm.Devm
________________________
<module 'huawei_devm_pb2' from 'C:\\Users\\Administrator\\PycharmProjects\\python_switch\\telemetry\\huawei_devm_pb2.py'>
________________________ content is ________________________

cpuInfos {
cpuInfo {
entIndex: 16842753
interval: 8
ovloadThreshold: 90
position: "1"
systemCpuUsage: 10
unovloadThreshold: 75
}
}

________________________ done ________________________
________________________
The proto path is :huawei_devm.Devm
________________________
<module 'huawei_devm_pb2' from 'C:\\Users\\Administrator\\PycharmProjects\\python_switch\\telemetry\\huawei_devm_pb2.py'>
________________________ content is ________________________

cpuInfos {
cpuInfo {
entIndex: 17891329
interval: 8
ovloadThreshold: 90
position: "17"
systemCpuUsage: 11
unovloadThreshold: 75
}
}

________________________ done ________________________