add_vlan.py 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275
  1. #!/usr/bin/env python3
  2. import argparse
  3. import sys
  4. import re
  5. import subprocess
  6. import os
  7. import tempfile
  8. from yaml import load, dump
  9. try:
  10. from yaml import CLoader as Loader, CDumper as Dumper
  11. except ImportError:
  12. from yaml import Loader, Dumper
  13. IPV4SEG = r'(?:25[0-5]|(?:2[0-4]|1{0,1}[0-9]){0,1}[0-9])'
  14. IPV4ADDR = r'(?:(?:' + IPV4SEG + r'\.){3,3}' + IPV4SEG + r')'
  15. IPV6SEG = r'(?:(?:[0-9a-fA-F]){1,4})'
  16. IPV6GROUPS = (
  17. r'(?:' + IPV6SEG + r':){7,7}' + IPV6SEG, # 1:2:3:4:5:6:7:8
  18. # 1:: 1:2:3:4:5:6:7::
  19. r'(?:' + IPV6SEG + r':){1,7}:',
  20. # 1::8 1:2:3:4:5:6::8 1:2:3:4:5:6::8
  21. r'(?:' + IPV6SEG + r':){1,6}:' + IPV6SEG,
  22. # 1::7:8 1:2:3:4:5::7:8 1:2:3:4:5::8
  23. r'(?:' + IPV6SEG + r':){1,5}(?::' + IPV6SEG + r'){1,2}',
  24. # 1::6:7:8 1:2:3:4::6:7:8 1:2:3:4::8
  25. r'(?:' + IPV6SEG + r':){1,4}(?::' + IPV6SEG + r'){1,3}',
  26. # 1::5:6:7:8 1:2:3::5:6:7:8 1:2:3::8
  27. r'(?:' + IPV6SEG + r':){1,3}(?::' + IPV6SEG + r'){1,4}',
  28. # 1::4:5:6:7:8 1:2::4:5:6:7:8 1:2::8
  29. r'(?:' + IPV6SEG + r':){1,2}(?::' + IPV6SEG + r'){1,5}',
  30. # 1::3:4:5:6:7:8 1::3:4:5:6:7:8 1::8
  31. IPV6SEG + r':(?:(?::' + IPV6SEG + r'){1,6})',
  32. # ::2:3:4:5:6:7:8 ::2:3:4:5:6:7:8 ::8 ::
  33. r':(?:(?::' + IPV6SEG + r'){1,7}|:)',
  34. # fe80::7:8%eth0 fe80::7:8%1 (link-local IPv6 addresses with zone index)
  35. r'fe80:(?::' + IPV6SEG + r'){0,4}%[0-9a-zA-Z]{1,}',
  36. # ::255.255.255.255 ::ffff:255.255.255.255 ::ffff:0:255.255.255.255 (IPv4-mapped IPv6 addresses and IPv4-translated addresses)
  37. r'::(?:ffff(?::0{1,4}){0,1}:){0,1}[^\s:]' + IPV4ADDR,
  38. # 2001:db8:3:4::192.0.2.33 64:ff9b::192.0.2.33 (IPv4-Embedded IPv6 Address)
  39. r'(?:' + IPV6SEG + r':){1,4}:[^\s:]' + IPV4ADDR,
  40. )
  41. # Reverse rows for greedy match
  42. IPV6ADDR = '|'.join(['(?:{})'.format(g) for g in IPV6GROUPS[::-1]])
  43. def main():
  44. parser = argparse.ArgumentParser(
  45. prog=sys.argv[0], description='Add a VLAN to the network')
  46. parser.add_argument('--vlan-name', '-n', metavar='<VLAN_NAME>',
  47. help='Name of the VLAN to add', required=True)
  48. parser.add_argument('--vm-vlan-name', metavar='<VM_VLAN_NAME>',
  49. help='Name of the VLAN port group in VMware (default: vlan-name)')
  50. parser.add_argument('--vlan-id', '-i', metavar='<VLAN_ID>',
  51. help='ID of the VLAN to add', type=int, required=True)
  52. parser.add_argument('--svi-v4-network', metavar='<SVI_NETWORK>',
  53. help='IPv4 network address of the SVI')
  54. parser.add_argument('--svi-subnet-len', metavar='<SVI_PREFIX_LEN>',
  55. help='Subnet length of the SVI v4 IP (e.g., 24 for a /24)', type=int)
  56. parser.add_argument(
  57. '--svi-standard-v4', help='Follow the standard rules to add a MAJOR.VLAN.IDF.0/24 SVI address', action='store_true')
  58. parser.add_argument('--svi-v6-network', metavar='<SVI_NETWORK>',
  59. help='IPv6 network address of the SVI (prefix len is assumed to be /64)')
  60. parser.add_argument(
  61. '--svi-standard-v6', help='Follow the standard rules to add a PREFIX:[VLAN][IDF]::/64 SVI address', action='store_true')
  62. parser.add_argument('--svi-descr', metavar='<SVI_DESCRIPTION>',
  63. help='Description of the SVI')
  64. parser.add_argument(
  65. '--is-stretched', help='VLAN is stretched between both data centres (default: False)', action='store_true')
  66. parser.add_argument(
  67. '--no-hsrp', help='Use HSRP or not (default: False)', action='store_true')
  68. parser.add_argument('--no-passive-interface',
  69. help='Whether or not to have OSPF use passive interface (default: False)', action='store_true')
  70. parser.add_argument(
  71. '--v6-link-local', help='Only use v6 link-local addresses (default: global IPv6 is expected)', action='store_true')
  72. parser.add_argument(
  73. '--ospf-broadcast', help='OSPF network is broadcast instead of P2P (default: P2P)', action='store_true')
  74. parser.add_argument('--interface', action='append', metavar='<INTF>',
  75. help='Interface to enable for VLAN (can be specified more than once)')
  76. parser.add_argument(
  77. '--generate-iflist', help='Automatically generate a list of allowed interfaces for VLAN (default: False)', action='store_true')
  78. parser.add_argument('--vmware-cluster', action='append', metavar='<CLUSTER>',
  79. help='VMware cluster to configure for VLAN (can be specified more than once) (default: all clusters are configured)')
  80. parser.add_argument('--mtu', '-m', metavar='<MTU>',
  81. help='MTU of SVI (default: 9216)', type=int)
  82. parser.add_argument('--username', '-u', metavar='<USERNAME>',
  83. help='Username to use to connect to the N9Ks', required=True)
  84. parser.add_argument('--limit', '-L', metavar='<HOSTS_OR_GROUP_NAMES>',
  85. help='Comma-separated list of hosts or host group names (from inventory/hosts) on which to restrict operations')
  86. parser.add_argument('--tags', metavar='<TAG_LIST>',
  87. help='Comma-separated list of task tags to execute')
  88. parser.add_argument(
  89. '--list-tags', help='List available task tags', action='store_true')
  90. parser.add_argument(
  91. '--check-only', help='Only check syntax and attempt to predict changes', action='store_true')
  92. args = parser.parse_args()
  93. if args.vlan_id < 1 or args.vlan_id > 3967:
  94. print('ERROR: VLAN ID must be between 1 and 3967')
  95. sys.exit(1)
  96. svi_prefix = None
  97. build_v4 = False
  98. use_hsrp = True
  99. passive_interface = True
  100. svi_v6_link_local = False
  101. build_v6 = True
  102. ospf_type = 'point-to-point'
  103. vm_vlan_name = args.vlan_name
  104. is_stretched = False
  105. generate_iflist = False
  106. if args.vm_vlan_name:
  107. vm_vlan_name = args.vm_vlan_name
  108. if args.svi_v4_network and args.svi_standard_v4:
  109. print('ERROR: Cannot specify both --svi-v4-network and --svi-standard-v4.')
  110. sys.exit(1)
  111. if args.svi_standard_v4:
  112. build_v4 = True
  113. if args.is_stretched:
  114. is_stretched = True
  115. if args.generate_iflist and args.interface and len(args.interface) > 0:
  116. print('ERROR: Cannot specify both an interface list and --generate-iflist.')
  117. sys.exit(1)
  118. if args.generate_iflist:
  119. generate_iflist = True
  120. if args.svi_v4_network:
  121. m = re.match(r'(\d+)\.(\d+)\.(\d+).(\d+)', args.svi_v4_network)
  122. for i in range(1, 5):
  123. if int(m.group(i)) > 255:
  124. print('ERROR: Invalid SVI IPv4 address, {}'.format(
  125. args.svi_v4_network))
  126. sys.exit(1)
  127. if not m:
  128. print('ERROR: SVI Network must be an IPv4 network address.')
  129. sys.exit(1)
  130. if not args.svi_subnet_len:
  131. print(
  132. 'ERROR: SVI Prefix Length is required when an SVI Network is specified.')
  133. sys.exit(1)
  134. if int(args.svi_subnet_len) < 8 or int(args.svi_subnet_len) > 30:
  135. print('ERROR: SVI Prefix Length must be between 8 and 30.')
  136. sys.exit(1)
  137. if args.svi_subnet_len >= 24:
  138. svi_prefix = '{}.{}.{}'.format(m.group(1), m.group(2), m.group(3))
  139. elif args.svi_prefix_len < 24 and args.svi_subnet_len >= 16:
  140. svi_prefix = '{}.{}'.format(m.group(1), m.group(2))
  141. else:
  142. svi_prefix = m.group(1)
  143. if args.svi_v4_network or args.svi_v6_network or args.svi_standard_v4 or args.svi_standard_v6:
  144. if args.mtu and (args.mtu < 1500 or args.mtu > 9216):
  145. print('ERROR: MTU must be between 1500 and 9216.')
  146. sys.exit(1)
  147. elif not args.mtu:
  148. args.mtu = 9216
  149. if args.no_passive_interface:
  150. passive_interface = False
  151. if args.no_hsrp:
  152. use_hsrp = False
  153. if args.ospf_broadcast:
  154. ospf_type = 'broadcast'
  155. if args.svi_standard_v6 and args.svi_v6_network:
  156. print('ERROR: Cannot specify both --svi-v6-network and --svi-standard-v6.')
  157. sys.exit(1)
  158. if args.svi_standard_v6:
  159. build_v6 = True
  160. if args.svi_v6_network:
  161. m = re.match(IPV6ADDR, args.svi_v6_network)
  162. if not m:
  163. print('ERROR: SVI Network must be an IPv6 network address.')
  164. sys.exit(1)
  165. if args.v6_link_local:
  166. print('ERROR: Cannot specify both svi-v6-network and v6-link-local.')
  167. sys.exit(1)
  168. elif args.v6_link_local:
  169. svi_v6_link_local = True
  170. os.environ['ANSIBLE_FORCE_COLOR'] = 'True'
  171. os.environ['ANSIBLE_HOST_KEY_CHECKING'] = 'False'
  172. os.environ['ANSIBLE_PERSISTENT_COMMAND_TIMEOUT'] = '300'
  173. if 'AD_PASSWORD' not in os.environ:
  174. print(
  175. 'ERROR: AD_PASSWORD must be set in the environment first (used for vCenter and UCS).')
  176. sys.exit(1)
  177. os.environ['VMWARE_USER'] = args.username
  178. os.environ['VMWARE_PASSWORD'] = os.environ['VMWARE_PASSWORD']
  179. cred_file = tempfile.NamedTemporaryFile(mode='w', delete=False)
  180. vars = {
  181. 'ucs_mgr_username': args.username,
  182. 'ucs_mgr_password': os.environ['AD_PASSWORD']
  183. }
  184. dump(vars, cred_file, Dumper=Dumper)
  185. cred_file.close()
  186. command = ['ansible-playbook', '-i', 'inventory/hosts',
  187. '-u', args.username, '-k', '-e',
  188. 'vlan_name={}'.format(
  189. args.vlan_name), '-e', 'vlan_id={}'.format(args.vlan_id), '-e', 'vm_vlan_name=\'{}\''.format(vm_vlan_name),
  190. '-e', 'ansible_python_interpreter={}'.format(sys.executable),
  191. '-e', '@{}'.format(cred_file.name),
  192. '-e', 'build_v4={}'.format(build_v4),
  193. '-e', 'build_v6={}'.format(build_v6),
  194. '-e', 'is_stretched={}'.format(is_stretched),
  195. '-e', 'generate_iflist={}'.format(generate_iflist),
  196. '-e', 'ospf_type={}'.format(ospf_type),
  197. 'add-vlan-playbook.yml']
  198. if args.svi_v4_network:
  199. command += ['-e', 'svi_v4_prefix={}'.format(
  200. svi_prefix), '-e', 'svi_subnet_len={}'.format(args.svi_subnet_len),
  201. '-e', 'svi_v4_network={}'.format(args.svi_v4_network)]
  202. if args.svi_v6_network:
  203. command += ['-e', 'svi_v6_network={}'.format(args.svi_v6_network)]
  204. if args.mtu:
  205. command += ['-e', 'svi_mtu={}'.format(args.mtu)]
  206. if args.svi_descr:
  207. command += ['-e', 'svi_descr=\'{}\''.format(args.svi_descr)]
  208. if use_hsrp:
  209. command += ['-e', 'use_hsrp={}'.format(use_hsrp)]
  210. if passive_interface:
  211. command += ['-e', 'passive_interface={}'.format(passive_interface)]
  212. if svi_v6_link_local:
  213. command += ['-e', 'svi_v6_link_local={}'.format(svi_v6_link_local)]
  214. if args.interface and len(args.interface) > 0:
  215. command += ['-e',
  216. '{{"iflist": [{}]}}'.format(','.join(args.interface))]
  217. if args.generate_iflist:
  218. command += ['-e', '{{"iflist": []}}']
  219. if args.vmware_cluster and len(args.vmware_cluster) > 0:
  220. command += ['-e',
  221. '{{"vm_clusters": [{}]}}'.format(','.join(args.vmware_cluster))]
  222. if args.limit:
  223. command += ['--limit', args.limit]
  224. if args.tags:
  225. command += ['--tags', args.tags]
  226. if args.list_tags:
  227. command += ['--list-tags']
  228. if args.check_only:
  229. command += ['-C']
  230. p = subprocess.Popen(command, stdout=subprocess.PIPE,
  231. stderr=subprocess.STDOUT)
  232. for c in iter(lambda: p.stdout.read(1), b''):
  233. sys.stdout.write(c.decode('utf-8'))
  234. sys.stdout.flush()
  235. p.poll()
  236. if os.path.isfile(cred_file.name):
  237. os.remove(cred_file.name)
  238. if __name__ == '__main__':
  239. main()