X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=csit%2Flibraries%2FDocker.py;h=5d568881841606391ec9d21df226b18aa614b4d3;hb=fa78d655ff6121f2b34e36ccec67a6c70dec7b76;hp=bc3d1e3e22baacebe3635222084d0603df32b60c;hpb=59e81c38620fa1b61e15771191e35771450b9499;p=integration%2Ftest.git diff --git a/csit/libraries/Docker.py b/csit/libraries/Docker.py index bc3d1e3e22..5d56888184 100755 --- a/csit/libraries/Docker.py +++ b/csit/libraries/Docker.py @@ -34,33 +34,35 @@ def docker_create(docker_image_name, passed_args_dict=None): logger.info(passed_args_dict) docker_client = docker_get_client() - default_args_dict = dict(command=None, - hostname=None, - user=None, - detach=False, - stdin_open=False, - tty=False, - mem_limit=0, - ports=None, - environment=None, - dns=None, - volumes=None, - volumes_from=None, - network_disabled=False, - name=None, - entrypoint=None, - cpu_shares=None, - working_dir=None, - domainname=None, - memswap_limit=0, - cpuset=None, - host_config=None - ) - args_dict = docker_process_args(passed_args_dict, default_args_dict, "docker_create") + default_args_dict = dict( + command=None, + hostname=None, + user=None, + detach=False, + stdin_open=False, + tty=False, + mem_limit=0, + ports=None, + environment=None, + dns=None, + volumes=None, + volumes_from=None, + network_disabled=False, + name=None, + entrypoint=None, + cpu_shares=None, + working_dir=None, + domainname=None, + memswap_limit=0, + cpuset=None, + host_config=None, + ) + args_dict = docker_process_args( + passed_args_dict, default_args_dict, "docker_create" + ) docker_client.images(name=docker_image_name) - docker_uid_dict = docker_client\ - .create_container(docker_image_name, **args_dict) + docker_uid_dict = docker_client.create_container(docker_image_name, **args_dict) docker_info = docker_client.inspect_container(docker_uid_dict.get("Id")) return docker_info @@ -85,28 +87,30 @@ def docker_start(docker_name, passed_args_dict=None): logger.info(passed_args_dict) docker_client = docker_get_client() - default_args_dict = dict(binds=None, - port_bindings=None, - lxc_conf=None, - publish_all_ports=False, - links=None, - privileged=False, - dns=None, - dns_search=None, - volumes_from=None, - network_mode=None, - restart_policy=None, - cap_add=None, - cap_drop=None, - devices=None, - extra_hosts=None - ) + default_args_dict = dict( + binds=None, + port_bindings=None, + lxc_conf=None, + publish_all_ports=False, + links=None, + privileged=False, + dns=None, + dns_search=None, + volumes_from=None, + network_mode=None, + restart_policy=None, + cap_add=None, + cap_drop=None, + devices=None, + extra_hosts=None, + ) args_dict = docker_process_args(passed_args_dict, default_args_dict, "docker_start") docker_client.start(docker_name, **args_dict) - if "True" in str(docker_client.inspect_container(docker_name) - .get("State").get("Running")): + if "True" in str( + docker_client.inspect_container(docker_name).get("State").get("Running") + ): logger.info("Started docker %s successfully" % docker_name) return True else: @@ -131,11 +135,10 @@ def docker_remove(docker_name, passed_args_dict=None): logger.info(passed_args_dict) docker_client = docker_get_client() - default_args_dict = dict(v=False, - link=False, - force=False - ) - args_dict = docker_process_args(passed_args_dict, default_args_dict, "docker_remove") + default_args_dict = dict(v=False, link=False, force=False) + args_dict = docker_process_args( + passed_args_dict, default_args_dict, "docker_remove" + ) docker_client.remove_container(docker_name, **args_dict) docker_containers = docker_client.containers(all=True) @@ -164,8 +167,9 @@ def docker_stop(docker_name, timeout=10): docker_client.stop(docker_name, timeout) - if "False" in str(docker_client.inspect_container(docker_name) - .get("State").get("Running")): + if "False" in str( + docker_client.inspect_container(docker_name).get("State").get("Running") + ): logger.info("Stopped docker %s successfully" % docker_name) return True else: @@ -189,13 +193,12 @@ def docker_return_logs(docker_name, passed_args_dict=None): logger.info(passed_args_dict) docker_client = docker_get_client() - default_args_dict = dict(stdout=True, - stderr=True, - stream=False, - timestamps=False, - tail='all' - ) - args_dict = docker_process_args(passed_args_dict, default_args_dict, "docker_return_logs") + default_args_dict = dict( + stdout=True, stderr=True, stream=False, timestamps=False, tail="all" + ) + args_dict = docker_process_args( + passed_args_dict, default_args_dict, "docker_return_logs" + ) return docker_client.logs(docker_name, **args_dict) @@ -223,13 +226,12 @@ def docker_execute(docker_name, cmd, passed_args_dict=None): logger.info(passed_args_dict) docker_client = docker_get_client() - default_args_dict = dict(detach=False, - stdout=True, - stderr=True, - stream=False, - tty=False - ) - args_dict = docker_process_args(passed_args_dict, default_args_dict, "docker_execute") + default_args_dict = dict( + detach=False, stdout=True, stderr=True, stream=False, tty=False + ) + args_dict = docker_process_args( + passed_args_dict, default_args_dict, "docker_execute" + ) return docker_client.execute(docker_name, cmd, **args_dict) @@ -246,9 +248,11 @@ def docker_get_ip4(docker_name): """ logger.info("Getting IP of docker %s" % docker_name) docker_client = docker_get_client() - return str(docker_client.inspect_container(docker_name) - .get("NetworkSettings") - .get("IPAddress")) + return str( + docker_client.inspect_container(docker_name) + .get("NetworkSettings") + .get("IPAddress") + ) def docker_ping(docker_name, ip, count=3): @@ -273,67 +277,70 @@ def docker_ping(docker_name, ip, count=3): def docker_list_containers(passed_args_dict=None): """Return a list of docker containers. - Returns: - :returns list: returns list of docker - containers in following format: - [{'Id': u'069a56ec06f965f98efa752467737faa58431ebb471bc51e9b2bd485fcc4916c'}, - {'Id': u'769aff6170eec78e7c502fea4770cfbb7b7e53a2dc44070566d01e18b6d57c14'}] + Returns: + :returns list: returns list of docker + containers in following format: + [{'Id': u'069a56ec06f965f98efa752467737faa58431ebb471bc51e9b2bd485fcc4916c'}, + {'Id': u'769aff6170eec78e7c502fea4770cfbb7b7e53a2dc44070566d01e18b6d57c14'}] """ logger.info("Listing docker containers") logger.info(passed_args_dict) - default_args_dict = dict(quiet=True, - all=True, - trunc=True, - latest=False, - since=None, - before=None, - limit=-1, - size=False, - filters=None - ) - args_dict = docker_process_args(passed_args_dict, default_args_dict, - "docker_list_containers") - - return docker.Client( - base_url='unix://var/run/docker.sock', - timeout=10)\ - .containers(**args_dict) + default_args_dict = dict( + quiet=True, + all=True, + trunc=True, + latest=False, + since=None, + before=None, + limit=-1, + size=False, + filters=None, + ) + args_dict = docker_process_args( + passed_args_dict, default_args_dict, "docker_list_containers" + ) + + return docker.Client(base_url="unix://var/run/docker.sock", timeout=10).containers( + **args_dict + ) def docker_create_host_config(passed_args_dict): """Return a list of docker create host config for port bindings. - Parameters: - :param passed_args_dict: dictionary of the keyword values to use. + Parameters: + :param passed_args_dict: dictionary of the keyword values to use. - Returns: - :returns list: returns host config for a container - create command in following format: - {'PortBindings': {'6640/tcp': [{'HostIp': '', 'HostPort': '6640'}], - '6653/tcp': [{'HostIp': '', 'HostPort': '6653'}], - '9001/tcp': [{'HostIp': '', 'HostPort': '9001'}]}} + Returns: + :returns list: returns host config for a container + create command in following format: + {'PortBindings': {'6640/tcp': [{'HostIp': '', 'HostPort': '6640'}], + '6653/tcp': [{'HostIp': '', 'HostPort': '6653'}], + '9001/tcp': [{'HostIp': '', 'HostPort': '9001'}]}} """ logger.info("Creating host config.") - default_args_dict = dict(binds=None, - port_bindings=None, - lxc_conf=None, - publish_all_ports=False, - links=None, - privileged=False, - dns=None, - dns_search=None, - volumes_from=None, - network_mode=None, - restart_policy=None, - cap_add=None, - cap_drop=None, - devices=None, - extra_hosts=None - ) - args_dict = docker_process_args(passed_args_dict, default_args_dict, - "docker_create_host_config") + default_args_dict = dict( + binds=None, + port_bindings=None, + lxc_conf=None, + publish_all_ports=False, + links=None, + privileged=False, + dns=None, + dns_search=None, + volumes_from=None, + network_mode=None, + restart_policy=None, + cap_add=None, + cap_drop=None, + devices=None, + extra_hosts=None, + ) + args_dict = docker_process_args( + passed_args_dict, default_args_dict, "docker_create_host_config" + ) return docker.utils.create_host_config(**args_dict) @@ -380,9 +387,10 @@ def docker_get_client(*passed_args_dict): Returns: :returns obj: returns docker-py client object. """ - default_args_dict = dict(base_url="unix://var/run/docker.sock", - version=None, - timeout=10, - tls=False) - args_dict = docker_process_args(passed_args_dict, default_args_dict, "docker_get_client") + default_args_dict = dict( + base_url="unix://var/run/docker.sock", version=None, timeout=10, tls=False + ) + args_dict = docker_process_args( + passed_args_dict, default_args_dict, "docker_get_client" + ) return docker.Client(**args_dict)