models.py 64 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110
  1. from __future__ import unicode_literals
  2. from collections import OrderedDict
  3. from itertools import count, groupby
  4. from django.conf import settings
  5. from django.contrib.auth.models import User
  6. from django.contrib.contenttypes.fields import GenericRelation
  7. from django.contrib.postgres.fields import ArrayField
  8. from django.core.exceptions import ValidationError
  9. from django.core.validators import MaxValueValidator, MinValueValidator
  10. from django.db import models
  11. from django.db.models import Count, Q, ObjectDoesNotExist
  12. from django.urls import reverse
  13. from django.utils.encoding import python_2_unicode_compatible
  14. from mptt.models import MPTTModel, TreeForeignKey
  15. from timezone_field import TimeZoneField
  16. from circuits.models import Circuit
  17. from extras.models import CustomFieldModel
  18. from extras.rpc import RPC_CLIENTS
  19. from utilities.fields import ColorField, NullableCharField
  20. from utilities.managers import NaturalOrderByManager
  21. from utilities.models import CreatedUpdatedModel
  22. from .constants import *
  23. from .fields import ASNField, MACAddressField
  24. from .querysets import InterfaceQuerySet
  25. #
  26. # Regions
  27. #
  28. @python_2_unicode_compatible
  29. class Region(MPTTModel):
  30. """
  31. Sites can be grouped within geographic Regions.
  32. """
  33. parent = TreeForeignKey(
  34. to='self',
  35. on_delete=models.CASCADE,
  36. related_name='children',
  37. blank=True,
  38. null=True,
  39. db_index=True
  40. )
  41. name = models.CharField(
  42. max_length=50,
  43. unique=True
  44. )
  45. slug = models.SlugField(
  46. unique=True
  47. )
  48. csv_headers = ['name', 'slug', 'parent']
  49. class MPTTMeta:
  50. order_insertion_by = ['name']
  51. def __str__(self):
  52. return self.name
  53. def get_absolute_url(self):
  54. return "{}?region={}".format(reverse('dcim:site_list'), self.slug)
  55. def to_csv(self):
  56. return (
  57. self.name,
  58. self.slug,
  59. self.parent.name if self.parent else None,
  60. )
  61. #
  62. # Sites
  63. #
  64. class SiteManager(NaturalOrderByManager):
  65. def get_queryset(self):
  66. return self.natural_order_by('name')
  67. @python_2_unicode_compatible
  68. class Site(CreatedUpdatedModel, CustomFieldModel):
  69. """
  70. A Site represents a geographic location within a network; typically a building or campus. The optional facility
  71. field can be used to include an external designation, such as a data center name (e.g. Equinix SV6).
  72. """
  73. name = models.CharField(
  74. max_length=50,
  75. unique=True
  76. )
  77. slug = models.SlugField(
  78. unique=True
  79. )
  80. status = models.PositiveSmallIntegerField(
  81. choices=SITE_STATUS_CHOICES,
  82. default=SITE_STATUS_ACTIVE
  83. )
  84. region = models.ForeignKey(
  85. to='dcim.Region',
  86. on_delete=models.SET_NULL,
  87. related_name='sites',
  88. blank=True,
  89. null=True
  90. )
  91. tenant = models.ForeignKey(
  92. to='tenancy.Tenant',
  93. on_delete=models.PROTECT,
  94. related_name='sites',
  95. blank=True,
  96. null=True
  97. )
  98. facility = models.CharField(
  99. max_length=50,
  100. blank=True
  101. )
  102. asn = ASNField(
  103. blank=True,
  104. null=True,
  105. verbose_name='ASN'
  106. )
  107. time_zone = TimeZoneField(
  108. blank=True
  109. )
  110. description = models.CharField(
  111. max_length=100,
  112. blank=True
  113. )
  114. physical_address = models.CharField(
  115. max_length=200,
  116. blank=True
  117. )
  118. shipping_address = models.CharField(
  119. max_length=200,
  120. blank=True
  121. )
  122. contact_name = models.CharField(
  123. max_length=50,
  124. blank=True
  125. )
  126. contact_phone = models.CharField(
  127. max_length=20,
  128. blank=True
  129. )
  130. contact_email = models.EmailField(
  131. blank=True,
  132. verbose_name='Contact E-mail'
  133. )
  134. comments = models.TextField(
  135. blank=True
  136. )
  137. custom_field_values = GenericRelation(
  138. to='extras.CustomFieldValue',
  139. content_type_field='obj_type',
  140. object_id_field='obj_id'
  141. )
  142. images = GenericRelation(
  143. to='extras.ImageAttachment'
  144. )
  145. objects = SiteManager()
  146. csv_headers = [
  147. 'name', 'slug', 'status', 'region', 'tenant', 'facility', 'asn', 'time_zone', 'description', 'physical_address',
  148. 'shipping_address', 'contact_name', 'contact_phone', 'contact_email', 'comments',
  149. ]
  150. class Meta:
  151. ordering = ['name']
  152. def __str__(self):
  153. return self.name
  154. def get_absolute_url(self):
  155. return reverse('dcim:site', args=[self.slug])
  156. def to_csv(self):
  157. return (
  158. self.name,
  159. self.slug,
  160. self.get_status_display(),
  161. self.region.name if self.region else None,
  162. self.tenant.name if self.tenant else None,
  163. self.facility,
  164. self.asn,
  165. self.time_zone,
  166. self.description,
  167. self.physical_address,
  168. self.shipping_address,
  169. self.contact_name,
  170. self.contact_phone,
  171. self.contact_email,
  172. self.comments,
  173. )
  174. def get_status_class(self):
  175. return STATUS_CLASSES[self.status]
  176. @property
  177. def count_prefixes(self):
  178. return self.prefixes.count()
  179. @property
  180. def count_vlans(self):
  181. return self.vlans.count()
  182. @property
  183. def count_racks(self):
  184. return Rack.objects.filter(site=self).count()
  185. @property
  186. def count_devices(self):
  187. return Device.objects.filter(site=self).count()
  188. @property
  189. def count_circuits(self):
  190. return Circuit.objects.filter(terminations__site=self).count()
  191. @property
  192. def count_vms(self):
  193. from virtualization.models import VirtualMachine
  194. return VirtualMachine.objects.filter(cluster__site=self).count()
  195. #
  196. # Racks
  197. #
  198. @python_2_unicode_compatible
  199. class RackGroup(models.Model):
  200. """
  201. Racks can be grouped as subsets within a Site. The scope of a group will depend on how Sites are defined. For
  202. example, if a Site spans a corporate campus, a RackGroup might be defined to represent each building within that
  203. campus. If a Site instead represents a single building, a RackGroup might represent a single room or floor.
  204. """
  205. name = models.CharField(
  206. max_length=50
  207. )
  208. slug = models.SlugField()
  209. site = models.ForeignKey(
  210. to='dcim.Site',
  211. on_delete=models.CASCADE,
  212. related_name='rack_groups'
  213. )
  214. csv_headers = ['site', 'name', 'slug']
  215. class Meta:
  216. ordering = ['site', 'name']
  217. unique_together = [
  218. ['site', 'name'],
  219. ['site', 'slug'],
  220. ]
  221. def __str__(self):
  222. return self.name
  223. def get_absolute_url(self):
  224. return "{}?group_id={}".format(reverse('dcim:rack_list'), self.pk)
  225. def to_csv(self):
  226. return (
  227. self.site,
  228. self.name,
  229. self.slug,
  230. )
  231. @python_2_unicode_compatible
  232. class RackRole(models.Model):
  233. """
  234. Racks can be organized by functional role, similar to Devices.
  235. """
  236. name = models.CharField(
  237. max_length=50,
  238. unique=True
  239. )
  240. slug = models.SlugField(
  241. unique=True
  242. )
  243. color = ColorField()
  244. csv_headers = ['name', 'slug', 'color']
  245. class Meta:
  246. ordering = ['name']
  247. def __str__(self):
  248. return self.name
  249. def get_absolute_url(self):
  250. return "{}?role={}".format(reverse('dcim:rack_list'), self.slug)
  251. def to_csv(self):
  252. return (
  253. self.name,
  254. self.slug,
  255. self.color,
  256. )
  257. class RackManager(NaturalOrderByManager):
  258. def get_queryset(self):
  259. return self.natural_order_by('site__name', 'name')
  260. @python_2_unicode_compatible
  261. class Rack(CreatedUpdatedModel, CustomFieldModel):
  262. """
  263. Devices are housed within Racks. Each rack has a defined height measured in rack units, and a front and rear face.
  264. Each Rack is assigned to a Site and (optionally) a RackGroup.
  265. """
  266. name = models.CharField(
  267. max_length=50
  268. )
  269. facility_id = NullableCharField(
  270. max_length=50,
  271. blank=True,
  272. null=True,
  273. verbose_name='Facility ID'
  274. )
  275. site = models.ForeignKey(
  276. to='dcim.Site',
  277. on_delete=models.PROTECT,
  278. related_name='racks'
  279. )
  280. group = models.ForeignKey(
  281. to='dcim.RackGroup',
  282. on_delete=models.SET_NULL,
  283. related_name='racks',
  284. blank=True,
  285. null=True
  286. )
  287. tenant = models.ForeignKey(
  288. to='tenancy.Tenant',
  289. on_delete=models.PROTECT,
  290. related_name='racks',
  291. blank=True,
  292. null=True
  293. )
  294. role = models.ForeignKey(
  295. to='dcim.RackRole',
  296. on_delete=models.PROTECT,
  297. related_name='racks',
  298. blank=True,
  299. null=True
  300. )
  301. serial = models.CharField(
  302. max_length=50,
  303. blank=True,
  304. verbose_name='Serial number'
  305. )
  306. type = models.PositiveSmallIntegerField(
  307. choices=RACK_TYPE_CHOICES,
  308. blank=True,
  309. null=True,
  310. verbose_name='Type'
  311. )
  312. width = models.PositiveSmallIntegerField(
  313. choices=RACK_WIDTH_CHOICES,
  314. default=RACK_WIDTH_19IN,
  315. verbose_name='Width',
  316. help_text='Rail-to-rail width'
  317. )
  318. u_height = models.PositiveSmallIntegerField(
  319. default=42,
  320. verbose_name='Height (U)',
  321. validators=[MinValueValidator(1), MaxValueValidator(100)]
  322. )
  323. desc_units = models.BooleanField(
  324. default=False,
  325. verbose_name='Descending units',
  326. help_text='Units are numbered top-to-bottom'
  327. )
  328. comments = models.TextField(
  329. blank=True
  330. )
  331. custom_field_values = GenericRelation(
  332. to='extras.CustomFieldValue',
  333. content_type_field='obj_type',
  334. object_id_field='obj_id'
  335. )
  336. images = GenericRelation(
  337. to='extras.ImageAttachment'
  338. )
  339. objects = RackManager()
  340. csv_headers = [
  341. 'site', 'group_name', 'name', 'facility_id', 'tenant', 'role', 'type', 'serial', 'width', 'u_height',
  342. 'desc_units', 'comments',
  343. ]
  344. class Meta:
  345. ordering = ['site', 'name']
  346. unique_together = [
  347. ['site', 'name'],
  348. ['site', 'facility_id'],
  349. ]
  350. def __str__(self):
  351. return self.display_name or super(Rack, self).__str__()
  352. def get_absolute_url(self):
  353. return reverse('dcim:rack', args=[self.pk])
  354. def clean(self):
  355. if self.pk:
  356. # Validate that Rack is tall enough to house the installed Devices
  357. top_device = Device.objects.filter(rack=self).exclude(position__isnull=True).order_by('-position').first()
  358. if top_device:
  359. min_height = top_device.position + top_device.device_type.u_height - 1
  360. if self.u_height < min_height:
  361. raise ValidationError({
  362. 'u_height': "Rack must be at least {}U tall to house currently installed devices.".format(
  363. min_height
  364. )
  365. })
  366. # Validate that Rack was assigned a group of its same site, if applicable
  367. if self.group:
  368. if self.group.site != self.site:
  369. raise ValidationError({
  370. 'group': "Rack group must be from the same site, {}.".format(self.site)
  371. })
  372. def save(self, *args, **kwargs):
  373. # Record the original site assignment for this rack.
  374. _site_id = None
  375. if self.pk:
  376. _site_id = Rack.objects.get(pk=self.pk).site_id
  377. super(Rack, self).save(*args, **kwargs)
  378. # Update racked devices if the assigned Site has been changed.
  379. if _site_id is not None and self.site_id != _site_id:
  380. Device.objects.filter(rack=self).update(site_id=self.site.pk)
  381. def to_csv(self):
  382. return (
  383. self.site.name,
  384. self.group.name if self.group else None,
  385. self.name,
  386. self.facility_id,
  387. self.tenant.name if self.tenant else None,
  388. self.role.name if self.role else None,
  389. self.get_type_display() if self.type else None,
  390. self.serial,
  391. self.width,
  392. self.u_height,
  393. self.desc_units,
  394. self.comments,
  395. )
  396. @property
  397. def units(self):
  398. if self.desc_units:
  399. return range(1, self.u_height + 1)
  400. else:
  401. return reversed(range(1, self.u_height + 1))
  402. @property
  403. def display_name(self):
  404. if self.facility_id:
  405. return "{} ({})".format(self.name, self.facility_id)
  406. elif self.name:
  407. return self.name
  408. return ""
  409. def get_rack_units(self, face=RACK_FACE_FRONT, exclude=None, remove_redundant=False):
  410. """
  411. Return a list of rack units as dictionaries. Example: {'device': None, 'face': 0, 'id': 48, 'name': 'U48'}
  412. Each key 'device' is either a Device or None. By default, multi-U devices are repeated for each U they occupy.
  413. :param face: Rack face (front or rear)
  414. :param exclude: PK of a Device to exclude (optional); helpful when relocating a Device within a Rack
  415. :param remove_redundant: If True, rack units occupied by a device already listed will be omitted
  416. """
  417. elevation = OrderedDict()
  418. for u in self.units:
  419. elevation[u] = {'id': u, 'name': 'U{}'.format(u), 'face': face, 'device': None}
  420. # Add devices to rack units list
  421. if self.pk:
  422. for device in Device.objects.select_related('device_type__manufacturer', 'device_role')\
  423. .annotate(devicebay_count=Count('device_bays'))\
  424. .exclude(pk=exclude)\
  425. .filter(rack=self, position__gt=0)\
  426. .filter(Q(face=face) | Q(device_type__is_full_depth=True)):
  427. if remove_redundant:
  428. elevation[device.position]['device'] = device
  429. for u in range(device.position + 1, device.position + device.device_type.u_height):
  430. elevation.pop(u, None)
  431. else:
  432. for u in range(device.position, device.position + device.device_type.u_height):
  433. elevation[u]['device'] = device
  434. return [u for u in elevation.values()]
  435. def get_front_elevation(self):
  436. return self.get_rack_units(face=RACK_FACE_FRONT, remove_redundant=True)
  437. def get_rear_elevation(self):
  438. return self.get_rack_units(face=RACK_FACE_REAR, remove_redundant=True)
  439. def get_available_units(self, u_height=1, rack_face=None, exclude=list()):
  440. """
  441. Return a list of units within the rack available to accommodate a device of a given U height (default 1).
  442. Optionally exclude one or more devices when calculating empty units (needed when moving a device from one
  443. position to another within a rack).
  444. :param u_height: Minimum number of contiguous free units required
  445. :param rack_face: The face of the rack (front or rear) required; 'None' if device is full depth
  446. :param exclude: List of devices IDs to exclude (useful when moving a device within a rack)
  447. """
  448. # Gather all devices which consume U space within the rack
  449. devices = self.devices.select_related('device_type').filter(position__gte=1).exclude(pk__in=exclude)
  450. # Initialize the rack unit skeleton
  451. units = list(range(1, self.u_height + 1))
  452. # Remove units consumed by installed devices
  453. for d in devices:
  454. if rack_face is None or d.face == rack_face or d.device_type.is_full_depth:
  455. for u in range(d.position, d.position + d.device_type.u_height):
  456. try:
  457. units.remove(u)
  458. except ValueError:
  459. # Found overlapping devices in the rack!
  460. pass
  461. # Remove units without enough space above them to accommodate a device of the specified height
  462. available_units = []
  463. for u in units:
  464. if set(range(u, u + u_height)).issubset(units):
  465. available_units.append(u)
  466. return list(reversed(available_units))
  467. def get_reserved_units(self):
  468. """
  469. Return a dictionary mapping all reserved units within the rack to their reservation.
  470. """
  471. reserved_units = {}
  472. for r in self.reservations.all():
  473. for u in r.units:
  474. reserved_units[u] = r
  475. return reserved_units
  476. def get_0u_devices(self):
  477. return self.devices.filter(position=0)
  478. def get_utilization(self):
  479. """
  480. Determine the utilization rate of the rack and return it as a percentage.
  481. """
  482. u_available = len(self.get_available_units())
  483. return int(float(self.u_height - u_available) / self.u_height * 100)
  484. @python_2_unicode_compatible
  485. class RackReservation(models.Model):
  486. """
  487. One or more reserved units within a Rack.
  488. """
  489. rack = models.ForeignKey(
  490. to='dcim.Rack',
  491. on_delete=models.CASCADE,
  492. related_name='reservations'
  493. )
  494. units = ArrayField(
  495. base_field=models.PositiveSmallIntegerField()
  496. )
  497. created = models.DateTimeField(
  498. auto_now_add=True
  499. )
  500. tenant = models.ForeignKey(
  501. to='tenancy.Tenant',
  502. on_delete=models.PROTECT,
  503. related_name='rackreservations',
  504. blank=True,
  505. null=True
  506. )
  507. user = models.ForeignKey(
  508. to=User,
  509. on_delete=models.PROTECT
  510. )
  511. description = models.CharField(
  512. max_length=100
  513. )
  514. class Meta:
  515. ordering = ['created']
  516. def __str__(self):
  517. return "Reservation for rack {}".format(self.rack)
  518. def clean(self):
  519. if self.units:
  520. # Validate that all specified units exist in the Rack.
  521. invalid_units = [u for u in self.units if u not in self.rack.units]
  522. if invalid_units:
  523. raise ValidationError({
  524. 'units': "Invalid unit(s) for {}U rack: {}".format(
  525. self.rack.u_height,
  526. ', '.join([str(u) for u in invalid_units]),
  527. ),
  528. })
  529. # Check that none of the units has already been reserved for this Rack.
  530. reserved_units = []
  531. for resv in self.rack.reservations.exclude(pk=self.pk):
  532. reserved_units += resv.units
  533. conflicting_units = [u for u in self.units if u in reserved_units]
  534. if conflicting_units:
  535. raise ValidationError({
  536. 'units': 'The following units have already been reserved: {}'.format(
  537. ', '.join([str(u) for u in conflicting_units]),
  538. )
  539. })
  540. @property
  541. def unit_list(self):
  542. """
  543. Express the assigned units as a string of summarized ranges. For example:
  544. [0, 1, 2, 10, 14, 15, 16] => "0-2, 10, 14-16"
  545. """
  546. group = (list(x) for _, x in groupby(sorted(self.units), lambda x, c=count(): next(c) - x))
  547. return ', '.join('-'.join(map(str, (g[0], g[-1])[:len(g)])) for g in group)
  548. #
  549. # Device Types
  550. #
  551. @python_2_unicode_compatible
  552. class Manufacturer(models.Model):
  553. """
  554. A Manufacturer represents a company which produces hardware devices; for example, Juniper or Dell.
  555. """
  556. name = models.CharField(
  557. max_length=50,
  558. unique=True
  559. )
  560. slug = models.SlugField(
  561. unique=True
  562. )
  563. csv_headers = ['name', 'slug']
  564. class Meta:
  565. ordering = ['name']
  566. def __str__(self):
  567. return self.name
  568. def get_absolute_url(self):
  569. return "{}?manufacturer={}".format(reverse('dcim:devicetype_list'), self.slug)
  570. def to_csv(self):
  571. return (
  572. self.name,
  573. self.slug,
  574. )
  575. @python_2_unicode_compatible
  576. class DeviceType(models.Model, CustomFieldModel):
  577. """
  578. A DeviceType represents a particular make (Manufacturer) and model of device. It specifies rack height and depth, as
  579. well as high-level functional role(s).
  580. Each DeviceType can have an arbitrary number of component templates assigned to it, which define console, power, and
  581. interface objects. For example, a Juniper EX4300-48T DeviceType would have:
  582. * 1 ConsolePortTemplate
  583. * 2 PowerPortTemplates
  584. * 48 InterfaceTemplates
  585. When a new Device of this type is created, the appropriate console, power, and interface objects (as defined by the
  586. DeviceType) are automatically created as well.
  587. """
  588. manufacturer = models.ForeignKey(
  589. to='dcim.Manufacturer',
  590. on_delete=models.PROTECT,
  591. related_name='device_types'
  592. )
  593. model = models.CharField(
  594. max_length=50
  595. )
  596. slug = models.SlugField()
  597. part_number = models.CharField(
  598. max_length=50,
  599. blank=True,
  600. help_text='Discrete part number (optional)'
  601. )
  602. u_height = models.PositiveSmallIntegerField(
  603. default=1,
  604. verbose_name='Height (U)'
  605. )
  606. is_full_depth = models.BooleanField(
  607. default=True,
  608. verbose_name='Is full depth',
  609. help_text='Device consumes both front and rear rack faces'
  610. )
  611. interface_ordering = models.PositiveSmallIntegerField(
  612. choices=IFACE_ORDERING_CHOICES,
  613. default=IFACE_ORDERING_POSITION
  614. )
  615. is_console_server = models.BooleanField(
  616. default=False,
  617. verbose_name='Is a console server',
  618. help_text='This type of device has console server ports'
  619. )
  620. is_pdu = models.BooleanField(
  621. default=False,
  622. verbose_name='Is a PDU',
  623. help_text='This type of device has power outlets'
  624. )
  625. is_network_device = models.BooleanField(
  626. default=True,
  627. verbose_name='Is a network device',
  628. help_text='This type of device has network interfaces'
  629. )
  630. subdevice_role = models.NullBooleanField(
  631. default=None,
  632. verbose_name='Parent/child status',
  633. choices=SUBDEVICE_ROLE_CHOICES,
  634. help_text='Parent devices house child devices in device bays. Select '
  635. '"None" if this device type is neither a parent nor a child.'
  636. )
  637. comments = models.TextField(
  638. blank=True
  639. )
  640. custom_field_values = GenericRelation(
  641. to='extras.CustomFieldValue',
  642. content_type_field='obj_type',
  643. object_id_field='obj_id'
  644. )
  645. csv_headers = [
  646. 'manufacturer', 'model', 'slug', 'part_number', 'u_height', 'is_full_depth', 'is_console_server',
  647. 'is_pdu', 'is_network_device', 'subdevice_role', 'interface_ordering', 'comments',
  648. ]
  649. class Meta:
  650. ordering = ['manufacturer', 'model']
  651. unique_together = [
  652. ['manufacturer', 'model'],
  653. ['manufacturer', 'slug'],
  654. ]
  655. def __str__(self):
  656. return self.model
  657. def __init__(self, *args, **kwargs):
  658. super(DeviceType, self).__init__(*args, **kwargs)
  659. # Save a copy of u_height for validation in clean()
  660. self._original_u_height = self.u_height
  661. def get_absolute_url(self):
  662. return reverse('dcim:devicetype', args=[self.pk])
  663. def to_csv(self):
  664. return (
  665. self.manufacturer.name,
  666. self.model,
  667. self.slug,
  668. self.part_number,
  669. self.u_height,
  670. self.is_full_depth,
  671. self.is_console_server,
  672. self.is_pdu,
  673. self.is_network_device,
  674. self.get_subdevice_role_display() if self.subdevice_role else None,
  675. self.get_interface_ordering_display(),
  676. self.comments,
  677. )
  678. def clean(self):
  679. # If editing an existing DeviceType to have a larger u_height, first validate that *all* instances of it have
  680. # room to expand within their racks. This validation will impose a very high performance penalty when there are
  681. # many instances to check, but increasing the u_height of a DeviceType should be a very rare occurrence.
  682. if self.pk is not None and self.u_height > self._original_u_height:
  683. for d in Device.objects.filter(device_type=self, position__isnull=False):
  684. face_required = None if self.is_full_depth else d.face
  685. u_available = d.rack.get_available_units(u_height=self.u_height, rack_face=face_required,
  686. exclude=[d.pk])
  687. if d.position not in u_available:
  688. raise ValidationError({
  689. 'u_height': "Device {} in rack {} does not have sufficient space to accommodate a height of "
  690. "{}U".format(d, d.rack, self.u_height)
  691. })
  692. if not self.is_console_server and self.cs_port_templates.count():
  693. raise ValidationError({
  694. 'is_console_server': "Must delete all console server port templates associated with this device before "
  695. "declassifying it as a console server."
  696. })
  697. if not self.is_pdu and self.power_outlet_templates.count():
  698. raise ValidationError({
  699. 'is_pdu': "Must delete all power outlet templates associated with this device before declassifying it "
  700. "as a PDU."
  701. })
  702. if not self.is_network_device and self.interface_templates.filter(mgmt_only=False).count():
  703. raise ValidationError({
  704. 'is_network_device': "Must delete all non-management-only interface templates associated with this "
  705. "device before declassifying it as a network device."
  706. })
  707. if self.subdevice_role != SUBDEVICE_ROLE_PARENT and self.device_bay_templates.count():
  708. raise ValidationError({
  709. 'subdevice_role': "Must delete all device bay templates associated with this device before "
  710. "declassifying it as a parent device."
  711. })
  712. if self.u_height and self.subdevice_role == SUBDEVICE_ROLE_CHILD:
  713. raise ValidationError({
  714. 'u_height': "Child device types must be 0U."
  715. })
  716. @property
  717. def full_name(self):
  718. return '{} {}'.format(self.manufacturer.name, self.model)
  719. @property
  720. def is_parent_device(self):
  721. return bool(self.subdevice_role)
  722. @property
  723. def is_child_device(self):
  724. return bool(self.subdevice_role is False)
  725. @python_2_unicode_compatible
  726. class ConsolePortTemplate(models.Model):
  727. """
  728. A template for a ConsolePort to be created for a new Device.
  729. """
  730. device_type = models.ForeignKey(
  731. to='dcim.DeviceType',
  732. on_delete=models.CASCADE,
  733. related_name='console_port_templates'
  734. )
  735. name = models.CharField(
  736. max_length=50
  737. )
  738. class Meta:
  739. ordering = ['device_type', 'name']
  740. unique_together = ['device_type', 'name']
  741. def __str__(self):
  742. return self.name
  743. @python_2_unicode_compatible
  744. class ConsoleServerPortTemplate(models.Model):
  745. """
  746. A template for a ConsoleServerPort to be created for a new Device.
  747. """
  748. device_type = models.ForeignKey(
  749. to='dcim.DeviceType',
  750. on_delete=models.CASCADE,
  751. related_name='cs_port_templates'
  752. )
  753. name = models.CharField(
  754. max_length=50
  755. )
  756. class Meta:
  757. ordering = ['device_type', 'name']
  758. unique_together = ['device_type', 'name']
  759. def __str__(self):
  760. return self.name
  761. @python_2_unicode_compatible
  762. class PowerPortTemplate(models.Model):
  763. """
  764. A template for a PowerPort to be created for a new Device.
  765. """
  766. device_type = models.ForeignKey(
  767. to='dcim.DeviceType',
  768. on_delete=models.CASCADE,
  769. related_name='power_port_templates'
  770. )
  771. name = models.CharField(
  772. max_length=50
  773. )
  774. class Meta:
  775. ordering = ['device_type', 'name']
  776. unique_together = ['device_type', 'name']
  777. def __str__(self):
  778. return self.name
  779. @python_2_unicode_compatible
  780. class PowerOutletTemplate(models.Model):
  781. """
  782. A template for a PowerOutlet to be created for a new Device.
  783. """
  784. device_type = models.ForeignKey(
  785. to='dcim.DeviceType',
  786. on_delete=models.CASCADE,
  787. related_name='power_outlet_templates'
  788. )
  789. name = models.CharField(
  790. max_length=50
  791. )
  792. class Meta:
  793. ordering = ['device_type', 'name']
  794. unique_together = ['device_type', 'name']
  795. def __str__(self):
  796. return self.name
  797. @python_2_unicode_compatible
  798. class InterfaceTemplate(models.Model):
  799. """
  800. A template for a physical data interface on a new Device.
  801. """
  802. device_type = models.ForeignKey(
  803. to='dcim.DeviceType',
  804. on_delete=models.CASCADE,
  805. related_name='interface_templates'
  806. )
  807. name = models.CharField(
  808. max_length=64
  809. )
  810. form_factor = models.PositiveSmallIntegerField(
  811. choices=IFACE_FF_CHOICES,
  812. default=IFACE_FF_10GE_SFP_PLUS
  813. )
  814. mgmt_only = models.BooleanField(
  815. default=False,
  816. verbose_name='Management only'
  817. )
  818. objects = InterfaceQuerySet.as_manager()
  819. class Meta:
  820. ordering = ['device_type', 'name']
  821. unique_together = ['device_type', 'name']
  822. def __str__(self):
  823. return self.name
  824. @python_2_unicode_compatible
  825. class DeviceBayTemplate(models.Model):
  826. """
  827. A template for a DeviceBay to be created for a new parent Device.
  828. """
  829. device_type = models.ForeignKey(
  830. to='dcim.DeviceType',
  831. on_delete=models.CASCADE,
  832. related_name='device_bay_templates'
  833. )
  834. name = models.CharField(
  835. max_length=50
  836. )
  837. class Meta:
  838. ordering = ['device_type', 'name']
  839. unique_together = ['device_type', 'name']
  840. def __str__(self):
  841. return self.name
  842. #
  843. # Devices
  844. #
  845. @python_2_unicode_compatible
  846. class DeviceRole(models.Model):
  847. """
  848. Devices are organized by functional role; for example, "Core Switch" or "File Server". Each DeviceRole is assigned a
  849. color to be used when displaying rack elevations. The vm_role field determines whether the role is applicable to
  850. virtual machines as well.
  851. """
  852. name = models.CharField(
  853. max_length=50,
  854. unique=True
  855. )
  856. slug = models.SlugField(
  857. unique=True
  858. )
  859. color = ColorField()
  860. vm_role = models.BooleanField(
  861. default=True,
  862. verbose_name='VM Role',
  863. help_text='Virtual machines may be assigned to this role'
  864. )
  865. csv_headers = ['name', 'slug', 'color', 'vm_role']
  866. class Meta:
  867. ordering = ['name']
  868. def __str__(self):
  869. return self.name
  870. def get_absolute_url(self):
  871. return "{}?role={}".format(reverse('dcim:device_list'), self.slug)
  872. def to_csv(self):
  873. return (
  874. self.name,
  875. self.slug,
  876. self.color,
  877. self.vm_role,
  878. )
  879. @python_2_unicode_compatible
  880. class Platform(models.Model):
  881. """
  882. Platform refers to the software or firmware running on a Device. For example, "Cisco IOS-XR" or "Juniper Junos".
  883. NetBox uses Platforms to determine how to interact with devices when pulling inventory data or other information by
  884. specifying a NAPALM driver.
  885. """
  886. name = models.CharField(
  887. max_length=50,
  888. unique=True
  889. )
  890. slug = models.SlugField(
  891. unique=True
  892. )
  893. manufacturer = models.ForeignKey(
  894. to='dcim.Manufacturer',
  895. on_delete=models.PROTECT,
  896. related_name='platforms',
  897. blank=True,
  898. null=True,
  899. help_text='Optionally limit this platform to devices of a certain manufacturer'
  900. )
  901. napalm_driver = models.CharField(
  902. max_length=50,
  903. blank=True,
  904. verbose_name='NAPALM driver',
  905. help_text='The name of the NAPALM driver to use when interacting with devices'
  906. )
  907. rpc_client = models.CharField(
  908. max_length=30,
  909. choices=RPC_CLIENT_CHOICES,
  910. blank=True,
  911. verbose_name='Legacy RPC client'
  912. )
  913. csv_headers = ['name', 'slug', 'manufacturer', 'napalm_driver']
  914. class Meta:
  915. ordering = ['name']
  916. def __str__(self):
  917. return self.name
  918. def get_absolute_url(self):
  919. return "{}?platform={}".format(reverse('dcim:device_list'), self.slug)
  920. def to_csv(self):
  921. return (
  922. self.name,
  923. self.slug,
  924. self.manufacturer.name if self.manufacturer else None,
  925. self.napalm_driver,
  926. )
  927. class DeviceManager(NaturalOrderByManager):
  928. def get_queryset(self):
  929. return self.natural_order_by('name')
  930. @python_2_unicode_compatible
  931. class Device(CreatedUpdatedModel, CustomFieldModel):
  932. """
  933. A Device represents a piece of physical hardware mounted within a Rack. Each Device is assigned a DeviceType,
  934. DeviceRole, and (optionally) a Platform. Device names are not required, however if one is set it must be unique.
  935. Each Device must be assigned to a site, and optionally to a rack within that site. Associating a device with a
  936. particular rack face or unit is optional (for example, vertically mounted PDUs do not consume rack units).
  937. When a new Device is created, console/power/interface/device bay components are created along with it as dictated
  938. by the component templates assigned to its DeviceType. Components can also be added, modified, or deleted after the
  939. creation of a Device.
  940. """
  941. device_type = models.ForeignKey(
  942. to='dcim.DeviceType',
  943. on_delete=models.PROTECT,
  944. related_name='instances'
  945. )
  946. device_role = models.ForeignKey(
  947. to='dcim.DeviceRole',
  948. on_delete=models.PROTECT,
  949. related_name='devices'
  950. )
  951. tenant = models.ForeignKey(
  952. to='tenancy.Tenant',
  953. on_delete=models.PROTECT,
  954. related_name='devices',
  955. blank=True,
  956. null=True
  957. )
  958. platform = models.ForeignKey(
  959. to='dcim.Platform',
  960. on_delete=models.SET_NULL,
  961. related_name='devices',
  962. blank=True,
  963. null=True
  964. )
  965. name = NullableCharField(
  966. max_length=64,
  967. blank=True,
  968. null=True,
  969. unique=True
  970. )
  971. serial = models.CharField(
  972. max_length=50,
  973. blank=True,
  974. verbose_name='Serial number'
  975. )
  976. asset_tag = NullableCharField(
  977. max_length=50,
  978. blank=True,
  979. null=True,
  980. unique=True,
  981. verbose_name='Asset tag',
  982. help_text='A unique tag used to identify this device'
  983. )
  984. site = models.ForeignKey(
  985. to='dcim.Site',
  986. on_delete=models.PROTECT,
  987. related_name='devices'
  988. )
  989. rack = models.ForeignKey(
  990. to='dcim.Rack',
  991. on_delete=models.PROTECT,
  992. related_name='devices',
  993. blank=True,
  994. null=True
  995. )
  996. position = models.PositiveSmallIntegerField(
  997. blank=True,
  998. null=True,
  999. validators=[MinValueValidator(1)],
  1000. verbose_name='Position (U)',
  1001. help_text='The lowest-numbered unit occupied by the device'
  1002. )
  1003. face = models.PositiveSmallIntegerField(
  1004. blank=True,
  1005. null=True,
  1006. choices=RACK_FACE_CHOICES,
  1007. verbose_name='Rack face'
  1008. )
  1009. status = models.PositiveSmallIntegerField(
  1010. choices=DEVICE_STATUS_CHOICES,
  1011. default=DEVICE_STATUS_ACTIVE,
  1012. verbose_name='Status'
  1013. )
  1014. primary_ip4 = models.OneToOneField(
  1015. to='ipam.IPAddress',
  1016. on_delete=models.SET_NULL,
  1017. related_name='primary_ip4_for',
  1018. blank=True,
  1019. null=True,
  1020. verbose_name='Primary IPv4'
  1021. )
  1022. primary_ip6 = models.OneToOneField(
  1023. to='ipam.IPAddress',
  1024. on_delete=models.SET_NULL,
  1025. related_name='primary_ip6_for',
  1026. blank=True,
  1027. null=True,
  1028. verbose_name='Primary IPv6'
  1029. )
  1030. cluster = models.ForeignKey(
  1031. to='virtualization.Cluster',
  1032. on_delete=models.SET_NULL,
  1033. related_name='devices',
  1034. blank=True,
  1035. null=True
  1036. )
  1037. virtual_chassis = models.ForeignKey(
  1038. to='VirtualChassis',
  1039. on_delete=models.SET_NULL,
  1040. related_name='members',
  1041. blank=True,
  1042. null=True
  1043. )
  1044. vc_position = models.PositiveSmallIntegerField(
  1045. blank=True,
  1046. null=True,
  1047. validators=[MaxValueValidator(255)]
  1048. )
  1049. vc_priority = models.PositiveSmallIntegerField(
  1050. blank=True,
  1051. null=True,
  1052. validators=[MaxValueValidator(255)]
  1053. )
  1054. comments = models.TextField(
  1055. blank=True
  1056. )
  1057. custom_field_values = GenericRelation(
  1058. to='extras.CustomFieldValue',
  1059. content_type_field='obj_type',
  1060. object_id_field='obj_id'
  1061. )
  1062. images = GenericRelation(
  1063. to='extras.ImageAttachment'
  1064. )
  1065. objects = DeviceManager()
  1066. csv_headers = [
  1067. 'name', 'device_role', 'tenant', 'manufacturer', 'model_name', 'platform', 'serial', 'asset_tag', 'status',
  1068. 'site', 'rack_group', 'rack_name', 'position', 'face', 'comments',
  1069. ]
  1070. class Meta:
  1071. ordering = ['name']
  1072. unique_together = [
  1073. ['rack', 'position', 'face'],
  1074. ['virtual_chassis', 'vc_position'],
  1075. ]
  1076. permissions = (
  1077. ('napalm_read', 'Read-only access to devices via NAPALM'),
  1078. ('napalm_write', 'Read/write access to devices via NAPALM'),
  1079. )
  1080. def __str__(self):
  1081. return self.display_name or super(Device, self).__str__()
  1082. def get_absolute_url(self):
  1083. return reverse('dcim:device', args=[self.pk])
  1084. def clean(self):
  1085. # Validate site/rack combination
  1086. if self.rack and self.site != self.rack.site:
  1087. raise ValidationError({
  1088. 'rack': "Rack {} does not belong to site {}.".format(self.rack, self.site),
  1089. })
  1090. if self.rack is None:
  1091. if self.face is not None:
  1092. raise ValidationError({
  1093. 'face': "Cannot select a rack face without assigning a rack.",
  1094. })
  1095. if self.position:
  1096. raise ValidationError({
  1097. 'face': "Cannot select a rack position without assigning a rack.",
  1098. })
  1099. # Validate position/face combination
  1100. if self.position and self.face is None:
  1101. raise ValidationError({
  1102. 'face': "Must specify rack face when defining rack position.",
  1103. })
  1104. if self.rack:
  1105. try:
  1106. # Child devices cannot be assigned to a rack face/unit
  1107. if self.device_type.is_child_device and self.face is not None:
  1108. raise ValidationError({
  1109. 'face': "Child device types cannot be assigned to a rack face. This is an attribute of the "
  1110. "parent device."
  1111. })
  1112. if self.device_type.is_child_device and self.position:
  1113. raise ValidationError({
  1114. 'position': "Child device types cannot be assigned to a rack position. This is an attribute of "
  1115. "the parent device."
  1116. })
  1117. # Validate rack space
  1118. rack_face = self.face if not self.device_type.is_full_depth else None
  1119. exclude_list = [self.pk] if self.pk else []
  1120. try:
  1121. available_units = self.rack.get_available_units(
  1122. u_height=self.device_type.u_height, rack_face=rack_face, exclude=exclude_list
  1123. )
  1124. if self.position and self.position not in available_units:
  1125. raise ValidationError({
  1126. 'position': "U{} is already occupied or does not have sufficient space to accommodate a(n) "
  1127. "{} ({}U).".format(self.position, self.device_type, self.device_type.u_height)
  1128. })
  1129. except Rack.DoesNotExist:
  1130. pass
  1131. except DeviceType.DoesNotExist:
  1132. pass
  1133. # Validate primary IP addresses
  1134. vc_interfaces = self.vc_interfaces.all()
  1135. if self.primary_ip4:
  1136. if self.primary_ip4.interface in vc_interfaces:
  1137. pass
  1138. elif self.primary_ip4.nat_inside is not None and self.primary_ip4.nat_inside.interface in vc_interfaces:
  1139. pass
  1140. else:
  1141. raise ValidationError({
  1142. 'primary_ip4': "The specified IP address ({}) is not assigned to this device.".format(
  1143. self.primary_ip4),
  1144. })
  1145. if self.primary_ip6:
  1146. if self.primary_ip6.interface in vc_interfaces:
  1147. pass
  1148. elif self.primary_ip6.nat_inside is not None and self.primary_ip6.nat_inside.interface in vc_interfaces:
  1149. pass
  1150. else:
  1151. raise ValidationError({
  1152. 'primary_ip6': "The specified IP address ({}) is not assigned to this device.".format(
  1153. self.primary_ip6),
  1154. })
  1155. # Validate manufacturer/platform
  1156. if self.device_type and self.platform:
  1157. if self.platform.manufacturer and self.platform.manufacturer != self.device_type.manufacturer:
  1158. raise ValidationError({
  1159. 'platform': "The assigned platform is limited to {} device types, but this device's type belongs "
  1160. "to {}.".format(self.platform.manufacturer, self.device_type.manufacturer)
  1161. })
  1162. # A Device can only be assigned to a Cluster in the same Site (or no Site)
  1163. if self.cluster and self.cluster.site is not None and self.cluster.site != self.site:
  1164. raise ValidationError({
  1165. 'cluster': "The assigned cluster belongs to a different site ({})".format(self.cluster.site)
  1166. })
  1167. # Validate virtual chassis assignment
  1168. if self.virtual_chassis and self.vc_position is None:
  1169. raise ValidationError({
  1170. 'vc_position': "A device assigned to a virtual chassis must have its position defined."
  1171. })
  1172. def save(self, *args, **kwargs):
  1173. is_new = not bool(self.pk)
  1174. super(Device, self).save(*args, **kwargs)
  1175. # If this is a new Device, instantiate all of the related components per the DeviceType definition
  1176. if is_new:
  1177. ConsolePort.objects.bulk_create(
  1178. [ConsolePort(device=self, name=template.name) for template in
  1179. self.device_type.console_port_templates.all()]
  1180. )
  1181. ConsoleServerPort.objects.bulk_create(
  1182. [ConsoleServerPort(device=self, name=template.name) for template in
  1183. self.device_type.cs_port_templates.all()]
  1184. )
  1185. PowerPort.objects.bulk_create(
  1186. [PowerPort(device=self, name=template.name) for template in
  1187. self.device_type.power_port_templates.all()]
  1188. )
  1189. PowerOutlet.objects.bulk_create(
  1190. [PowerOutlet(device=self, name=template.name) for template in
  1191. self.device_type.power_outlet_templates.all()]
  1192. )
  1193. Interface.objects.bulk_create(
  1194. [Interface(device=self, name=template.name, form_factor=template.form_factor,
  1195. mgmt_only=template.mgmt_only) for template in self.device_type.interface_templates.all()]
  1196. )
  1197. DeviceBay.objects.bulk_create(
  1198. [DeviceBay(device=self, name=template.name) for template in
  1199. self.device_type.device_bay_templates.all()]
  1200. )
  1201. # Update Site and Rack assignment for any child Devices
  1202. Device.objects.filter(parent_bay__device=self).update(site=self.site, rack=self.rack)
  1203. def to_csv(self):
  1204. return (
  1205. self.name or '',
  1206. self.device_role.name,
  1207. self.tenant.name if self.tenant else None,
  1208. self.device_type.manufacturer.name,
  1209. self.device_type.model,
  1210. self.platform.name if self.platform else None,
  1211. self.serial,
  1212. self.asset_tag,
  1213. self.get_status_display(),
  1214. self.site.name,
  1215. self.rack.group.name if self.rack and self.rack.group else None,
  1216. self.rack.name if self.rack else None,
  1217. self.position,
  1218. self.get_face_display(),
  1219. self.comments,
  1220. )
  1221. @property
  1222. def display_name(self):
  1223. if self.name:
  1224. return self.name
  1225. elif self.virtual_chassis and self.virtual_chassis.master.name:
  1226. return "{}:{}".format(self.virtual_chassis.master, self.vc_position)
  1227. elif hasattr(self, 'device_type'):
  1228. return "{}".format(self.device_type)
  1229. return ""
  1230. @property
  1231. def identifier(self):
  1232. """
  1233. Return the device name if set; otherwise return the Device's primary key as {pk}
  1234. """
  1235. if self.name is not None:
  1236. return self.name
  1237. return '{{{}}}'.format(self.pk)
  1238. @property
  1239. def primary_ip(self):
  1240. if settings.PREFER_IPV4 and self.primary_ip4:
  1241. return self.primary_ip4
  1242. elif self.primary_ip6:
  1243. return self.primary_ip6
  1244. elif self.primary_ip4:
  1245. return self.primary_ip4
  1246. else:
  1247. return None
  1248. def get_vc_master(self):
  1249. """
  1250. If this Device is a VirtualChassis member, return the VC master. Otherwise, return None.
  1251. """
  1252. return self.virtual_chassis.master if self.virtual_chassis else None
  1253. @property
  1254. def vc_interfaces(self):
  1255. """
  1256. Return a QuerySet matching all Interfaces assigned to this Device or, if this Device is a VC master, to another
  1257. Device belonging to the same VirtualChassis.
  1258. """
  1259. filter = Q(device=self)
  1260. if self.virtual_chassis and self.virtual_chassis.master == self:
  1261. filter |= Q(device__virtual_chassis=self.virtual_chassis, mgmt_only=False)
  1262. return Interface.objects.filter(filter)
  1263. def get_children(self):
  1264. """
  1265. Return the set of child Devices installed in DeviceBays within this Device.
  1266. """
  1267. return Device.objects.filter(parent_bay__device=self.pk)
  1268. def get_status_class(self):
  1269. return STATUS_CLASSES[self.status]
  1270. def get_rpc_client(self):
  1271. """
  1272. Return the appropriate RPC (e.g. NETCONF, ssh, etc.) client for this device's platform, if one is defined.
  1273. """
  1274. if not self.platform:
  1275. return None
  1276. return RPC_CLIENTS.get(self.platform.rpc_client)
  1277. #
  1278. # Console ports
  1279. #
  1280. @python_2_unicode_compatible
  1281. class ConsolePort(models.Model):
  1282. """
  1283. A physical console port within a Device. ConsolePorts connect to ConsoleServerPorts.
  1284. """
  1285. device = models.ForeignKey(
  1286. to='dcim.Device',
  1287. on_delete=models.CASCADE,
  1288. related_name='console_ports'
  1289. )
  1290. name = models.CharField(
  1291. max_length=50
  1292. )
  1293. cs_port = models.OneToOneField(
  1294. to='dcim.ConsoleServerPort',
  1295. on_delete=models.SET_NULL,
  1296. related_name='connected_console',
  1297. verbose_name='Console server port',
  1298. blank=True,
  1299. null=True
  1300. )
  1301. connection_status = models.NullBooleanField(
  1302. choices=CONNECTION_STATUS_CHOICES,
  1303. default=CONNECTION_STATUS_CONNECTED
  1304. )
  1305. csv_headers = ['console_server', 'cs_port', 'device', 'console_port', 'connection_status']
  1306. class Meta:
  1307. ordering = ['device', 'name']
  1308. unique_together = ['device', 'name']
  1309. def __str__(self):
  1310. return self.name
  1311. def get_absolute_url(self):
  1312. return self.device.get_absolute_url()
  1313. def to_csv(self):
  1314. return (
  1315. self.cs_port.device.identifier if self.cs_port else None,
  1316. self.cs_port.name if self.cs_port else None,
  1317. self.device.identifier,
  1318. self.name,
  1319. self.get_connection_status_display(),
  1320. )
  1321. #
  1322. # Console server ports
  1323. #
  1324. class ConsoleServerPortManager(models.Manager):
  1325. def get_queryset(self):
  1326. # Pad any trailing digits to effect natural sorting
  1327. return super(ConsoleServerPortManager, self).get_queryset().extra(select={
  1328. 'name_padded': "CONCAT(REGEXP_REPLACE(dcim_consoleserverport.name, '\d+$', ''), "
  1329. "LPAD(SUBSTRING(dcim_consoleserverport.name FROM '\d+$'), 8, '0'))",
  1330. }).order_by('device', 'name_padded')
  1331. @python_2_unicode_compatible
  1332. class ConsoleServerPort(models.Model):
  1333. """
  1334. A physical port within a Device (typically a designated console server) which provides access to ConsolePorts.
  1335. """
  1336. device = models.ForeignKey(
  1337. to='dcim.Device',
  1338. on_delete=models.CASCADE,
  1339. related_name='cs_ports'
  1340. )
  1341. name = models.CharField(
  1342. max_length=50
  1343. )
  1344. objects = ConsoleServerPortManager()
  1345. class Meta:
  1346. unique_together = ['device', 'name']
  1347. def __str__(self):
  1348. return self.name
  1349. def get_absolute_url(self):
  1350. return self.device.get_absolute_url()
  1351. def clean(self):
  1352. # Check that the parent device's DeviceType is a console server
  1353. if self.device is None:
  1354. raise ValidationError("Console server ports must be assigned to devices.")
  1355. device_type = self.device.device_type
  1356. if not device_type.is_console_server:
  1357. raise ValidationError("The {} {} device type not support assignment of console server ports.".format(
  1358. device_type.manufacturer, device_type
  1359. ))
  1360. #
  1361. # Power ports
  1362. #
  1363. @python_2_unicode_compatible
  1364. class PowerPort(models.Model):
  1365. """
  1366. A physical power supply (intake) port within a Device. PowerPorts connect to PowerOutlets.
  1367. """
  1368. device = models.ForeignKey(
  1369. to='dcim.Device',
  1370. on_delete=models.CASCADE,
  1371. related_name='power_ports'
  1372. )
  1373. name = models.CharField(
  1374. max_length=50
  1375. )
  1376. power_outlet = models.OneToOneField(
  1377. to='dcim.PowerOutlet',
  1378. on_delete=models.SET_NULL,
  1379. related_name='connected_port',
  1380. blank=True,
  1381. null=True
  1382. )
  1383. connection_status = models.NullBooleanField(
  1384. choices=CONNECTION_STATUS_CHOICES,
  1385. default=CONNECTION_STATUS_CONNECTED
  1386. )
  1387. csv_headers = ['pdu', 'power_outlet', 'device', 'power_port', 'connection_status']
  1388. class Meta:
  1389. ordering = ['device', 'name']
  1390. unique_together = ['device', 'name']
  1391. def __str__(self):
  1392. return self.name
  1393. def get_absolute_url(self):
  1394. return self.device.get_absolute_url()
  1395. def to_csv(self):
  1396. return (
  1397. self.power_outlet.device.identifier if self.power_outlet else None,
  1398. self.power_outlet.name if self.power_outlet else None,
  1399. self.device.identifier,
  1400. self.name,
  1401. self.get_connection_status_display(),
  1402. )
  1403. #
  1404. # Power outlets
  1405. #
  1406. class PowerOutletManager(models.Manager):
  1407. def get_queryset(self):
  1408. # Pad any trailing digits to effect natural sorting
  1409. return super(PowerOutletManager, self).get_queryset().extra(select={
  1410. 'name_padded': "CONCAT(REGEXP_REPLACE(dcim_poweroutlet.name, '\d+$', ''), "
  1411. "LPAD(SUBSTRING(dcim_poweroutlet.name FROM '\d+$'), 8, '0'))",
  1412. }).order_by('device', 'name_padded')
  1413. @python_2_unicode_compatible
  1414. class PowerOutlet(models.Model):
  1415. """
  1416. A physical power outlet (output) within a Device which provides power to a PowerPort.
  1417. """
  1418. device = models.ForeignKey(
  1419. to='dcim.Device',
  1420. on_delete=models.CASCADE,
  1421. related_name='power_outlets'
  1422. )
  1423. name = models.CharField(
  1424. max_length=50
  1425. )
  1426. objects = PowerOutletManager()
  1427. class Meta:
  1428. unique_together = ['device', 'name']
  1429. def __str__(self):
  1430. return self.name
  1431. def get_absolute_url(self):
  1432. return self.device.get_absolute_url()
  1433. def clean(self):
  1434. # Check that the parent device's DeviceType is a PDU
  1435. if self.device is None:
  1436. raise ValidationError("Power outlets must be assigned to devices.")
  1437. device_type = self.device.device_type
  1438. if not device_type.is_pdu:
  1439. raise ValidationError("The {} {} device type not support assignment of power outlets.".format(
  1440. device_type.manufacturer, device_type
  1441. ))
  1442. #
  1443. # Interfaces
  1444. #
  1445. @python_2_unicode_compatible
  1446. class Interface(models.Model):
  1447. """
  1448. A network interface within a Device or VirtualMachine. A physical Interface can connect to exactly one other
  1449. Interface via the creation of an InterfaceConnection.
  1450. """
  1451. device = models.ForeignKey(
  1452. to='Device',
  1453. on_delete=models.CASCADE,
  1454. related_name='interfaces',
  1455. null=True,
  1456. blank=True
  1457. )
  1458. virtual_machine = models.ForeignKey(
  1459. to='virtualization.VirtualMachine',
  1460. on_delete=models.CASCADE,
  1461. related_name='interfaces',
  1462. null=True,
  1463. blank=True
  1464. )
  1465. lag = models.ForeignKey(
  1466. to='self',
  1467. on_delete=models.SET_NULL,
  1468. related_name='member_interfaces',
  1469. null=True,
  1470. blank=True,
  1471. verbose_name='Parent LAG'
  1472. )
  1473. name = models.CharField(
  1474. max_length=64
  1475. )
  1476. form_factor = models.PositiveSmallIntegerField(
  1477. choices=IFACE_FF_CHOICES,
  1478. default=IFACE_FF_10GE_SFP_PLUS
  1479. )
  1480. enabled = models.BooleanField(
  1481. default=True
  1482. )
  1483. mac_address = MACAddressField(
  1484. null=True,
  1485. blank=True,
  1486. verbose_name='MAC Address'
  1487. )
  1488. mtu = models.PositiveSmallIntegerField(
  1489. blank=True,
  1490. null=True,
  1491. verbose_name='MTU'
  1492. )
  1493. mgmt_only = models.BooleanField(
  1494. default=False,
  1495. verbose_name='OOB Management',
  1496. help_text='This interface is used only for out-of-band management'
  1497. )
  1498. description = models.CharField(
  1499. max_length=100,
  1500. blank=True
  1501. )
  1502. mode = models.PositiveSmallIntegerField(
  1503. choices=IFACE_MODE_CHOICES,
  1504. blank=True,
  1505. null=True
  1506. )
  1507. untagged_vlan = models.ForeignKey(
  1508. to='ipam.VLAN',
  1509. on_delete=models.SET_NULL,
  1510. related_name='interfaces_as_untagged',
  1511. null=True,
  1512. blank=True,
  1513. verbose_name='Untagged VLAN'
  1514. )
  1515. tagged_vlans = models.ManyToManyField(
  1516. to='ipam.VLAN',
  1517. related_name='interfaces_as_tagged',
  1518. blank=True,
  1519. verbose_name='Tagged VLANs'
  1520. )
  1521. objects = InterfaceQuerySet.as_manager()
  1522. class Meta:
  1523. ordering = ['device', 'name']
  1524. unique_together = ['device', 'name']
  1525. def __str__(self):
  1526. return self.name
  1527. def get_absolute_url(self):
  1528. return self.parent.get_absolute_url()
  1529. def clean(self):
  1530. # Check that the parent device's DeviceType is a network device
  1531. if self.device is not None:
  1532. device_type = self.device.device_type
  1533. if not device_type.is_network_device:
  1534. raise ValidationError("The {} {} device type not support assignment of network interfaces.".format(
  1535. device_type.manufacturer, device_type
  1536. ))
  1537. # An Interface must belong to a Device *or* to a VirtualMachine
  1538. if self.device and self.virtual_machine:
  1539. raise ValidationError("An interface cannot belong to both a device and a virtual machine.")
  1540. if not self.device and not self.virtual_machine:
  1541. raise ValidationError("An interface must belong to either a device or a virtual machine.")
  1542. # VM interfaces must be virtual
  1543. if self.virtual_machine and self.form_factor is not IFACE_FF_VIRTUAL:
  1544. raise ValidationError({
  1545. 'form_factor': "Virtual machines can only have virtual interfaces."
  1546. })
  1547. # Virtual interfaces cannot be connected
  1548. if self.form_factor in NONCONNECTABLE_IFACE_TYPES and self.is_connected:
  1549. raise ValidationError({
  1550. 'form_factor': "Virtual and wireless interfaces cannot be connected to another interface or circuit. "
  1551. "Disconnect the interface or choose a suitable form factor."
  1552. })
  1553. # An interface's LAG must belong to the same device (or VC master)
  1554. if self.lag and self.lag.device not in [self.device, self.device.get_vc_master()]:
  1555. raise ValidationError({
  1556. 'lag': "The selected LAG interface ({}) belongs to a different device ({}).".format(
  1557. self.lag.name, self.lag.device.name
  1558. )
  1559. })
  1560. # A virtual interface cannot have a parent LAG
  1561. if self.form_factor in NONCONNECTABLE_IFACE_TYPES and self.lag is not None:
  1562. raise ValidationError({
  1563. 'lag': "{} interfaces cannot have a parent LAG interface.".format(self.get_form_factor_display())
  1564. })
  1565. # Only a LAG can have LAG members
  1566. if self.form_factor != IFACE_FF_LAG and self.member_interfaces.exists():
  1567. raise ValidationError({
  1568. 'form_factor': "Cannot change interface form factor; it has LAG members ({}).".format(
  1569. ", ".join([iface.name for iface in self.member_interfaces.all()])
  1570. )
  1571. })
  1572. # Validate untagged VLAN
  1573. if self.untagged_vlan and self.untagged_vlan.site not in [self.parent.site, None]:
  1574. raise ValidationError({
  1575. 'untagged_vlan': "The untagged VLAN ({}) must belong to the same site as the interface's parent "
  1576. "device/VM, or it must be global".format(self.untagged_vlan)
  1577. })
  1578. def save(self, *args, **kwargs):
  1579. # Remove untagged VLAN assignment for non-802.1Q interfaces
  1580. if self.mode is None:
  1581. self.untagged_vlan = None
  1582. # Only "tagged" interfaces may have tagged VLANs assigned. ("tagged all" implies all VLANs are assigned.)
  1583. if self.pk and self.mode is not IFACE_MODE_TAGGED:
  1584. self.tagged_vlans.clear()
  1585. return super(Interface, self).save(*args, **kwargs)
  1586. @property
  1587. def parent(self):
  1588. return self.device or self.virtual_machine
  1589. @property
  1590. def is_virtual(self):
  1591. return self.form_factor in VIRTUAL_IFACE_TYPES
  1592. @property
  1593. def is_wireless(self):
  1594. return self.form_factor in WIRELESS_IFACE_TYPES
  1595. @property
  1596. def is_lag(self):
  1597. return self.form_factor == IFACE_FF_LAG
  1598. @property
  1599. def is_connected(self):
  1600. try:
  1601. return bool(self.circuit_termination)
  1602. except ObjectDoesNotExist:
  1603. pass
  1604. return bool(self.connection)
  1605. @property
  1606. def connection(self):
  1607. try:
  1608. return self.connected_as_a
  1609. except ObjectDoesNotExist:
  1610. pass
  1611. try:
  1612. return self.connected_as_b
  1613. except ObjectDoesNotExist:
  1614. pass
  1615. return None
  1616. @property
  1617. def connected_interface(self):
  1618. try:
  1619. if self.connected_as_a:
  1620. return self.connected_as_a.interface_b
  1621. except ObjectDoesNotExist:
  1622. pass
  1623. try:
  1624. if self.connected_as_b:
  1625. return self.connected_as_b.interface_a
  1626. except ObjectDoesNotExist:
  1627. pass
  1628. return None
  1629. class InterfaceConnection(models.Model):
  1630. """
  1631. An InterfaceConnection represents a symmetrical, one-to-one connection between two Interfaces. There is no
  1632. significant difference between the interface_a and interface_b fields.
  1633. """
  1634. interface_a = models.OneToOneField(
  1635. to='dcim.Interface',
  1636. on_delete=models.CASCADE,
  1637. related_name='connected_as_a'
  1638. )
  1639. interface_b = models.OneToOneField(
  1640. to='dcim.Interface',
  1641. on_delete=models.CASCADE,
  1642. related_name='connected_as_b'
  1643. )
  1644. connection_status = models.BooleanField(
  1645. choices=CONNECTION_STATUS_CHOICES,
  1646. default=CONNECTION_STATUS_CONNECTED,
  1647. verbose_name='Status'
  1648. )
  1649. csv_headers = ['device_a', 'interface_a', 'device_b', 'interface_b', 'connection_status']
  1650. def clean(self):
  1651. try:
  1652. if self.interface_a == self.interface_b:
  1653. raise ValidationError({
  1654. 'interface_b': "Cannot connect an interface to itself."
  1655. })
  1656. except ObjectDoesNotExist:
  1657. pass
  1658. def to_csv(self):
  1659. return (
  1660. self.interface_a.device.identifier,
  1661. self.interface_a.name,
  1662. self.interface_b.device.identifier,
  1663. self.interface_b.name,
  1664. self.get_connection_status_display(),
  1665. )
  1666. #
  1667. # Device bays
  1668. #
  1669. @python_2_unicode_compatible
  1670. class DeviceBay(models.Model):
  1671. """
  1672. An empty space within a Device which can house a child device
  1673. """
  1674. device = models.ForeignKey(
  1675. to='dcim.Device',
  1676. on_delete=models.CASCADE,
  1677. related_name='device_bays'
  1678. )
  1679. name = models.CharField(
  1680. max_length=50,
  1681. verbose_name='Name'
  1682. )
  1683. installed_device = models.OneToOneField(
  1684. to='dcim.Device',
  1685. on_delete=models.SET_NULL,
  1686. related_name='parent_bay',
  1687. blank=True,
  1688. null=True
  1689. )
  1690. class Meta:
  1691. ordering = ['device', 'name']
  1692. unique_together = ['device', 'name']
  1693. def __str__(self):
  1694. return '{} - {}'.format(self.device.name, self.name)
  1695. def get_absolute_url(self):
  1696. return self.device.get_absolute_url()
  1697. def clean(self):
  1698. # Validate that the parent Device can have DeviceBays
  1699. if not self.device.device_type.is_parent_device:
  1700. raise ValidationError("This type of device ({}) does not support device bays.".format(
  1701. self.device.device_type
  1702. ))
  1703. # Cannot install a device into itself, obviously
  1704. if self.device == self.installed_device:
  1705. raise ValidationError("Cannot install a device into itself.")
  1706. #
  1707. # Inventory items
  1708. #
  1709. @python_2_unicode_compatible
  1710. class InventoryItem(models.Model):
  1711. """
  1712. An InventoryItem represents a serialized piece of hardware within a Device, such as a line card or power supply.
  1713. InventoryItems are used only for inventory purposes.
  1714. """
  1715. device = models.ForeignKey(
  1716. to='dcim.Device',
  1717. on_delete=models.CASCADE,
  1718. related_name='inventory_items'
  1719. )
  1720. parent = models.ForeignKey(
  1721. to='self',
  1722. on_delete=models.CASCADE,
  1723. related_name='child_items',
  1724. blank=True,
  1725. null=True
  1726. )
  1727. name = models.CharField(
  1728. max_length=50,
  1729. verbose_name='Name'
  1730. )
  1731. manufacturer = models.ForeignKey(
  1732. to='dcim.Manufacturer',
  1733. on_delete=models.PROTECT,
  1734. related_name='inventory_items',
  1735. blank=True,
  1736. null=True
  1737. )
  1738. part_id = models.CharField(
  1739. max_length=50,
  1740. verbose_name='Part ID',
  1741. blank=True
  1742. )
  1743. serial = models.CharField(
  1744. max_length=50,
  1745. verbose_name='Serial number',
  1746. blank=True
  1747. )
  1748. asset_tag = NullableCharField(
  1749. max_length=50,
  1750. unique=True,
  1751. blank=True,
  1752. null=True,
  1753. verbose_name='Asset tag',
  1754. help_text='A unique tag used to identify this item'
  1755. )
  1756. discovered = models.BooleanField(
  1757. default=False,
  1758. verbose_name='Discovered'
  1759. )
  1760. description = models.CharField(
  1761. max_length=100,
  1762. blank=True
  1763. )
  1764. csv_headers = [
  1765. 'device', 'name', 'manufacturer', 'part_id', 'serial', 'asset_tag', 'discovered', 'description',
  1766. ]
  1767. class Meta:
  1768. ordering = ['device__id', 'parent__id', 'name']
  1769. unique_together = ['device', 'parent', 'name']
  1770. def __str__(self):
  1771. return self.name
  1772. def get_absolute_url(self):
  1773. return self.device.get_absolute_url()
  1774. def to_csv(self):
  1775. return (
  1776. self.device.name or '{' + self.device.pk + '}',
  1777. self.name,
  1778. self.manufacturer.name if self.manufacturer else None,
  1779. self.part_id,
  1780. self.serial,
  1781. self.asset_tag,
  1782. self.discovered,
  1783. self.description,
  1784. )
  1785. #
  1786. # Virtual chassis
  1787. #
  1788. @python_2_unicode_compatible
  1789. class VirtualChassis(models.Model):
  1790. """
  1791. A collection of Devices which operate with a shared control plane (e.g. a switch stack).
  1792. """
  1793. master = models.OneToOneField(
  1794. to='Device',
  1795. on_delete=models.PROTECT,
  1796. related_name='vc_master_for'
  1797. )
  1798. domain = models.CharField(
  1799. max_length=30,
  1800. blank=True
  1801. )
  1802. class Meta:
  1803. ordering = ['master']
  1804. verbose_name_plural = 'virtual chassis'
  1805. def __str__(self):
  1806. return str(self.master) if hasattr(self, 'master') else 'New Virtual Chassis'
  1807. def get_absolute_url(self):
  1808. return self.master.get_absolute_url()
  1809. def clean(self):
  1810. # Verify that the selected master device has been assigned to this VirtualChassis. (Skip when creating a new
  1811. # VirtualChassis.)
  1812. if self.pk and self.master not in self.members.all():
  1813. raise ValidationError({
  1814. 'master': "The selected master is not assigned to this virtual chassis."
  1815. })