docker_client.py 1.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. from __future__ import absolute_import
  2. from __future__ import unicode_literals
  3. import logging
  4. import os
  5. from docker import Client
  6. from docker.errors import TLSParameterError
  7. from docker.tls import TLSConfig
  8. from docker.utils import kwargs_from_env
  9. from ..const import HTTP_TIMEOUT
  10. from .errors import UserError
  11. log = logging.getLogger(__name__)
  12. def tls_config_from_options(options):
  13. tls = options.get('--tls', False)
  14. ca_cert = options.get('--tlscacert')
  15. cert = options.get('--tlscert')
  16. key = options.get('--tlskey')
  17. verify = options.get('--tlsverify')
  18. advanced_opts = any([ca_cert, cert, key, verify])
  19. if tls is True and not advanced_opts:
  20. return True
  21. elif advanced_opts:
  22. client_cert = None
  23. if cert or key:
  24. client_cert = (cert, key)
  25. return TLSConfig(
  26. client_cert=client_cert, verify=verify, ca_cert=ca_cert,
  27. assert_hostname=options.get('--skip-hostname-check')
  28. )
  29. else:
  30. return None
  31. def docker_client(version=None, tls_config=None, host=None):
  32. """
  33. Returns a docker-py client configured using environment variables
  34. according to the same logic as the official Docker client.
  35. """
  36. if 'DOCKER_CLIENT_TIMEOUT' in os.environ:
  37. log.warn("The DOCKER_CLIENT_TIMEOUT environment variable is deprecated. "
  38. "Please use COMPOSE_HTTP_TIMEOUT instead.")
  39. try:
  40. kwargs = kwargs_from_env(assert_hostname=False)
  41. except TLSParameterError:
  42. raise UserError(
  43. "TLS configuration is invalid - make sure your DOCKER_TLS_VERIFY "
  44. "and DOCKER_CERT_PATH are set correctly.\n"
  45. "You might need to run `eval \"$(docker-machine env default)\"`")
  46. if host:
  47. kwargs['base_url'] = host
  48. if tls_config:
  49. kwargs['tls'] = tls_config
  50. if version:
  51. kwargs['version'] = version
  52. kwargs['timeout'] = HTTP_TIMEOUT
  53. return Client(**kwargs)