Décodage des données de l’interface de télémétrie Junos avec les utilitaires UNIX
Vous pouvez utiliser les utilitaires UNIX pour décoder les données de l’interface de télémétrie Junos sur un serveur, ou collecteur, qui diffuse des données en continu à partir d’un équipement Juniper Networks. L’exemple de cette section vous montre comment décoder un seul paquet de données diffusées en continu.
Préparation du collecteur pour décoder les données
Cet exemple requiert les éléments suivants :
OS UNIX avec l’utilitaire Netcat (nc).
Compilateur de tampons de protocole.
Le protocole de l’interface de télémétrie Junos met les fichiers en mémoire tampon.
Cette procédure montre comment préparer le collecteur pour décoder les données à l’aide du système d’exploitation Ubuntu.
Installez l’utilitaire Netcat.
sudo apt-get install netcat
Installez le compilateur protocol buffers.
sudo apt-get install protobuf-compiler
Installez la bibliothèque du développeur des tampons de protocole.
sudo apt-get install libprotobuf-dev
Vérifiez que les fichiers de la bibliothèque sont installés.
ls /usr/include/google/protobuf/descriptor.proto /usr/include/google/protobuf/descriptor.proto
Téléchargez et installez la dernière version des fichiers tampons de protocole de l’interface de télémétrie Junos.
À partir d’un navigateur Web, accédez à l’URL de téléchargement du logiciel Toutes les plates-formes Junos sur la page Juniper Networks : https://www.juniper.net/support/downloads/. Après avoir sélectionné le nom de la plate-forme Junos OS et le numéro de version, accédez à la section Outils et téléchargez le package Fichiers du modèle de données de l’interface de télémétrie Junos .
tar –xvzf junos-telemetry-interface-15.1F6.9.tgz junos-telemetry-interface/telemetry_top.proto junos-telemetry-interface/logical_port.proto junos-telemetry-interface/lsp_mon.proto junos-telemetry-interface/firewall.proto junos-telemetry-interface/lsp_stats.proto junos-telemetry-interface/port.proto junos-telemetry-interface/NOTICE junos-telemetry-interface/license.txt
Note:Assurez-vous de noter l’emplacement des fichiers extraits.
Décodage des données sur le collecteur
Cette procédure vous montre comment capturer des données, décoder les données brutes et utiliser les fichiers tampons de protocole pour décoder les données.
Pour décoder les données :
Capturez les données.
Exécutez netcat sur un serveur de télémétrie en streaming de destination, ou collecteur, en mode d’écoute UDP pour stocker tous les datagrammes entrants dans un fichier. Utilisez le numéro de port de destination configuré dans le profil du serveur de streaming de votre équipement Juniper Networks.
nc -ul 0.0.0.0 20000 > data.gpb
Note:Cette commande stocke les datagrammes dans un fichier nommé
data.gpb. Exécutez ce programme pour capturer des données. Lorsque vous souhaitez arrêter de recevoir des données, arrêtez avec le programme en envoyant le signal de coupure (Control + C)Décoder les données brutes.
Note:Cette étape est facultative. Ce n’est pas nécessaire si vous connaissez le type de message codé des données.
Décodez le message du
data.gpbfichier.protoc --decode_raw < ../data.gpb 1: "hillrock:160.1.1.25" 2: 0 4: "S1:/junos/system/linecard/interface/logical/usage/:/junos/system/linecard/interface/logical/usage/:PFE" 5: 65265 6: 1477686534474 7: 1 8: 1 101 { 2636 { 7 { 1 { 1: "et-0/0/4:2.32767" 2: 1477642750 3: 813 4 { 12: 0x37363732332e3165 } . . .La structure imbriquée suivante ci-dessous
2636identifie le type de capteur. La valeur2636numérique identifie leJuniperNetworksSensormessage, qui est défini dans letelemetry_top.protofichier. Dans cet exemple, l’identifiant7numérique correspond auLogicalPortmessage défini dans lelogical_port.protofichier. Utilisez ces informations à l’étape suivante pour générer des résultats plus détaillés.Décodez le message pour inclure les noms de champ.
Exécutez le compilateur protocol buffers avec l’option decode. En outre, spécifiez le type de message de niveau supérieur (
TelemetryStream) et le fichier avec la définition de message,logical_port.proto. Vous devez également inclure la bibliothèque Goggle protocol buffers (gpb).protoc --decode TelemetryStream logical_port.proto -I /usr/include -I . < data.gpb system_id: "hillrock:160.1.1.25" component_id: 0 sensor_name: "S1:/junos/system/linecard/interface/logical/usage/:/junos/system/linecard/interface/logical/usage/:PFE" sequence_number: 65268 timestamp: 1477686536484 version_major: 1 version_minor: 1 enterprise { [juniperNetworks] { [jnprLogicalInterfaceExt] { interface_info { if_name: "et-0/0/4:2.32767" init_time: 1477642750 snmp_if_index: 813 parent_ae_name: "ae1.32767" ingress_stats { if_packets: 0 if_octets: 0 } egress_stats { if_packets: 0 if_octets: 0 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/7:3.0" init_time: 1477642750 snmp_if_index: 520 parent_ae_name: "ae0.0" ingress_stats { if_packets: 61203309 if_octets: 6487548454 } egress_stats { if_packets: 87416547 if_octets: 9266153982 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.0" init_time: 1477642750 snmp_if_index: 2512 ingress_stats { if_packets: 26266247 if_octets: 2784214806 } egress_stats { if_packets: 26247215 if_octets: 2781829290 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.1" init_time: 1477642750 snmp_if_index: 2522 ingress_stats { if_packets: 26266249 if_octets: 2784214972 } egress_stats { if_packets: 26249115 if_octets: 2781935590 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.2" init_time: 1477642750 snmp_if_index: 2523 ingress_stats { if_packets: 26266248 if_octets: 2784214912 } egress_stats { if_packets: 26249106 if_octets: 2781935086 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.3" init_time: 1477642750 snmp_if_index: 2524 ingress_stats { if_packets: 26266248 if_octets: 2784214820 } egress_stats { if_packets: 26248520 if_octets: 2781902320 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.4" init_time: 1477642750 snmp_if_index: 2525 ingress_stats { if_packets: 26266247 if_octets: 2784214760 } egress_stats { if_packets: 26247302 if_octets: 2781834112 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.5" init_time: 1477642750 snmp_if_index: 2526 ingress_stats { if_packets: 26266247 if_octets: 2784214760 } egress_stats { if_packets: 26247209 if_octets: 2781828904 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.6" init_time: 1477642750 snmp_if_index: 2527 ingress_stats { if_packets: 26266248 if_octets: 2784214820 } egress_stats { if_packets: 26247196 if_octets: 2781828226 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.7" init_time: 1477642750 snmp_if_index: 2528 ingress_stats { if_packets: 26266247 if_octets: 2784214760 } egress_stats { if_packets: 26247203 if_octets: 2781828618 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.8" init_time: 1477642750 snmp_if_index: 2529 ingress_stats { if_packets: 26266247 if_octets: 2784214760 } egress_stats { if_packets: 26247225 if_octets: 2781829850 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.9" init_time: 1477642750 snmp_if_index: 2530 ingress_stats { if_packets: 26266247 if_octets: 2784214760 } egress_stats { if_packets: 26247209 if_octets: 2781828954 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.32767" init_time: 1477642750 snmp_if_index: 648 ingress_stats { if_packets: 4 if_octets: 240 } egress_stats { if_packets: 0 if_octets: 0 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/4:2.32767" init_time: 1477642750 snmp_if_index: 813 parent_ae_name: "ae1.32767" ingress_stats { if_packets: 0 if_octets: 0 } egress_stats { if_packets: 0 if_octets: 0 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/7:3.0" init_time: 1477642750 snmp_if_index: 520 parent_ae_name: "ae0.0" ingress_stats { if_packets: 61206122 if_octets: 6487846632 } egress_stats { if_packets: 87420567 if_octets: 9266580102 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.0" init_time: 1477642750 snmp_if_index: 2512 ingress_stats { if_packets: 26267458 if_octets: 2784343172 } egress_stats { if_packets: 26248420 if_octets: 2781957020 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.1" init_time: 1477642750 snmp_if_index: 2522 ingress_stats { if_packets: 26267460 if_octets: 2784343338 } egress_stats { if_packets: 26250320 if_octets: 2782063320 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.2" init_time: 1477642750 snmp_if_index: 2523 ingress_stats { if_packets: 26267459 if_octets: 2784343278 } egress_stats { if_packets: 26250311 if_octets: 2782062816 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.3" init_time: 1477642750 snmp_if_index: 2524 ingress_stats { if_packets: 26267460 if_octets: 2784343292 } egress_stats { if_packets: 26249725 if_octets: 2782030050 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.4" init_time: 1477642750 snmp_if_index: 2525 ingress_stats { if_packets: 26267459 if_octets: 2784343232 } egress_stats { if_packets: 26248507 if_octets: 2781961842 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.5" init_time: 1477642750 snmp_if_index: 2526 ingress_stats { if_packets: 26267459 if_octets: 2784343232 } egress_stats { if_packets: 26248414 if_octets: 2781956634 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.6" init_time: 1477642750 snmp_if_index: 2527 ingress_stats { if_packets: 26267460 if_octets: 2784343292 } egress_stats { if_packets: 26248401 if_octets: 2781955956 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.7" init_time: 1477642750 snmp_if_index: 2528 ingress_stats { if_packets: 26267459 if_octets: 2784343232 } egress_stats { if_packets: 26248408 if_octets: 2781956348 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.8" init_time: 1477642750 snmp_if_index: 2529 ingress_stats { if_packets: 26267459 if_octets: 2784343232 } egress_stats { if_packets: 26248430 if_octets: 2781957580 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.9" init_time: 1477642750 snmp_if_index: 2530 ingress_stats { if_packets: 26267459 if_octets: 2784343232 } egress_stats { if_packets: 26248414 if_octets: 2781956684 } op_state { operational_status: "up" } } interface_info { if_name: "et-0/0/13:0.32767" init_time: 1477642750 snmp_if_index: 648 ingress_stats { if_packets: 4 if_octets: 240 } egress_stats { if_packets: 0 if_octets: 0 } op_state { operational_status: "up" } } } } }
Décodage des données UDP de l’interface de télémétrie Junos au niveau du collecteur
Le collecteur doit démarrer un écouteur sur l’adresse distante ou la combinaison de ports pour lire les données entrantes. Les données entrantes peuvent être décodées à l’aide des fichiers telemetry_top.proto et sensor proto.
Pour simplifier la procédure de décodage, les collecteurs peuvent charger tous les fichiers proto livrés dans le cadre du progiciel de télémétrie pour décoder les données entrantes.
- Vérifiez les données de streaming sur les interfaces de gestion et WAN. Spécifiez l’adresse appropriée dans le profil du serveur de diffusion en continu.
- Les énumérations et float sont diffusées en continu sous forme de chaînes pour le streaming UDP. Les énumérations seront conservées sous forme de chaînes de caractères, car gNMI utilise le même format.
- La gestion du type de données float est limitée pour une version ultérieure.
Lorsque les données de télémétrie sont transmises via UDP, assurez-vous que les données sont décodées correctement et que les champs inconnus ne sont pas décodés au niveau du collecteur.
Voici quelques problèmes observés lors de la diffusion de données de télémétrie sur UDP :
- Décodage incorrect : un décodage incorrect implique que les données de télémétrie ne sont pas correctement transmises via UDP. Dans l’exemple suivant, les données surlignées en gras indiquent que les données n’ont pas été décodées correctement. Ce comportement est dû soit à un encodage incorrect, soit à un mauvais empaquetage de fichiers proto.
system_id: "r02.dtw01.icn" component_id: 65535 sensor_name: "mpls:/network-instances/network-instance/mpls:/network-instances/network-instance/mpls:rpd" sequence_number: 2421 timestamp: 1715024560793 version_major: 1 version_minor: 0 enterprise: { [juniperNetworks]: { [jnpr_network_instances_rsvp_ext]: { network_instance: { name: "master" mpls: { 153 { 151 { 152{ 151{ 51: "r02.dtw01.icn-r01.bos02.icn-01" 152{ 151{ 51: "AUTO" 52: 0 53: 12873154 } 152{ 151{ 51:1 52:200000 53: 0 54: 300 55: 1 61: 1549061 } 152 {Vous trouverez ci-dessous un exemple de décodage correct des données :
system_id: "r0-RE0" component_id: 65535 sub_component_id: 0 sensor_name: "test_chassisd:/network-instances/:/network-instances/:rpd" sequence_number: 0 timestamp: 1719126223900 version_major: 1 version_minor: 0 enterprise { [juniperNetworks] { [jnpr_network_instances_ni_226_ext] { network_instance { name: "DEFAULT" protocols { protocol { identifier: "STATIC" name: "DEFAULT" static_routes { static { prefix: "10.0.0.0/8" state { prefix: "10.0.0.0/8" set_tag: "0" } next_hops { next_hop { index: "1" state { index: "1" next_hop: "10.220.127.254" metric: 0 recurse: false } interface_ref { state { interface: "re0:mgmt-0" subinterface: 0 } } } } } - Diffusion de données incomplètes : la diffusion de données incomplètes en continu doit être vérifiée par la validation des données dans le fichier de sortie.