Streaming telemetry with gNMI

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

<?xml version="1.0"?>

<!-- vJunos router baseline XML -->

<!-- Copyright (c) 2023, Juniper Networks, Inc. -->
<!--  All rights reserved. -->

<domain xmlns:ns0="http://libvirt.org/schemas/domain/qemu/1.0" type="kvm">
  <name>vjunos-rtr1</name>
  <memory unit="KiB">5242880</memory>
  <currentMemory unit="KiB">5242880</currentMemory>
  <vcpu placement="static">4</vcpu>
  <resource>
    <partition>/machine</partition>
  </resource>
  <os>
    <type arch="x86_64">hvm</type>
    <boot dev="hd"/>
  </os>
  <features>
    <acpi/>
    <apic/>
    <pae/>
  </features>
  <cpu>
     <arch>x86_64</arch>
     <model>IvyBridge</model>
     <topology cores="4" sockets="1" threads="1"/>
     <model fallback="allow">qemu64</model>
     <feature name="vmx" policy="require"/>
  </cpu>
  <clock offset="utc"/>
  <on_poweroff>destroy</on_poweroff>
  <on_reboot>restart</on_reboot>
  <on_crash>restart</on_crash>
  <devices>
    <emulator>/usr/bin/qemu-system-x86_64</emulator>
    <disk device="disk" type="file">
      <driver cache="writeback" name="qemu" type="qcow2"/>
      <source file="/var/lib/libvirt/images/vjunos-rtr1-live.qcow2"/>
      <target dev="vda" bus="virtio"/>
    </disk>
       <disk device="disk" type="file">
      <driver cache="writeback" name="qemu" type="raw"/>
      <source file="/var/lib/libvirt/images/vjunos-rtr1-config.img"/>
      <target dev="sda" bus="usb"/>
    </disk>
    <controller index="0" model="pci-root" type="pci">
      <alias name="pci.0"/>
    </controller>
    <interface type='direct'>
       <source dev='bond0.11' mode='bridge'/>
      <model type="virtio"/>
      <alias name="net0"/>
      <address type='pci' domain='0x0000' bus='0x00' slot='0x03' function='0x0'/>
    </interface>
    <interface type="bridge">
      <source bridge="ge-000"/>
      <model type="virtio"/>
       <mtu size='9600'/>
      <alias name="net1"/>
      <address bus="0x00" domain="0x0000" function="0x0" slot="0x08" type="pci"/>
    </interface>
      <interface type="bridge">
      <source bridge="ge-001"/>
      <model type="virtio"/>
       <mtu size='9600'/>
      <alias name="net1"/>
      <address bus="0x00" domain="0x0000" function="0x0" slot="0x09" type="pci"/>
    </interface>
    <serial type="tcp">
      <source host="127.0.0.1" mode="bind" service="8610"/>
      <protocol type="telnet"/>
      <target port="0"/>
      <alias name="serial0"/>
    </serial>
    <memballoon model="virtio">
      <alias name="balloon0"/>
      <address bus="0x00" domain="0x0000" function="0x0" slot="0x06" type="pci"/>
    </memballoon>
  </devices>
  <ns0:commandline>
    <ns0:arg value="-smbios"/>
    <ns0:arg value="type=1,product=VM-VMX,family=lab"/>
  </ns0:commandline>
</domain>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

<?xml version="1.0"?>
<telemetryd-config>
    <connector name="Juniper-gNMI-Connector"
               class-name="org.opennms.netmgt.telemetry.protocols.openconfig.connector.OpenConfigConnector"
               service-name="Juniper-gNMI"
               queue="juniper-gnmi-queue"
               enabled="true">
        <package name="Juniper-gNMI-Package">
            <filter>IPADDR != '0.0.0.0'</filter>
	        <parameter key="port" value="${requisition:oc.port|9339}"/>
	        <parameter key="frequency" value="10000000000"/>
            <parameter key="origin" value="gnmi"/>
            <parameter key="retries" value="5"/>
            <parameter key="interval" value="10"/>
            <parameter key="username" value="admin"/>
            <parameter key="password" value="admin@123"/>
            <parameter key="tls.enabled" value="${requisition:oc.tls.enabled|true}"/>
            <parameter key="tls.skip.verify" value="${requisition:oc.tls.skip.verify|false}"/>
            <parameter key="paths" value="/interfaces/interface/state/counters,/components/component/cpu/utilization"/>
         </package>
    </connector>

    <queue name="juniper-gnmi-queue">
        <adapter name="OpenConfig-Adapter" class-name="org.opennms.netmgt.telemetry.protocols.openconfig.adapter.OpenConfigAdapter" enabled="true">
	    <parameter key="script" value="/opt/opennms/etc/telemetryd-adapters/openconfig-gnmi-telemetry.groovy"/>
            <package name="Juniper-gNMI-RRD">
                <rrd step="300">
                    <rra>RRA:AVERAGE:0.5:1:2016</rra>
                    <rra>RRA:AVERAGE:0.5:12:1488</rra>
                    <rra>RRA:AVERAGE:0.5:288:366</rra>
                    <rra>RRA:MAX:0.5:288:366</rra>
                    <rra>RRA:MIN:0.5:288:366</rra>
                </rrd>
            </package>
        </adapter>
    </queue>
</telemetryd-config>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

<?xml version="1.0" encoding="UTF-8"?>
<model-import xmlns="http://xmlns.opennms.org/xsd/config/model-import" date-stamp="2016-10-28T10:50:02.025Z" foreign-source="gnmi-lab" last-import="2016-10-28T10:51:29.354Z">
    <node location="Default" foreign-id="rtr1" node-label="rtr1">
        <interface ip-addr="192.168.11.100" status="1" snmp-primary="P">
            <monitored-service service-name="ICMP"/>
            <monitored-service service-name="Juniper-gNMI"/>
        </interface>
        <asset name="longitude" value="9.1685303"/>
        <asset name="latitude" value="48.8258763"/>
    </node>
</model-import>

1
2
3
4
5
6

<?xml version="1.0" encoding="UTF-8"?>
<foreign-source xmlns="http://xmlns.opennms.org/xsd/config/foreign-source" name="gnmi-lab" date-stamp="2016-10-28T10:40:43.995Z">
    <scan-interval>1d</scan-interval>
    <detectors/>
    <policies/>
</foreign-source>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

16:00:38.996 DEBUG [AggregatorFlush-Telemetry-juniper-gnmi-queue] Generating collection set for message: update {
  timestamp: 1752854436816000000
  prefix {
    origin: "gnmi"
    elem {
      name: "interfaces"
    }
    elem {
      name: "interface"
      key {
        key: "name"
        value: "ge-0/0/0"
      }
    }
  }
  update {
    path {
      elem {
        name: "init-time"
      }
    }
    val {
      json_val: "1752680309"
    }
  }
  update {
    path {
      elem {
        name: "state"
      }
      elem {
        name: "high-speed"
      }
    }
    val {
      json_val: "1000"
    }
  }
  update {
    path {
      elem {
        name: "state"
      }
      elem {
        name: "counters"
      }
      elem {
        name: "in-pkts"
      }
    }
    val {
      json_val: "5902"
    }
  }
  update {
    path {
      elem {
        name: "state"
      }
      elem {
        name: "counters"
      }
      elem {
        name: "in-octets"
      }
    }
    val {
      json_val: "1287975"
    }
  }
  update {
    path {
      elem {
        name: "state"
      }
      elem {
        name: "counters"
      }
      elem 
        name: "in-unicast-pkts"
      }
    }
    val {
      json_val: "5916"
    }
  }
}
extension {
  registered_ext {
    id: UNKNOWN_ENUM_VALUE_ExtensionID_1
    msg: "\020\377\377\003\"\017sensor_1004_1_2*%/interfaces/interface/state/counters/2%/interfaces/interface/state/counters/:\bna-grpcd@\n`\272\275\220\362\2013\200\001\002"
  }
}