U
Ø–]æà ã @ sˆ d dl m Z d dlZddlmZ ddlmZ ddlmZ ddlmZ ddlm Z dd lm
Z
dd
lm Z dd lm Z G d d
„ d
e
ƒZdS )é )ÚdatetimeNé )Úerrors)Úutils)ÚDEFAULT_DATA_CHUNK_SIZE)ÚCancellableStream)ÚContainerConfig)ÚEndpointConfig)Ú
HostConfig©ÚNetworkingConfigc @ s& e Zd Ze d¡dHdd„ƒZe d¡dIdd„ƒZe d¡dJd d
„ƒZdKd d
„ZdLdd„Z dd„ Z
dMdd„Z dd„ Z dd„ Z
dd„ Ze d¡dd„ ƒZe d¡efd d „ƒZe d¡efd d „ƒZe d¡d d!„ ƒZe d¡dNd"d#„ƒZe d¡dOd%d&„ƒZe d¡d'd(„ ƒZe d¡d)d*„ ƒZe d¡d+d,„ ƒZe d-¡dPd.d/„ƒZe d¡dQd0d1„ƒZe d¡d2d3„ ƒZ e d¡d4d5„ ƒZ e d¡dRd7d8„ƒZ e d¡d9d:„ ƒZ e d¡dSd;d<„ƒZ e d¡dTd=d>„ƒZ!e d¡dUd?d@„ƒZ"e d¡dAdB„ ƒZ#e dC¡e d¡dVdDdE„ƒƒZ$e d¡dWdFdG„ƒZ%dS )XÚContainerApiMixinÚ containerTFc C s„ |rdp
d|rdpd|r dp d|r&dp(ddœ}dddœ}| d|¡} | j| ||dd }
| j|
|| |¡|d
} |r|t| |
ƒS | S d S ) aI
Attach to a container.
The ``.logs()`` function is a wrapper around this method, which you can
use instead if you want to fetch/stream container output without first
retrieving the entire backlog.
Args:
container (str): The container to attach to.
stdout (bool): Include stdout.
stderr (bool): Include stderr.
stream (bool): Return container output progressively as an iterator
of strings, rather than a single string.
logs (bool): Include the container's previous output.
demux (bool): Keep stdout and stderr separate.
Returns:
By default, the container's output as a single string (two if
``demux=True``: one for stdout and one for stderr).
If ``stream=True``, an iterator of output strings. If
``demux=True``, two iterators are returned: one for stdout and one
for stderr.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
é r )ÚlogsÚstdoutÚstderrÚstreamÚUpgradeÚtcp©Z
Connectionr ú/containers/{0}/attachT)ÚheadersÚparamsr )ÚdemuxN)Ú_urlÚ_postZ_read_from_socketZ
_check_is_ttyr ) Úselfr r r r r r r r ÚuZresponseÚoutput© r ú6/usr/lib/python3/dist-packages/docker/api/container.pyÚattach s&
üþ ÿ
zContainerApiMixin.attachNc C sz |dkrddddœ}d|kr4d| j kr4| j d |d< |rD| ||¡S dddœ}| d|¡}| | j|d| |¡d |d
¡S ) a&
Like ``attach``, but returns the underlying socket-like object for the
HTTP request.
Args:
container (str): The container to attach to.
params (dict): Dictionary of request parameters (e.g. ``stdout``,
``stderr``, ``stream``).
For ``detachKeys``, ~/.docker/config.json is used by default.
ws (bool): Use websockets instead of raw HTTP.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
Nr )r r r Z
detachKeysr r r r T)r r r )Z_general_configsZ_attach_websocketr Z_get_raw_response_socketZpostZ_attach_params)r r r Zwsr r r r r! Ú
attach_socketF s0 ýÿ þ þÿz ContainerApiMixin.attach_socketc
C s6 ||||||dœ}| d¡} | j| j| ||dddS )a
Commit a container to an image. Similar to the ``docker commit``
command.
Args:
container (str): The image hash of the container
repository (str): The repository to push the image to
tag (str): The tag to push
message (str): A commit message
author (str): The name of the author
changes (str): Dockerfile instructions to apply while committing
conf (dict): The configuration for the container. See the
`Engine API documentation
`_
for full details.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
)r ZrepoÚtagZcommentÚauthorÚchangesz/commit©Údatar T©Újson)r Ú_resultÚ
_post_json)
r r Z
repositoryr$ Úmessager% r& Úconfr r r r r! Úcommits s ú
ÿzContainerApiMixin.commitéÿÿÿÿc
C sœ |rdn||rdnd|r dnd|r&dnd||dœ}
| rDt | ¡|
d< | d¡} | | j| |
dd¡} |rvdd „ | D ƒS |r˜| D ]}
|
d
d d … |
d
< q~| S )
a6
List containers. Similar to the ``docker ps`` command.
Args:
quiet (bool): Only display numeric Ids
all (bool): Show all containers. Only running containers are shown
by default
trunc (bool): Truncate output
latest (bool): Show only the latest created container, include
non-running ones.
since (str): Show only containers created since Id or Name, include
non-running ones
before (str): Show only container created before Id or Name,
include non-running ones
limit (int): Show `limit` last created containers, include
non-running ones
size (bool): Display sizes
filters (dict): Filters to be processed on the image list.
Available filters:
- `exited` (int): Only containers with specified exit code
- `status` (str): One of ``restarting``, ``running``,
``paused``, ``exited``
- `label` (str|list): format either ``"key"``, ``"key=value"``
or a list of such.
- `id` (str): The id of the container.
- `name` (str): The name of the container.
- `ancestor` (str): Filter by container ancestor. Format of
``[:tag]``, ````, or
````.
- `before` (str): Only containers created before a particular
container. Give the container name or id.
- `since` (str): Only containers created after a particular
container. Give container name or id.
A comprehensive list can be found in the documentation for
`docker ps
`_.
Returns:
A list of dicts, one per container
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
r r )ÚlimitÚallÚsizeZ trunc_cmdÚsinceÚbeforeÚfiltersz/containers/json©r Tc S s g | ]}d |d i‘qS )ÚIdr )Ú.0Úxr r r! Ú
Ö s z0ContainerApiMixin.containers..r8 Né )r Úconvert_filtersr r+ Ú_get)r Úquietr2 ZtruncZlatestr4 r5 r1 r3 r6 r r Úresr: r r r! Ú
containers— s" 2
ú
z ContainerApiMixin.containersc C s| t |
tjƒr|
g}
t | tƒr(tj | ¡} |r<| j | ¡p:d} | ||||||||| |
| |
||||||||||¡}| || ¡S )a¶
Creates a container. Parameters are similar to those for the ``docker
run`` command except it doesn't support the attach options (``-a``).
The arguments that are passed directly to this function are
host-independent configuration options. Host-specific configuration
is passed with the `host_config` argument. You'll normally want to
use this method in combination with the :py:meth:`create_host_config`
method to generate ``host_config``.
**Port bindings**
Port binding is done in two parts: first, provide a list of ports to
open inside the container with the ``ports`` parameter, then declare
bindings with the ``host_config`` parameter. For example:
.. code-block:: python
container_id = cli.create_container(
'busybox', 'ls', ports=[1111, 2222],
host_config=cli.create_host_config(port_bindings={
1111: 4567,
2222: None
})
)
You can limit the host address on which the port will be exposed like
such:
.. code-block:: python
cli.create_host_config(port_bindings={1111: ('127.0.0.1', 4567)})
Or without host port assignment:
.. code-block:: python
cli.create_host_config(port_bindings={1111: ('127.0.0.1',)})
If you wish to use UDP instead of TCP (default), you need to declare
ports as such in both the config and host config:
.. code-block:: python
container_id = cli.create_container(
'busybox', 'ls', ports=[(1111, 'udp'), 2222],
host_config=cli.create_host_config(port_bindings={
'1111/udp': 4567, 2222: None
})
)
To bind multiple host ports to a single container port, use the
following syntax:
.. code-block:: python
cli.create_host_config(port_bindings={
1111: [1234, 4567]
})
You can also bind multiple IPs to a single container port:
.. code-block:: python
cli.create_host_config(port_bindings={
1111: [
('192.168.0.100', 1234),
('192.168.0.101', 1234)
]
})
**Using volumes**
Volume declaration is done in two parts. Provide a list of
paths to use as mountpoints inside the container with the
``volumes`` parameter, and declare mappings from paths on the host
in the ``host_config`` section.
.. code-block:: python
container_id = cli.create_container(
'busybox', 'ls', volumes=['/mnt/vol1', '/mnt/vol2'],
host_config=cli.create_host_config(binds={
'/home/user1/': {
'bind': '/mnt/vol2',
'mode': 'rw',
},
'/var/www': {
'bind': '/mnt/vol1',
'mode': 'ro',
}
})
)
You can alternatively specify binds as a list. This code is equivalent
to the example above:
.. code-block:: python
container_id = cli.create_container(
'busybox', 'ls', volumes=['/mnt/vol1', '/mnt/vol2'],
host_config=cli.create_host_config(binds=[
'/home/user1/:/mnt/vol2',
'/var/www:/mnt/vol1:ro',
])
)
**Networking**
You can specify networks to connect the container to by using the
``networking_config`` parameter. At the time of creation, you can
only connect a container to a single networking, but you
can create more connections by using
:py:meth:`~connect_container_to_network`.
For example:
.. code-block:: python
networking_config = docker_client.create_networking_config({
'network1': docker_client.create_endpoint_config(
ipv4_address='172.28.0.124',
aliases=['foo', 'bar'],
links=['container2']
)
})
ctnr = docker_client.create_container(
img, command, networking_config=networking_config
)
Args:
image (str): The image to run
command (str or list): The command to be run in the container
hostname (str): Optional hostname for the container
user (str or int): Username or UID
detach (bool): Detached mode: run container in the background and
return container ID
stdin_open (bool): Keep STDIN open even if not attached
tty (bool): Allocate a pseudo-TTY
ports (list of ints): A list of port numbers
environment (dict or list): A dictionary or a list of strings in
the following format ``["PASSWORD=xxx"]`` or
``{"PASSWORD": "xxx"}``.
volumes (str or list): List of paths inside the container to use
as volumes.
network_disabled (bool): Disable networking
name (str): A name for the container
entrypoint (str or list): An entrypoint
working_dir (str): Path to the working directory
domainname (str): The domain name to use for the container
host_config (dict): A dictionary created with
:py:meth:`create_host_config`.
mac_address (str): The Mac Address to assign the container
labels (dict or list): A dictionary of name-value labels (e.g.
``{"label1": "value1", "label2": "value2"}``) or a list of
names of labels to set with empty values (e.g.
``["label1", "label2"]``)
stop_signal (str): The stop signal to use to stop the container
(e.g. ``SIGINT``).
stop_timeout (int): Timeout to stop the container, in seconds.
Default: 10
networking_config (dict): A networking configuration generated
by :py:meth:`create_networking_config`.
runtime (str): Runtime to use with this container.
healthcheck (dict): Specify a test to perform to check that the
container is healthy.
use_config_proxy (bool): If ``True``, and if the docker client
configuration file (``~/.docker/config.json`` by default)
contains a proxy configuration, the corresponding environment
variables will be set in the container being created.
Returns:
A dictionary with an image 'Id' key and a 'Warnings' key.
Raises:
:py:class:`docker.errors.ImageNotFound`
If the specified image does not exist.
:py:class:`docker.errors.APIError`
If the server returns an error.
N)
Ú
isinstanceÚsixÚ string_typesÚdictr Zformat_environmentZ_proxy_configsZinject_proxy_environmentÚcreate_container_configÚ create_container_from_config)r ZimageZcommandZhostnameÚuserÚdetachZ
stdin_openZttyZportsZ environmentZvolumesZnetwork_disabledÚnameZ
entrypointZ working_dirZ
domainnameZ host_configZ mac_addressÚlabelsZ stop_signalZnetworking_configZ healthcheckZ stop_timeoutZruntimeZuse_config_proxyÚconfigr r r! Úcreate_containerÜ sH @
ÿþ úz"ContainerApiMixin.create_containerc O s t | jf|ž|ŽS )N)r Ú_version©r ÚargsÚkwargsr r r! rF ° s z)ContainerApiMixin.create_container_configc C s. | d¡}d|i}| j|||d}| |d¡S )Nz/containers/createrJ r' T)r r, r+ )r rL rJ r r r@ r r r! rG ³ s
ÿz.ContainerApiMixin.create_container_from_configc O s, |si }d|krt dƒ‚| j|d< t||ŽS )a
Create a dictionary for the ``host_config`` argument to
:py:meth:`create_container`.
Args:
auto_remove (bool): enable auto-removal of the container on daemon
side when the container's process exits.
binds (dict): Volumes to bind. See :py:meth:`create_container`
for more information.
blkio_weight_device: Block IO weight (relative device weight) in
the form of: ``[{"Path": "device_path", "Weight": weight}]``.
blkio_weight: Block IO weight (relative weight), accepts a weight
value between 10 and 1000.
cap_add (list of str): Add kernel capabilities. For example,
``["SYS_ADMIN", "MKNOD"]``.
cap_drop (list of str): Drop kernel capabilities.
cpu_period (int): The length of a CPU period in microseconds.
cpu_quota (int): Microseconds of CPU time that the container can
get in a CPU period.
cpu_shares (int): CPU shares (relative weight).
cpuset_cpus (str): CPUs in which to allow execution (``0-3``,
``0,1``).
cpuset_mems (str): Memory nodes (MEMs) in which to allow execution
(``0-3``, ``0,1``). Only effective on NUMA systems.
device_cgroup_rules (:py:class:`list`): A list of cgroup rules to
apply to the container.
device_read_bps: Limit read rate (bytes per second) from a device
in the form of: `[{"Path": "device_path", "Rate": rate}]`
device_read_iops: Limit read rate (IO per second) from a device.
device_write_bps: Limit write rate (bytes per second) from a
device.
device_write_iops: Limit write rate (IO per second) from a device.
devices (:py:class:`list`): Expose host devices to the container,
as a list of strings in the form
``::``.
For example, ``/dev/sda:/dev/xvda:rwm`` allows the container
to have read-write access to the host's ``/dev/sda`` via a
node named ``/dev/xvda`` inside the container.
dns (:py:class:`list`): Set custom DNS servers.
dns_opt (:py:class:`list`): Additional options to be added to the
container's ``resolv.conf`` file
dns_search (:py:class:`list`): DNS search domains.
extra_hosts (dict): Additional hostnames to resolve inside the
container, as a mapping of hostname to IP address.
group_add (:py:class:`list`): List of additional group names and/or
IDs that the container process will run as.
init (bool): Run an init inside the container that forwards
signals and reaps processes
ipc_mode (str): Set the IPC mode for the container.
isolation (str): Isolation technology to use. Default: ``None``.
links (dict): Mapping of links using the
``{'container': 'alias'}`` format. The alias is optional.
Containers declared in this dict will be linked to the new
container using the provided alias. Default: ``None``.
log_config (LogConfig): Logging configuration
lxc_conf (dict): LXC config.
mem_limit (float or str): Memory limit. Accepts float values
(which represent the memory limit of the created container in
bytes) or a string with a units identification char
(``100000b``, ``1000k``, ``128m``, ``1g``). If a string is
specified without a units character, bytes are assumed as an
mem_reservation (int or str): Memory soft limit.
mem_swappiness (int): Tune a container's memory swappiness
behavior. Accepts number between 0 and 100.
memswap_limit (str or int): Maximum amount of memory + swap a
container is allowed to consume.
mounts (:py:class:`list`): Specification for mounts to be added to
the container. More powerful alternative to ``binds``. Each
item in the list is expected to be a
:py:class:`docker.types.Mount` object.
network_mode (str): One of:
- ``bridge`` Create a new network stack for the container on
the bridge network.
- ``none`` No networking for this container.
- ``container:`` Reuse another container's network
stack.
- ``host`` Use the host network stack.
oom_kill_disable (bool): Whether to disable OOM killer.
oom_score_adj (int): An integer value containing the score given
to the container in order to tune OOM killer preferences.
pid_mode (str): If set to ``host``, use the host PID namespace
inside the container.
pids_limit (int): Tune a container's pids limit. Set ``-1`` for
unlimited.
port_bindings (dict): See :py:meth:`create_container`
for more information.
privileged (bool): Give extended privileges to this container.
publish_all_ports (bool): Publish all ports to the host.
read_only (bool): Mount the container's root filesystem as read
only.
restart_policy (dict): Restart the container when it exits.
Configured as a dictionary with keys:
- ``Name`` One of ``on-failure``, or ``always``.
- ``MaximumRetryCount`` Number of times to restart the
container on failure.
security_opt (:py:class:`list`): A list of string values to
customize labels for MLS systems, such as SELinux.
shm_size (str or int): Size of /dev/shm (e.g. ``1G``).
storage_opt (dict): Storage driver options per container as a
key-value mapping.
sysctls (dict): Kernel parameters to set in the container.
tmpfs (dict): Temporary filesystems to mount, as a dictionary
mapping a path inside the container to options for that path.
For example:
.. code-block:: python
{
'/mnt/vol2': '',
'/mnt/vol1': 'size=3G,uid=1000'
}
ulimits (:py:class:`list`): Ulimits to set inside the container,
as a list of :py:class:`docker.types.Ulimit` instances.
userns_mode (str): Sets the user namespace mode for the container
when user namespace remapping option is enabled. Supported
values are: ``host``
uts_mode (str): Sets the UTS namespace mode for the container.
Supported values are: ``host``
volumes_from (:py:class:`list`): List of container names or IDs to
get volumes from.
runtime (str): Runtime to use with this container.
Returns:
(dict) A dictionary which can be passed to the ``host_config``
argument to :py:meth:`create_container`.
Example:
>>> cli.create_host_config(privileged=True, cap_drop=['MKNOD'],
volumes_from=['nostalgic_newton'])
{'CapDrop': ['MKNOD'], 'LxcConf': None, 'Privileged': True,
'VolumesFrom': ['nostalgic_newton'], 'PublishAllPorts': False}
ÚversionzAcreate_host_config() got an unexpected keyword argument 'version')Ú TypeErrorrN r
rO r r r! Úcreate_host_config» s ÿ
z$ContainerApiMixin.create_host_configc O s
t ||ŽS )a
Create a networking config dictionary to be used as the
``networking_config`` parameter in :py:meth:`create_container`.
Args:
endpoints_config (dict): A dictionary mapping network names to
endpoint configurations generated by
:py:meth:`create_endpoint_config`.
Returns:
(dict) A networking config.
Example:
>>> docker_client.create_network('network1')
>>> networking_config = docker_client.create_networking_config({
'network1': docker_client.create_endpoint_config()
})
>>> container = docker_client.create_container(
img, command, networking_config=networking_config
)
r rO r r r! Úcreate_networking_configR s z*ContainerApiMixin.create_networking_configc O s t | jf|ž|ŽS )a&
Create an endpoint config dictionary to be used with
:py:meth:`create_networking_config`.
Args:
aliases (:py:class:`list`): A list of aliases for this endpoint.
Names in that list can be used within the network to reach the
container. Defaults to ``None``.
links (dict): Mapping of links for this endpoint using the
``{'container': 'alias'}`` format. The alias is optional.
Containers declared in this dict will be linked to this
container using the provided alias. Defaults to ``None``.
ipv4_address (str): The IP address of this container on the
network, using the IPv4 protocol. Defaults to ``None``.
ipv6_address (str): The IP address of this container on the
network, using the IPv6 protocol. Defaults to ``None``.
link_local_ips (:py:class:`list`): A list of link-local (IPv4/IPv6)
addresses.
Returns:
(dict) An endpoint config.
Example:
>>> endpoint_config = client.create_endpoint_config(
aliases=['web', 'app'],
links={'app_db': 'db', 'another': None},
ipv4_address='132.65.0.123'
)
)r rN rO r r r! Úcreate_endpoint_configl s z(ContainerApiMixin.create_endpoint_configc C s | | | d|¡¡d¡S )a
Inspect changes on a container's filesystem.
Args:
container (str): The container to diff
Returns:
(str)
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/changesT©r+ r> r ©r r r r r! ÚdiffŽ s ÿzContainerApiMixin.diffc C s$ | j | d|¡dd}| ||d¡S )a
Export the contents of a filesystem as a tar archive.
Args:
container (str): The container to export
chunk_size (int): The number of bytes returned by each iteration
of the generator. If ``None``, data will be streamed as it is
received. Default: 2 MB
Returns:
(generator): The archived filesystem data stream
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/exportT©r F)r> r Ú_stream_raw_result)r r Ú
chunk_sizer@ r r r! Úexport¡ s
ÿzContainerApiMixin.exportc C sZ d|i}| d|¡}| j||dd}| |¡ |j d¡}| ||d¡|rTt |¡ndfS )az
Retrieve a file or folder from a container in the form of a tar
archive.
Args:
container (str): The container where the file is located
path (str): Path to the file or folder to retrieve
chunk_size (int): The number of bytes returned by each iteration
of the generator. If ``None``, data will be streamed as it is
received. Default: 2 MB
Returns:
(tuple): First element is a raw tar data stream. Second element is
a dict containing ``stat`` information on the specified ``path``.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
Example:
>>> c = docker.APIClient()
>>> f = open('./sh_bin.tar', 'wb')
>>> bits, stat = c.get_archive(container, '/bin/sh')
>>> print(stat)
{'name': 'sh', 'size': 1075464, 'mode': 493,
'mtime': '2018-10-01T15:37:48-07:00', 'linkTarget': ''}
>>> for chunk in bits:
... f.write(chunk)
>>> f.close()
Úpathú/containers/{0}/archiveT©r r z x-docker-container-path-statFN)r r> Ú_raise_for_statusr Úgetr[ r Zdecode_json_header)r r r^ r\ r Úurlr@ Z encoded_statr r r! Ú get_archive¸ s " ÿ
þz ContainerApiMixin.get_archivec C s | | | d|¡¡d¡S )a|
Identical to the `docker inspect` command, but only for containers.
Args:
container (str): The container to inspect
Returns:
(dict): Similar to the output of `docker inspect`, but as a
single dict
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
ú/containers/{0}/jsonTrW rX r r r! Úinspect_containerå s ÿz#ContainerApiMixin.inspect_containerc C sP | d|¡}i }|dk r4t|tjƒs,t|ƒ}||d< | j||d}| |¡ dS )aB
Kill a container or send a signal to a container.
Args:
container (str): The container to kill
signal (str or int): The signal to send. Defaults to ``SIGKILL``
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/killNÚsignalr7 )r rB rC rD Úintr ra )r r rg rc r r@ r r r! Úkillù s
zContainerApiMixin.killr2 c
C sd |dkr |}|rdpd|r dp d|r(dp*d|r2dp4ddœ}
|dkrXt |tƒrT|dk rXd}||
d< |dk r²t |tƒr‚t |¡|
d< n0t |tƒrž|dkrž||
d< nt d t|ƒ¡¡‚| dk r"t | j
d ¡rÔt d
¡‚t | tƒrît | ¡|
d < n4t | tƒr| dkr| |
d < nt d t| ƒ¡¡‚| d
|¡} | j
| |
|d} | ||| ¡}
|r\t|
| ƒS |
S dS )aÒ
Get logs from a container. Similar to the ``docker logs`` command.
The ``stream`` parameter makes the ``logs`` function return a blocking
generator you can iterate over to retrieve log output as it happens.
Args:
container (str): The container to get logs from
stdout (bool): Get ``STDOUT``. Default ``True``
stderr (bool): Get ``STDERR``. Default ``True``
stream (bool): Stream the response. Default ``False``
timestamps (bool): Show timestamps. Default ``False``
tail (str or int): Output specified number of lines at the end of
logs. Either an integer of number of lines or the string
``all``. Default ``all``
since (datetime or int): Show logs since a given datetime or
integer epoch (in seconds)
follow (bool): Follow log output. Default ``False``
until (datetime or int): Show logs that occurred before the given
datetime or integer epoch (in seconds)
Returns:
(generator or str)
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
Nr r )r r Ú
timestampsÚfollowr2 Útailr4 z6since value should be datetime or positive int, not {}z1.35z-until is not supported for API version < 1.35Úuntilz6until value should be datetime or positive int, not {}z/containers/{0}/logsr` )rB rh r r Zdatetime_to_timestampr ÚInvalidArgumentÚformatÚtypeÚ
version_ltrN ÚInvalidVersionr r> Z _get_resultr )r r r r r rj rl r4 rk rm r rc r@ r r r r! r sP
ý
ÿÿ
ÿ
ÿÿ
zContainerApiMixin.logsc C s$ | d|¡}| |¡}| |¡ dS )zí
Pauses all processes within a container.
Args:
container (str): The container to pause
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/pauseN©r r ra ©r r rc r@ r r r! Úpause^ s
zContainerApiMixin.pausec C sˆ | | d|¡¡}| |¡ | ¡ }t|ƒ}d}| di ¡ d¡}|dkrNdS d|kr`| |¡S dD ] }| |d | ¡}|rd q„qd|S )a
Lookup the public-facing port that is NAT-ed to ``private_port``.
Identical to the ``docker port`` command.
Args:
container (str): The container to look up
private_port (int): The private port to inspect
Returns:
(list of dict): The mapping for the host ports
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
Example:
.. code-block:: bash
$ docker run -d -p 80:80 ubuntu:14.04 /bin/sleep 30
7174d6347063a83f412fad6124c99cffd25ffe1a0807eb4b7f9cec76ac8cb43b
.. code-block:: python
>>> cli.port('7174d6347063', 80)
[{'HostIp': '0.0.0.0', 'HostPort': '80'}]
re NZNetworkSettingsZPortsú/)r ZudpZsctp)r> r ra r* Ústrrb )r r Z private_portr@ Zjson_Zh_portsZ
port_settingsZprotocolr r r! Úportn s
zContainerApiMixin.portc C s8 d|i}| d|¡}| j|||d}| |¡ |jdkS )a
Insert a file or folder in an existing container using a tar archive as
source.
Args:
container (str): The container where the file(s) will be extracted
path (str): Path inside the container where the file(s) will be
extracted. Must exist.
data (bytes): tar data to be extracted
Returns:
(bool): True if the call succeeds.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
r^ r_ )r r( éÈ )r Z_putra Z status_code)r r r^ r( r rc r@ r r r! Ú put_archive s
z ContainerApiMixin.put_archivez1.25c C s6 i }|rt |¡|d< | d¡}| | j||dd¡S )a…
Delete stopped containers
Args:
filters (dict): Filters to process on the prune list.
Returns:
(dict): A dict containing a list of deleted container IDs and
the amount of disk space reclaimed in bytes.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
r6 z/containers/pruner7 T)r r= r r+ r )r r6 r rc r r r! Úprune_containers¹ s
z"ContainerApiMixin.prune_containersc C s0 |||dœ}| j | d|¡|d}| |¡ dS )a
Remove a container. Similar to the ``docker rm`` command.
Args:
container (str): The container to remove
v (bool): Remove the volumes associated with the container
link (bool): Remove the specified link and not the underlying
container
force (bool): Force the removal of a running container (uses
``SIGKILL``)
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
)ÚvÚlinkÚforcez/containers/{0}r7 N)Z_deleter ra )r r r| r} r~ r r@ r r r! Úremove_containerÏ s
ÿz"ContainerApiMixin.remove_containerc C s0 | d|¡}d|i}| j||d}| |¡ dS )a<
Rename a container. Similar to the ``docker rename`` command.
Args:
container (str): ID of the container to rename
name (str): New name for the container
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/renamerJ r7 Nrs )r r rJ rc r r@ r r r! Úrenameæ s
zContainerApiMixin.renamec C s2 ||dœ}| d|¡}| j||d}| |¡ dS )aC
Resize the tty session.
Args:
container (str or dict): The container to resize
height (int): Height of tty session
width (int): Width of tty session
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
)ÚhÚwz/containers/{0}/resizer7 Nrs )r r ZheightÚwidthr rc r@ r r r! Úresizeø s
zContainerApiMixin.resizeé
c C sH d|i}| d|¡}| j}|dk r*||7 }| j|||d}| |¡ dS )aþ
Restart a container. Similar to the ``docker restart`` command.
Args:
container (str or dict): The container to restart. If a dict, the
``Id`` key is used.
timeout (int): Number of seconds to try to stop for before killing
the container. Once killed it will then be restarted. Default
is 10 seconds.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
Útz/containers/{0}/restartN©r Útimeout©r rˆ r ra ©r r rˆ r rc Z conn_timeoutr@ r r r! Úrestart s zContainerApiMixin.restartc O s6 |s|rt d¡‚| d|¡}| |¡}| |¡ dS )a‚
Start a container. Similar to the ``docker start`` command, but
doesn't support attach options.
**Deprecation warning:** Passing configuration options in ``start`` is
no longer supported. Users are expected to provide host config options
in the ``host_config`` parameter of
:py:meth:`~ContainerApiMixin.create_container`.
Args:
container (str): The container to start
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
:py:class:`docker.errors.DeprecatedMethod`
If any argument besides ``container`` are provided.
Example:
>>> container = cli.create_container(
... image='busybox:latest',
... command='/bin/sleep 30')
>>> cli.start(container=container.get('Id'))
z|Providing configuration in the start() method is no longer supported. Use the host_config param in create_container instead.z/containers/{0}/startN)r ZDeprecatedMethodr r ra )r r rP rQ rc r@ r r r! Ústart# s ÿ
zContainerApiMixin.startc C sV | d|¡}|r(| j| j|dd|dS |r6t d¡‚| j| j|ddiddd S d
S ) ao
Stream statistics for a specific container. Similar to the
``docker stats`` command.
Args:
container (str): The container to stream statistics from
decode (bool): If set to true, stream will be decoded into dicts
on the fly. Only applicable if ``stream`` is True.
False by default.
stream (bool): If set to false, only the current stats will be
returned instead of a stream. True by default.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/statsTrZ )Údecodez7decode is only available in conjuction with stream=Truer Fr7 r) N)r Z_stream_helperr> r rn r+ )r r r r rc r r r! ÚstatsI s ÿÿÿzContainerApiMixin.statsc C sZ |dkri }d}nd|i}| d|¡}| j}|dk r<||7 }| j|||d}| |¡ dS )aí
Stops a container. Similar to the ``docker stop`` command.
Args:
container (str): The container to stop
timeout (int): Timeout in seconds to wait for the container to
stop before sending a ``SIGKILL``. If None, then the
StopTimeout value of the container will be used.
Default: None
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
Nr… r† z/containers/{0}/stopr‡ r‰ rŠ r r r! Ústoph s zContainerApiMixin.stopc C s6 | d|¡}i }|dk r ||d< | | j||dd¡S )a|
Display the running processes of a container.
Args:
container (str): The container to inspect
ps_args (str): An optional arguments passed to ps (e.g. ``aux``)
Returns:
(str): The output of the top
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/topNÚps_argsr7 T)r r+ r> )r r r r r r r r! Útop„ s
zContainerApiMixin.topc C s$ | d|¡}| |¡}| |¡ dS )z€
Unpause all processes within a container.
Args:
container (str): The container to unpause
z/containers/{0}/unpauseNrs rt r r r! Úunpauseš s
zContainerApiMixin.unpausez1.22c
C sÞ | d|¡}
i }|r ||d< |r(||d< |r4||d< |r@||d< |rL||d< |rX||d< |rjt |¡|d< | r|t | ¡|d < |
rŽt |
¡|d
< | r t | ¡|d < | rÄt | jd ¡r¼t d
¡‚| |d< | j|
|d}| |d¡S )a?
Update resource configs of one or more containers.
Args:
container (str): The container to inspect
blkio_weight (int): Block IO (relative weight), between 10 and 1000
cpu_period (int): Limit CPU CFS (Completely Fair Scheduler) period
cpu_quota (int): Limit CPU CFS (Completely Fair Scheduler) quota
cpu_shares (int): CPU shares (relative weight)
cpuset_cpus (str): CPUs in which to allow execution
cpuset_mems (str): MEMs in which to allow execution
mem_limit (int or str): Memory limit
mem_reservation (int or str): Memory soft limit
memswap_limit (int or str): Total memory (memory + swap), -1 to
disable swap
kernel_memory (int or str): Kernel memory limit
restart_policy (dict): Restart policy dictionary
Returns:
(dict): Dictionary containing a ``Warnings`` key.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/updateZ BlkioWeightZ CpuPeriodZ CpuSharesZCpuQuotaZ
CpusetCpusZ
CpusetMemsZMemoryZMemoryReservationZ
MemorySwapZ KernelMemoryz1.23z=restart policy update is not supported for API version < 1.23Z
RestartPolicy)r( T) r r Z parse_bytesrq rN r rr r, r+ )r r Z blkio_weightZ
cpu_periodZ cpu_quotaZ
cpu_sharesZ cpuset_cpusZ cpuset_memsZ mem_limitZmem_reservationZ
memswap_limitZ
kernel_memoryZrestart_policyrc r( r@ r r r! Úupdate_container¦ s< ! ÿz"ContainerApiMixin.update_containerc C sT | d|¡}i }|dk r8t | jd¡r0t d¡‚||d< | j|||d}| |d¡S )a[
Block until a container stops, then return its exit code. Similar to
the ``docker wait`` command.
Args:
container (str or dict): The container to wait on. If a dict, the
``Id`` key is used.
timeout (int): Request timeout
condition (str): Wait until a container state reaches the given
condition, either ``not-running`` (default), ``next-exit``,
or ``removed``
Returns:
(dict): The API's response as a Python dictionary, including
the container's exit code under the ``StatusCode`` attribute.
Raises:
:py:class:`requests.exceptions.ReadTimeout`
If the timeout is exceeded.
:py:class:`docker.errors.APIError`
If the server returns an error.
z/containers/{0}/waitNz1.30z6wait condition is not supported for API version < 1.30Ú condition)rˆ r T)r r rq rN r rr r r+ )r r rˆ r” rc r r@ r r r! Úwaitè s ÿzContainerApiMixin.wait)TTFFF)NF)NNNNNN) FFFFNNr0 FN)NNNFFFNNNFNNNNNNNNNNNNT)N)N)TTFFr2 NNN)N)FFF)r… )NT)N)N) NNNNNNNNNNN)NN)&Ú__name__Ú
__module__Ú __qualname__r Zcheck_resourcer" r# r/ rA rM rF rG rT rU rV rY r r] rd rf ri r ru rx rz Zminimum_versionr{ r r€ r„ r‹ rŒ rŽ r r‘ r’ r“ r• r r r r! r
sÜ ÿ 5 , ÿ # þ
E ø
U
"
,
þ M
1
%
ü@r
)r rC Ú r r Z constantsr Útypesr r r r
r Úobjectr
r r r r! Ú s