我有一个名为“node”的docker容器,我想扩展.
该节点需要知道它实际上有多少节点的节点.
总数可能是一个环境变量,但目前更令人不安.
$docker-compose scale node=100
Starting projectdir_node_1 ... done
Creating and starting projectdir_node_2 ... done
Creating and starting projectdir_node_3 ... done
Creating and starting projectdir_node_4 ... done
Creating and starting projectdir_node_5 ... done
Creating and starting projectdir_node_6 ... done
Creating and starting projectdir_node_7 ... done
Creating and starting projectdir_node_8 ... done
Creating and starting projectdir_node_9 ... done
...
Creating and starting projectdir_node_99 ... done
Creating and starting projectdir_node_100 ... done
如果projectdir_node_100现在是节点100怎么办?
我看到$HOSTNAME是容器ID(例如2c73136347cd),但是找不到我需要的主机名的ENV变量.
作为参考,我的docker-compose.yml:
version: '2'
services:
node:
build: ./node/
volumes:
- ./node/code/:/code:ro
entrypoint: ["/bin/bash"]
我找到了未解决的How to reach additional containers by the hostname after docker-compose scale?,但我仍然不知道我是哪个容器.
我用docker-py包来访问它.
api为每个容器公开一个标签字典,com.docker.compose.container-number,com.docker.compose.project和com.docker.compose.service这两个键完成了构建主机名所需的操作.
下面的代码是我现在使用的代码的简化.
您可以在Github的luckydonald/pbft/dockerus.ServiceInfos(备份时间为gist.github.com)找到我的高级代码,其中包含缓存和花哨的东西.
让我们分步解决这个问题:
0.使API可用于容器.
我们需要使套接字文件可用于卷,因此在docker-compose.yml文件的volume部分中添加/var/run/docker.sock:/var/run/docker.sock:
version: '2'
services:
node:
build: .
volumes:
- /var/run/docker.sock:/var/run/docker.sock
这会将套接字文件映射到docker容器中.
因为我们不公开任何套接字端口,所以我们不必担心外部世界的防火墙.
1.连接到API
现在我们可以连接到它.当我使用python时,我使用docker-py.
from docker import Client # pip install docker-py
cli = Client(base_url='unix://var/run/docker.sock')
2.通过我们自己的项目名称和服务名称过滤容器,使所有容器处于相同的比例组中.
找到自己
要知道我们是哪个容器,我们将$HOSTNAME环境变量与容器ID进行比较.
import os
HOSTNAME = os.environ.get("HOSTNAME")
all_containers = cli.containers()
# filter out ourself by HOSTNAME
our_container = [c for c in all_containers if c['Id'][:12] == HOSTNAME[:12]][0]
主机名应该是Id的12个字符,因此我们在比较时剪切id以确保它是相等的.
our_container现在是我们自己的api代表.好极了.
接下来是获取其他容器.
我们将搜索具有相同项目和服务名称的容器.
这样我们就知道它们是我们自己的实例.
service_name = our_container.Labels['com.docker.compose.service']
project_name = our_container.Labels['com.docker.compose.project']
filters = [
'com.docker.compose.project={}'.format(project_name),'com.docker.compose.service={}'.format(service_name)
]
# The python wrapper has a filter function to do that work for us.
containers = cli.containers(filters={'label': filters})
我们只希望com.docker.compose.project和com.docker.compose.service标签的每个容器与我们自己的容器相同.
最后建立一个主机名列表
hostname_list = list()
for container in containers:
project = container.Labels["com.docker.compose.project"]
service = container.Labels["com.docker.compose.service"]
number = container.Labels["com.docker.compose.container-number"]
hostname = "{project}_{service}_{i}".format(project=project,service=service,i=number)
hostname_list.append(hostname)
# end for
所以,我们得到了hostname_list.
我使用它作为一个类,缓存值一分钟:
dockerus.ServiceInfos(备份于gist.github.com)