mirror of
https://github.com/Telecominfraproject/ols-nos.git
synced 2025-12-04 23:15:29 +00:00
ec73735d21
* Move get_machine_info to lib * Add get platform info API * Create sonic_platform.py Signed-off-by: Sihui Han <sihan@microsoft.com>
471 lines
19 KiB
Python
471 lines
19 KiB
Python
#!/usr/bin/env python
|
|
import calendar
|
|
import os
|
|
import sys
|
|
import socket
|
|
import struct
|
|
import json
|
|
import copy
|
|
import ipaddr as ipaddress
|
|
from collections import defaultdict
|
|
|
|
from lxml import etree as ET
|
|
from lxml.etree import QName
|
|
|
|
DOCUMENTATION = '''
|
|
---
|
|
module: minigraph_facts
|
|
version_added: "1.9"
|
|
author: Guohan Lu (gulv@microsoft.com)
|
|
short_description: Retrive minigraph facts for a device.
|
|
description:
|
|
- Retrieve minigraph facts for a device, the facts will be
|
|
inserted to the ansible_facts key.
|
|
options:
|
|
host:
|
|
description:
|
|
- Set to target snmp server (normally {{inventory_hostname}})
|
|
required: true
|
|
'''
|
|
|
|
EXAMPLES = '''
|
|
# Gather minigraph facts
|
|
- name: Gathering minigraph facts about the device
|
|
minigraph_facts: host={{ hostname }}
|
|
'''
|
|
|
|
ns = "Microsoft.Search.Autopilot.Evolution"
|
|
ns1 = "http://schemas.datacontract.org/2004/07/Microsoft.Search.Autopilot.Evolution"
|
|
ns2 = "Microsoft.Search.Autopilot.NetMux"
|
|
ns3 = "http://www.w3.org/2001/XMLSchema-instance"
|
|
|
|
|
|
class minigraph_encoder(json.JSONEncoder):
|
|
def default(self, obj):
|
|
if isinstance(obj,
|
|
(ipaddress.IPv4Network, ipaddress.IPv6Network, ipaddress.IPv4Address, ipaddress.IPv6Address)):
|
|
return str(obj)
|
|
return json.JSONEncoder.default(self, obj)
|
|
|
|
def parse_png(png, hname):
|
|
neighbors = {}
|
|
devices = {}
|
|
console_dev = ''
|
|
console_port = ''
|
|
mgmt_dev = ''
|
|
mgmt_port = ''
|
|
for child in png:
|
|
if child.tag == str(QName(ns, "DeviceInterfaceLinks")):
|
|
for link in child.findall(str(QName(ns, "DeviceLinkBase"))):
|
|
linktype = link.find(str(QName(ns, "ElementType"))).text
|
|
if linktype != "DeviceInterfaceLink" and linktype != "UnderlayInterfaceLink":
|
|
continue
|
|
|
|
enddevice = link.find(str(QName(ns, "EndDevice"))).text
|
|
endport = link.find(str(QName(ns, "EndPort"))).text
|
|
startdevice = link.find(str(QName(ns, "StartDevice"))).text
|
|
startport = link.find(str(QName(ns, "StartPort"))).text
|
|
|
|
if enddevice == hname:
|
|
if port_alias_map.has_key(endport):
|
|
endport = port_alias_map[endport]
|
|
neighbors[endport] = {'name': startdevice, 'port': startport}
|
|
else:
|
|
if port_alias_map.has_key(startport):
|
|
startport = port_alias_map[startport]
|
|
neighbors[startport] = {'name': enddevice, 'port': endport}
|
|
|
|
if child.tag == str(QName(ns, "Devices")):
|
|
for device in child.findall(str(QName(ns, "Device"))):
|
|
lo_addr = None
|
|
# don't shadow type()
|
|
d_type = None
|
|
mgmt_addr = None
|
|
hwsku = None
|
|
if str(QName(ns3, "type")) in device.attrib:
|
|
d_type = device.attrib[str(QName(ns3, "type"))]
|
|
|
|
for node in device:
|
|
if node.tag == str(QName(ns, "Address")):
|
|
lo_addr = node.find(str(QName(ns2, "IPPrefix"))).text.split('/')[0]
|
|
elif node.tag == str(QName(ns, "ManagementAddress")):
|
|
mgmt_addr = node.find(str(QName(ns2, "IPPrefix"))).text.split('/')[0]
|
|
elif node.tag == str(QName(ns, "Hostname")):
|
|
name = node.text
|
|
elif node.tag == str(QName(ns, "HwSku")):
|
|
hwsku = node.text
|
|
|
|
devices[name] = {'lo_addr': lo_addr, 'type': d_type, 'mgmt_addr': mgmt_addr, 'hwsku': hwsku}
|
|
|
|
if child.tag == str(QName(ns, "DeviceInterfaceLinks")):
|
|
for if_link in child.findall(str(QName(ns, 'DeviceLinkBase'))):
|
|
if str(QName(ns3, "type")) in if_link.attrib:
|
|
link_type = if_link.attrib[str(QName(ns3, "type"))]
|
|
if link_type == 'DeviceSerialLink':
|
|
for node in if_link:
|
|
if node.tag == str(QName(ns, "EndPort")):
|
|
console_port = node.text.split()[-1]
|
|
elif node.tag == str(QName(ns, "EndDevice")):
|
|
console_dev = node.text
|
|
elif link_type == 'DeviceMgmtLink':
|
|
for node in if_link:
|
|
if node.tag == str(QName(ns, "EndPort")):
|
|
mgmt_port = node.text.split()[-1]
|
|
elif node.tag == str(QName(ns, "EndDevice")):
|
|
mgmt_dev = node.text
|
|
|
|
return (neighbors, devices, console_dev, console_port, mgmt_dev, mgmt_port)
|
|
|
|
|
|
def parse_dpg(dpg, hname):
|
|
for child in dpg:
|
|
hostname = child.find(str(QName(ns, "Hostname")))
|
|
if hostname.text != hname:
|
|
continue
|
|
|
|
ipintfs = child.find(str(QName(ns, "IPInterfaces")))
|
|
intfs = []
|
|
for ipintf in ipintfs.findall(str(QName(ns, "IPInterface"))):
|
|
intfalias = ipintf.find(str(QName(ns, "AttachTo"))).text
|
|
if port_alias_map.has_key(intfalias):
|
|
intfname = port_alias_map[intfalias]
|
|
else:
|
|
intfname = intfalias
|
|
ipprefix = ipintf.find(str(QName(ns, "Prefix"))).text
|
|
ipn = ipaddress.IPNetwork(ipprefix)
|
|
ipaddr = ipn.ip
|
|
prefix_len = ipn.prefixlen
|
|
addr_bits = ipn.max_prefixlen
|
|
subnet = ipaddress.IPNetwork(str(ipn.network) + '/' + str(prefix_len))
|
|
ipmask = ipn.netmask
|
|
|
|
intf = {'addr': ipaddr, 'subnet': subnet}
|
|
if isinstance(ipn, ipaddress.IPv4Network):
|
|
intf['mask'] = ipmask
|
|
else:
|
|
intf['mask'] = str(prefix_len)
|
|
intf.update({'attachto': intfname, 'prefixlen': int(prefix_len)})
|
|
|
|
# TODO: remove peer_addr after dependency removed
|
|
ipaddr_val = int(ipn.ip)
|
|
peer_addr_val = None
|
|
if int(prefix_len) == addr_bits - 2:
|
|
if ipaddr_val & 0x3 == 1:
|
|
peer_addr_val = ipaddr_val + 1
|
|
else:
|
|
peer_addr_val = ipaddr_val - 1
|
|
elif int(prefix_len) == addr_bits - 1:
|
|
if ipaddr_val & 0x1 == 0:
|
|
peer_addr_val = ipaddr_val + 1
|
|
else:
|
|
peer_addr_val = ipaddr_val - 1
|
|
if peer_addr_val is not None:
|
|
intf['peer_addr'] = ipaddress.IPAddress(peer_addr_val)
|
|
intfs.append(intf)
|
|
|
|
lointfs = child.find(str(QName(ns, "LoopbackIPInterfaces")))
|
|
lo_intfs = []
|
|
for lointf in lointfs.findall(str(QName(ns1, "LoopbackIPInterface"))):
|
|
intfname = lointf.find(str(QName(ns, "AttachTo"))).text
|
|
ipprefix = lointf.find(str(QName(ns1, "PrefixStr"))).text
|
|
ipn = ipaddress.IPNetwork(ipprefix)
|
|
ipaddr = ipn.ip
|
|
prefix_len = ipn.prefixlen
|
|
ipmask = ipn.netmask
|
|
lo_intf = {'name': intfname, 'addr': ipaddr, 'prefixlen': prefix_len}
|
|
if isinstance(ipn, ipaddress.IPv4Network):
|
|
lo_intf['mask'] = ipmask
|
|
else:
|
|
lo_intf['mask'] = str(prefix_len)
|
|
lo_intfs.append(lo_intf)
|
|
|
|
mgmtintfs = child.find(str(QName(ns, "ManagementIPInterfaces")))
|
|
mgmt_intf = None
|
|
for mgmtintf in mgmtintfs.findall(str(QName(ns1, "ManagementIPInterface"))):
|
|
ipprefix = mgmtintf.find(str(QName(ns1, "PrefixStr"))).text
|
|
mgmtipn = ipaddress.IPNetwork(ipprefix)
|
|
ipaddr = mgmtipn.ip
|
|
prefix_len = str(mgmtipn.prefixlen)
|
|
ipmask = mgmtipn.netmask
|
|
gwaddr = ipaddress.IPAddress(int(mgmtipn.network) + 1)
|
|
mgmt_intf = {'addr': ipaddr, 'prefixlen': prefix_len, 'mask': ipmask, 'gwaddr': gwaddr}
|
|
|
|
pcintfs = child.find(str(QName(ns, "PortChannelInterfaces")))
|
|
pc_intfs = []
|
|
pcs = {}
|
|
for pcintf in pcintfs.findall(str(QName(ns, "PortChannel"))):
|
|
pcintfname = pcintf.find(str(QName(ns, "Name"))).text
|
|
pcintfmbr = pcintf.find(str(QName(ns, "AttachTo"))).text
|
|
pcmbr_list = pcintfmbr.split(';')
|
|
for i, member in enumerate(pcmbr_list):
|
|
pcmbr_list[i] = port_alias_map[member]
|
|
pcs[pcintfname] = {'name': pcintfname, 'members': pcmbr_list}
|
|
|
|
vlanintfs = child.find(str(QName(ns, "VlanInterfaces")))
|
|
vlan_intfs = []
|
|
vlans = {}
|
|
for vintf in vlanintfs.findall(str(QName(ns, "VlanInterface"))):
|
|
vintfname = vintf.find(str(QName(ns, "Name"))).text
|
|
vlanid = vintf.find(str(QName(ns, "VlanID"))).text
|
|
vintfmbr = vintf.find(str(QName(ns, "AttachTo"))).text
|
|
vmbr_list = vintfmbr.split(';')
|
|
for i, member in enumerate(vmbr_list):
|
|
vmbr_list[i] = port_alias_map[member]
|
|
vlan_attributes = {'name': vintfname, 'members': vmbr_list, 'vlanid': vlanid}
|
|
vlans[vintfname] = vlan_attributes
|
|
|
|
aclintfs = child.find(str(QName(ns, "AclInterfaces")))
|
|
acls = {}
|
|
for aclintf in aclintfs.findall(str(QName(ns, "AclInterface"))):
|
|
aclname = aclintf.find(str(QName(ns, "InAcl"))).text.lower().replace(" ", "_").replace("-", "_")
|
|
aclattach = aclintf.find(str(QName(ns, "AttachTo"))).text.split(';')
|
|
acl_intfs = []
|
|
is_mirror = False
|
|
for member in aclattach:
|
|
member = member.strip()
|
|
if pcs.has_key(member):
|
|
acl_intfs.extend(pcs[member]['members']) # For ACL attaching to port channels, we break them into port channel members
|
|
elif vlans.has_key(member):
|
|
print >> sys.stderr, "Warning: ACL " + aclname + " is attached to a Vlan interface, which is currently not supported"
|
|
elif port_alias_map.has_key(member):
|
|
acl_intfs.append(port_alias_map[member])
|
|
elif member.lower() == 'erspan':
|
|
is_mirror = True;
|
|
# Erspan session will be attached to all front panel ports
|
|
acl_intfs = port_alias_map.values()
|
|
break;
|
|
if acl_intfs:
|
|
acls[aclname] = { 'AttachTo': acl_intfs, 'IsMirror': is_mirror }
|
|
return intfs, lo_intfs, mgmt_intf, vlans, pcs, acls
|
|
return None, None, None, None, None, None
|
|
|
|
|
|
def parse_cpg(cpg, hname):
|
|
bgp_sessions = []
|
|
myasn = None
|
|
for child in cpg:
|
|
tag = child.tag
|
|
if tag == str(QName(ns, "PeeringSessions")):
|
|
for session in child.findall(str(QName(ns, "BGPSession"))):
|
|
start_router = session.find(str(QName(ns, "StartRouter"))).text
|
|
start_peer = session.find(str(QName(ns, "StartPeer"))).text
|
|
end_router = session.find(str(QName(ns, "EndRouter"))).text
|
|
end_peer = session.find(str(QName(ns, "EndPeer"))).text
|
|
if end_router == hname:
|
|
bgp_sessions.append({
|
|
'name': start_router,
|
|
'addr': start_peer,
|
|
'peer_addr': end_peer
|
|
})
|
|
else:
|
|
bgp_sessions.append({
|
|
'name': end_router,
|
|
'addr': end_peer,
|
|
'peer_addr': start_peer
|
|
})
|
|
elif child.tag == str(QName(ns, "Routers")):
|
|
for router in child.findall(str(QName(ns1, "BGPRouterDeclaration"))):
|
|
asn = router.find(str(QName(ns1, "ASN"))).text
|
|
hostname = router.find(str(QName(ns1, "Hostname"))).text
|
|
if hostname == hname:
|
|
myasn = int(asn)
|
|
else:
|
|
for bgp_session in bgp_sessions:
|
|
if hostname == bgp_session['name']:
|
|
bgp_session['asn'] = int(asn)
|
|
|
|
return bgp_sessions, myasn
|
|
|
|
|
|
def parse_meta(meta, hname):
|
|
syslog_servers = []
|
|
dhcp_servers = []
|
|
ntp_servers = []
|
|
mgmt_routes = []
|
|
device_metas = meta.find(str(QName(ns, "Devices")))
|
|
for device in device_metas.findall(str(QName(ns1, "DeviceMetadata"))):
|
|
if device.find(str(QName(ns1, "Name"))).text == hname:
|
|
properties = device.find(str(QName(ns1, "Properties")))
|
|
for device_property in properties.findall(str(QName(ns1, "DeviceProperty"))):
|
|
name = device_property.find(str(QName(ns1, "Name"))).text
|
|
value = device_property.find(str(QName(ns1, "Value"))).text
|
|
value_group = value.split(';') if value and value != "" else []
|
|
if name == "DhcpResources":
|
|
dhcp_servers = value_group
|
|
elif name == "NtpResources":
|
|
ntp_servers = value_group
|
|
elif name == "SyslogResources":
|
|
syslog_servers = value_group
|
|
elif name == "ForcedMgmtRoutes":
|
|
mgmt_routes = value_group
|
|
return syslog_servers, dhcp_servers, ntp_servers, mgmt_routes
|
|
|
|
|
|
def get_console_info(devices, dev, port):
|
|
for k, v in devices.items():
|
|
if k == dev:
|
|
break
|
|
else:
|
|
return {}
|
|
|
|
ret_val = v
|
|
ret_val.update({
|
|
'ts_port': port,
|
|
'ts_dev': dev
|
|
})
|
|
|
|
return ret_val
|
|
|
|
|
|
def get_mgmt_info(devices, dev, port):
|
|
for k, v in devices.items():
|
|
if k == dev:
|
|
break
|
|
else:
|
|
return {}
|
|
|
|
ret_val = v
|
|
ret_val.update({
|
|
'mgmt_port': port,
|
|
'mgmt_dev': dev
|
|
})
|
|
|
|
return ret_val
|
|
|
|
|
|
def parse_port_config(hwsku, platform=None, port_config_file=None):
|
|
port_config_candidates = []
|
|
if port_config_file != None:
|
|
port_config_candidates.append(port_config_file)
|
|
port_config_candidates.append('/usr/share/sonic/hwsku/port_config.ini')
|
|
if platform != None:
|
|
port_config_candidates.append(os.path.join('/usr/share/sonic/device', platform, hwsku, 'port_config.ini'))
|
|
port_config_candidates.append(os.path.join('/usr/share/sonic/platform', hwsku, 'port_config.ini'))
|
|
port_config_candidates.append(os.path.join('/usr/share/sonic', hwsku, 'port_config.ini'))
|
|
port_config = None
|
|
for candidate in port_config_candidates:
|
|
if os.path.isfile(candidate):
|
|
port_config = candidate
|
|
break
|
|
if port_config == None:
|
|
return None
|
|
|
|
ports = {}
|
|
with open(port_config) as data:
|
|
for line in data:
|
|
if line.startswith('#'):
|
|
continue
|
|
tokens = line.split()
|
|
if len(tokens) < 2:
|
|
continue
|
|
name = tokens[0].strip()
|
|
if len(tokens) == 2:
|
|
alias = name
|
|
else:
|
|
alias = tokens[2].strip()
|
|
ports[name] = {'name': name, 'alias': alias}
|
|
port_alias_map[alias] = name
|
|
return ports
|
|
|
|
|
|
def parse_xml(filename, platform=None, port_config_file=None):
|
|
root = ET.parse(filename).getroot()
|
|
mini_graph_path = filename
|
|
|
|
u_neighbors = None
|
|
u_devices = None
|
|
hwsku = None
|
|
bgp_sessions = None
|
|
bgp_asn = None
|
|
intfs = None
|
|
vlan_intfs = None
|
|
pc_intfs = None
|
|
vlans = None
|
|
pcs = None
|
|
mgmt_intf = None
|
|
lo_intf = None
|
|
neighbors = None
|
|
devices = None
|
|
hostname = None
|
|
syslog_servers = []
|
|
dhcp_servers = []
|
|
ntp_servers = []
|
|
mgmt_routes = []
|
|
|
|
hwsku_qn = QName(ns, "HwSku")
|
|
hostname_qn = QName(ns, "Hostname")
|
|
for child in root:
|
|
if child.tag == str(hwsku_qn):
|
|
hwsku = child.text
|
|
if child.tag == str(hostname_qn):
|
|
hostname = child.text
|
|
|
|
ports = parse_port_config(hwsku, platform, port_config_file)
|
|
|
|
for child in root:
|
|
if child.tag == str(QName(ns, "DpgDec")):
|
|
(intfs, lo_intfs, mgmt_intf, vlans, pcs, acls) = parse_dpg(child, hostname)
|
|
elif child.tag == str(QName(ns, "CpgDec")):
|
|
(bgp_sessions, bgp_asn) = parse_cpg(child, hostname)
|
|
elif child.tag == str(QName(ns, "PngDec")):
|
|
(neighbors, devices, console_dev, console_port, mgmt_dev, mgmt_port) = parse_png(child, hostname)
|
|
elif child.tag == str(QName(ns, "UngDec")):
|
|
(u_neighbors, u_devices, _, _, _, _) = parse_png(child, hostname)
|
|
elif child.tag == str(QName(ns, "MetadataDeclaration")):
|
|
(syslog_servers, dhcp_servers, ntp_servers, mgmt_routes) = parse_meta(child, hostname)
|
|
|
|
Tree = lambda: defaultdict(Tree)
|
|
|
|
results = Tree()
|
|
results['minigraph_hwsku'] = hwsku
|
|
# sorting by lambdas are not easily done without custom filters.
|
|
# TODO: add jinja2 filter to accept a lambda to sort a list of dictionaries by attribute.
|
|
# TODO: alternatively (preferred), implement class containers for multiple-attribute entries, enabling sort by attr
|
|
results['minigraph_bgp'] = sorted(bgp_sessions, key=lambda x: x['addr'])
|
|
results['minigraph_bgp_asn'] = bgp_asn
|
|
# TODO: sort does not work properly on all interfaces of varying lengths. Need to sort by integer group(s).
|
|
|
|
phyport_intfs = []
|
|
vlan_intfs = []
|
|
pc_intfs = []
|
|
for intf in intfs:
|
|
intfname = intf['attachto']
|
|
if intfname[0:4] == 'Vlan':
|
|
vlan_intfs.append(intf)
|
|
elif intfname[0:11] == 'PortChannel':
|
|
pc_intfs.append(intf)
|
|
else:
|
|
phyport_intfs.append(intf)
|
|
|
|
results['minigraph_interfaces'] = sorted(phyport_intfs, key=lambda x: x['attachto'])
|
|
results['minigraph_vlan_interfaces'] = sorted(vlan_intfs, key=lambda x: x['attachto'])
|
|
results['minigraph_portchannel_interfaces'] = sorted(pc_intfs, key=lambda x: x['attachto'])
|
|
results['minigraph_ports'] = ports
|
|
results['minigraph_vlans'] = vlans
|
|
results['minigraph_portchannels'] = pcs
|
|
results['minigraph_mgmt_interface'] = mgmt_intf
|
|
results['minigraph_lo_interfaces'] = lo_intfs
|
|
results['minigraph_acls'] = acls
|
|
results['minigraph_neighbors'] = neighbors
|
|
results['minigraph_devices'] = devices
|
|
results['minigraph_underlay_neighbors'] = u_neighbors
|
|
results['minigraph_underlay_devices'] = u_devices
|
|
results['minigraph_as_xml'] = mini_graph_path
|
|
if devices != None:
|
|
results['minigraph_console'] = get_console_info(devices, console_dev, console_port)
|
|
results['minigraph_mgmt'] = get_mgmt_info(devices, mgmt_dev, mgmt_port)
|
|
results['minigraph_hostname'] = hostname
|
|
results['inventory_hostname'] = hostname
|
|
results['syslog_servers'] = syslog_servers
|
|
results['dhcp_servers'] = dhcp_servers
|
|
results['ntp_servers'] = ntp_servers
|
|
results['forced_mgmt_routes'] = mgmt_routes
|
|
|
|
return results
|
|
|
|
port_alias_map = {}
|
|
|
|
def print_parse_xml(filename):
|
|
results = parse_xml(filename)
|
|
print(json.dumps(results, indent=3, cls=minigraph_encoder))
|