Decodtura de dados de interface de telemetria Junos com utilitários UNIX
Você pode usar serviços unix para decodificar dados da interface de telemetria Junos em um servidor, ou coletor, que é streaming de dados de um dispositivo Juniper Networks. O exemplo nesta seção mostra como decodificar um único pacote de dados transmitidos.
Preparando o coletor para decodificar dados
Este exemplo requer o seguinte:
OS UNIX com o utilitário Netcat (nc).
Compilador de buffers de protocolo.
Arquivos de buffer de protocolo de interface de telemetria Junos.
Esse procedimento mostra como preparar o coletor para decodificar dados usando o Ubuntu OS.
Instale o utilitário Netcat.
sudo apt-get install netcat
Instale o compilador de buffers de protocolo.
sudo apt-get install protobuf-compiler
Instale os buffers de protocolo na biblioteca do desenvolvedor.
sudo apt-get install libprotobuf-dev
Verifique se os arquivos da biblioteca estão instalados.
ls /usr/include/google/protobuf/descriptor.proto /usr/include/google/protobuf/descriptor.proto
Baixe e instale a versão mais recente dos arquivos buffers de protocolo de interface de telemetria Junos.
De um navegador web, navegue até o software All Junos Platforms baixe URL na página da Juniper Networks: https://www.juniper.net/support/downloads/. Depois de selecionar o nome da plataforma Junos OS e o número de lançamento, acesse a seção Ferramentas e baixe o pacote de Arquivos de modelo de dados da interface de telemetria 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
Nota:Não se esqueça de observar a localização dos arquivos extraídos.
Decodagem de dados sobre o coletor
Este procedimento mostra como capturar dados, decodificar dados brutos e usar os arquivos buffers de protocolo para decodificar dados.
Para decodificar dados:
Capture os dados.
Execute netcat em um servidor de telemetria de streaming de destino, ou coletor, no modo de ouvidor UDP para armazenar todos os datagramas de entrada em um arquivo. Use o número da porta de destino configurado em perfil de servidor de streaming em seu dispositivo Juniper Networks.
nc -ul 0.0.0.0 20000 > data.gpb
Nota:Este comando armazena datagramas em um arquivo chamado
data.gpb. Execute este programa para capturar dados. Quando você quiser parar de receber dados, pare com o programa enviando o sinal de interrupção (Control + C)Decodificar dados brutos.
Nota:Essa etapa é opcional. Não é necessário saber o tipo de mensagem codificada dos dados.
Decodifica a mensagem do
data.gpbarquivo.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 } . . .A próxima estrutura aninhada sob
2636identifica o tipo de sensor. O valor2636numérico identifica aJuniperNetworksSensormensagem, que é definida notelemetry_top.protoarquivo. Neste exemplo, o identificador7numérico corresponde àLogicalPortmensagem definida nological_port.protoarquivo. Use essas informações na próxima etapa para gerar uma saída mais detalhada.Decodifica a mensagem para incluir nomes de campo.
Execute o compilador de buffers de protocolo com a opção de decodificação. Além disso, especifique o tipo de mensagem de nível superior (
TelemetryStream) e o arquivo com a definição da mensagem,logical_port.proto. Você também deve incluir a biblioteca de buffers de protocolo Goggle (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" } } } } }
Decodizando dados UDP de interface de telemetria Junos no coletor
O coletor deve iniciar um ouvidor no endereço remoto ou na combinação de portas para ler os dados de entrada. Os dados de entrada podem ser decodificados usando o telemetry_top.proto e os arquivos proto do sensor.
Para simplificar o procedimento de decodificação, os coletores podem carregar todos os arquivos proto enviados como parte do pacote de software de telemetria para decodificar os dados de entrada.
- Verifique os dados de streaming em interfaces de gerenciamento e WAN. Especifique o endereço apropriado no perfil do servidor de streaming.
- Enums e float são transmitidos como strings para streaming UDP. Os Enums serão retidos como strings, pois o gNMI usa o mesmo formato.
- O manuseio do tipo de dados flutuantes é escopo para uma versão futura.
Quando os dados de telemetria forem transmitidos por UDP, certifique-se de que os dados sejam decodificados corretamente e os campos desconhecidos não sejam decodificados no coletor.
Abaixo estão alguns problemas observados ao transmitir dados de telemetria por UDP:
- Decodagem incorreta: a decodagem incorreta implica que os dados de telemetria não são transmitidos corretamente por UDP. No exemplo a seguir, os dados destacados em negrito indicam que os dados não foram decodificados corretamente. Esse comportamento deve-se à codificação incorreta ou à embalagem errada de arquivos 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 {Abaixo está o exemplo dos dados que estão sendo decodificados corretamente:
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 } } } } } - Streaming de dados incompleto: o streaming de dados incompletos deve ser verificado por meio da validação de dados no arquivo de saída.