container.py 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144
  1. from __future__ import unicode_literals
  2. from __future__ import absolute_import
  3. class Container(object):
  4. """
  5. Represents a Docker container, constructed from the output of
  6. GET /containers/:id:/json.
  7. """
  8. def __init__(self, client, dictionary, has_been_inspected=False):
  9. self.client = client
  10. self.dictionary = dictionary
  11. self.has_been_inspected = has_been_inspected
  12. @classmethod
  13. def from_ps(cls, client, dictionary, **kwargs):
  14. """
  15. Construct a container object from the output of GET /containers/json.
  16. """
  17. new_dictionary = {
  18. 'ID': dictionary['Id'],
  19. 'Image': dictionary['Image'],
  20. }
  21. for name in dictionary.get('Names', []):
  22. if len(name.split('/')) == 2:
  23. new_dictionary['Name'] = name
  24. return cls(client, new_dictionary, **kwargs)
  25. @classmethod
  26. def from_id(cls, client, id):
  27. return cls(client, client.inspect_container(id))
  28. @classmethod
  29. def create(cls, client, **options):
  30. response = client.create_container(**options)
  31. return cls.from_id(client, response['Id'])
  32. @property
  33. def id(self):
  34. return self.dictionary['ID']
  35. @property
  36. def short_id(self):
  37. return self.id[:10]
  38. @property
  39. def name(self):
  40. return self.dictionary['Name'][1:]
  41. @property
  42. def number(self):
  43. try:
  44. return int(self.name.split('_')[-1])
  45. except ValueError:
  46. return None
  47. @property
  48. def human_readable_ports(self):
  49. self.inspect_if_not_inspected()
  50. if not self.dictionary['NetworkSettings']['Ports']:
  51. return ''
  52. ports = []
  53. for private, public in list(self.dictionary['NetworkSettings']['Ports'].items()):
  54. if public:
  55. ports.append('%s->%s' % (public[0]['HostPort'], private))
  56. return ', '.join(ports)
  57. @property
  58. def human_readable_state(self):
  59. self.inspect_if_not_inspected()
  60. if self.dictionary['State']['Running']:
  61. if self.dictionary['State']['Ghost']:
  62. return 'Ghost'
  63. else:
  64. return 'Up'
  65. else:
  66. return 'Exit %s' % self.dictionary['State']['ExitCode']
  67. @property
  68. def human_readable_command(self):
  69. self.inspect_if_not_inspected()
  70. return ' '.join(self.dictionary['Config']['Cmd'])
  71. @property
  72. def environment(self):
  73. self.inspect_if_not_inspected()
  74. out = {}
  75. for var in self.dictionary.get('Config', {}).get('Env', []):
  76. k, v = var.split('=', 1)
  77. out[k] = v
  78. return out
  79. @property
  80. def is_running(self):
  81. self.inspect_if_not_inspected()
  82. return self.dictionary['State']['Running']
  83. def start(self, **options):
  84. return self.client.start(self.id, **options)
  85. def stop(self, **options):
  86. return self.client.stop(self.id, **options)
  87. def kill(self):
  88. return self.client.kill(self.id)
  89. def remove(self):
  90. return self.client.remove_container(self.id)
  91. def inspect_if_not_inspected(self):
  92. if not self.has_been_inspected:
  93. self.inspect()
  94. def wait(self):
  95. return self.client.wait(self.id)
  96. def logs(self, *args, **kwargs):
  97. return self.client.logs(self.id, *args, **kwargs)
  98. def inspect(self):
  99. self.dictionary = self.client.inspect_container(self.id)
  100. return self.dictionary
  101. def links(self):
  102. links = []
  103. for container in self.client.containers():
  104. for name in container['Names']:
  105. bits = name.split('/')
  106. if len(bits) > 2 and bits[1] == self.name:
  107. links.append(bits[2])
  108. return links
  109. def attach(self, *args, **kwargs):
  110. return self.client.attach(self.id, *args, **kwargs)
  111. def attach_socket(self, **kwargs):
  112. return self.client.attach_socket(self.id, **kwargs)
  113. def __repr__(self):
  114. return '<Container: %s>' % self.name
  115. def __eq__(self, other):
  116. if type(self) != type(other):
  117. return False
  118. return self.id == other.id