共计 7136 个字符，预计需要花费 18 分钟才能阅读完成。
这篇文章主要为大家展示了“ceph-deploy 中 new 模块有什么用”，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让丸趣 TV 小编带领大家一起研究并学习一下“ceph-deploy 中 new 模块有什么用”这篇文章吧。
ceph-deploy 源码分析——new 模块
ceph-deploy 的 new.py 模块是用来开始部署新集群，创建 ceph.conf、ceph.mon.keyring 文件。
new 子命令格式如下
ceph-deploy new [-h] [--no-ssh-copykey] [--fsid FSID]
[--cluster-network CLUSTER_NETWORK]
[--public-network PUBLIC_NETWORK]
MON [MON ...]部署集群
make 函数 priority 为 10，子命令设置的默认函数为 new 函数。
@priority(10)
def make(parser):
Start deploying a new cluster, and write a CLUSTER.conf and keyring for it.
parser.add_argument(
mon ,
metavar= MON ,
nargs= + ,
help= initial monitor hostname, fqdn, or hostname:fqdn pair ,
type=arg_validators.Hostname(),
)
parser.add_argument(
--no-ssh-copykey ,
dest= ssh_copykey ,
action= store_false ,
default=True,
help= do not attempt to copy SSH keys ,
)
parser.add_argument(
--fsid ,
dest= fsid ,
help= provide an alternate FSID for ceph.conf generation ,
)
parser.add_argument(
--cluster-network ,
help= specify the (internal) cluster network ,
type=arg_validators.Subnet(),
)
parser.add_argument(
--public-network ,
help= specify the public network for a cluster ,
type=arg_validators.Subnet(),
)
parser.set_defaults(
func=new,
)部署新集群
new 函数开始部署新集群
创建 ceph.conf 文件, 写入 [global]fsid、mon_initial_members、mon_host、auth_cluster_required、auth_service_required、auth_client_required，如果参数中有 public_network、cluster_network 写入配置文件
调用 new_mon_keyring 函数创建 ceph.mon.keyring 文件
def new(args):
if args.ceph_conf:
raise RuntimeError(will not create a Ceph conf file if attemtping to re-use with `--ceph-conf` flag)
LOG.debug(Creating new cluster named %s , args.cluster)
# 生成配置
cfg = conf.ceph.CephConf()
cfg.add_section(global)
# 获取参数中的额 fsid 或者自动生成
fsid = args.fsid or uuid.uuid4()
cfg.set(global , fsid , str(fsid))
# if networks were passed in, lets set them in the
# global section
if args.public_network:
cfg.set(global , public network , str(args.public_network))
if args.cluster_network:
cfg.set(global , cluster network , str(args.cluster_network))
# mon 节点
mon_initial_members = []
# mon 主机
mon_host = []
# 循环 host
for (name, host) in mon_hosts(args.mon):
# Try to ensure we can ssh in properly before anything else
# ssh key copy
if args.ssh_copykey:
ssh_copy_keys(host, args.username)
# Now get the non-local IPs from the remote node
# 连接远程主机
distro = hosts.get(host, username=args.username)
# 获取主机的 IP 地址
remote_ips = net.ip_addresses(distro.conn)
# custom cluster names on sysvinit hosts won t work
if distro.init == sysvinit and args.cluster != ceph :
LOG.error(custom cluster names are not supported on sysvinit hosts)
raise exc.ClusterNameError(
host %s does not support custom cluster names % host
)
distro.conn.exit()
# Validate subnets if we received any
if args.public_network or args.cluster_network:
# 校验 IP 地址
validate_host_ip(remote_ips, [args.public_network, args.cluster_network])
# Pick the IP that matches the public cluster (if we were told to do
# so) otherwise pick the first, non-local IP
LOG.debug(Resolving host %s , host)
if args.public_network:
ip = get_public_network_ip(remote_ips, args.public_network)
else:
ip = net.get_nonlocal_ip(host)
LOG.debug(Monitor %s at %s , name, ip)
mon_initial_members.append(name)
try:
socket.inet_pton(socket.AF_INET6, ip)
mon_host.append([ + ip + ] )
LOG.info(Monitors are IPv6, binding Messenger traffic on IPv6)
cfg.set(global , ms bind ipv6 , true)
except socket.error:
mon_host.append(ip)
LOG.debug(Monitor initial members are %s , mon_initial_members)
LOG.debug(Monitor addrs are %s , mon_host)
# mon_initial_members 有多个的话，中间用空格隔开
cfg.set(global , mon initial members , , .join(mon_initial_members))
# no spaces here, see http://tracker.newdream.net/issues/3145
# mon_host 有多个的话，中间没有空格
cfg.set(global , mon host , , .join(mon_host))
# override undesirable defaults, needed until bobtail
# http://tracker.ceph.com/issues/6788
cfg.set(global , auth cluster required , cephx)
cfg.set(global , auth service required , cephx)
cfg.set(global , auth client required , cephx)
path = {name}.conf .format(
name=args.cluster,
)
# 创建 mon keyring
new_mon_keyring(args)
LOG.debug(Writing initial config to %s... , path)
tmp = %s.tmp % path
with open(tmp, w) as f:
# 保存 ceph 配置文件
cfg.write(f)
try:
os.rename(tmp, path)
except OSError as e:
if e.errno == errno.EEXIST:
raise exc.ClusterExistsError(path)
else:
raise
注意：
mon_initial_members 有多个的话，中间用空格隔开
mon_host 有多个的话，中间没有空格
创建 ceph.mon.keyring 文件
new_mon_keyring 函数创建 ceph.mon.keyring 文件
def new_mon_keyring(args):
LOG.debug(Creating a random mon key...)
mon_keyring = [mon.]\nkey = %s\ncaps mon = allow *\n % generate_auth_key()
keypath = {name}.mon.keyring .format(
name=args.cluster,
)
oldmask = os.umask(0o77)
LOG.debug(Writing monitor keyring to %s... , keypath)
try:
tmp = %s.tmp % keypath
with open(tmp, w , 0o600) as f:
f.write(mon_keyring)
try:
os.rename(tmp, keypath)
except OSError as e:
if e.errno == errno.EEXIST:
raise exc.ClusterExistsError(keypath)
else:
raise
finally:
os.umask(oldmask)手工部署集群
以 ceph-deploy 部署集群：ceph-deploy new ceph-231 为例，对应的手工操作。
获取 ip 地址
执行以下命令，通过正则表达式获取 IP 地址 192.168.217.231
[root@ceph-231 ceph-cluster]# /usr/sbin/ip link show
1: lo: LOOPBACK,UP,LOWER_UP mtu 65536 qdisc noqueue state UNKNOWN mode DEFAULT
link/loopback 00:00:00:00:00:00 brd 00:00:00:00:00:00
2: eth0: BROADCAST,MULTICAST,UP,LOWER_UP mtu 1500 qdisc pfifo_fast master ovs-system state UP mode DEFAULT qlen 1000
link/ether 02:03:e7:fc:dc:36 brd ff:ff:ff:ff:ff:ff
3: ovs-system: BROADCAST,MULTICAST mtu 1500 qdisc noop state DOWN mode DEFAULT
link/ether 86:f4:14:e3:1b:b2 brd ff:ff:ff:ff:ff:ff
4: xenbr0: BROADCAST,MULTICAST,UP,LOWER_UP mtu 1500 qdisc noqueue state UNKNOWN mode DEFAULT
link/ether 02:03:e7:fc:dc:36 brd ff:ff:ff:ff:ff:ff[root@ceph-231 ceph-cluster]# /usr/sbin/ip addr show
1: lo: LOOPBACK,UP,LOWER_UP mtu 65536 qdisc noqueue state UNKNOWN
link/loopback 00:00:00:00:00:00 brd 00:00:00:00:00:00
inet 127.0.0.1/8 scope host lo
valid_lft forever preferred_lft forever
2: eth0: BROADCAST,MULTICAST,UP,LOWER_UP mtu 1500 qdisc pfifo_fast master ovs-system state UP qlen 1000
link/ether 02:03:e7:fc:dc:36 brd ff:ff:ff:ff:ff:ff
3: ovs-system: BROADCAST,MULTICAST mtu 1500 qdisc noop state DOWN
link/ether 86:f4:14:e3:1b:b2 brd ff:ff:ff:ff:ff:ff
4: xenbr0: BROADCAST,MULTICAST,UP,LOWER_UP mtu 1500 qdisc noqueue state UNKNOWN
link/ether 02:03:e7:fc:dc:36 brd ff:ff:ff:ff:ff:ff
inet 192.168.217.231/24 brd 192.168.217.255 scope global xenbr0
valid_lft forever preferred_lft forever创建 ceph.conf
[root@ceph-231 ceph-cluster]# vi ceph.conf
[global]
fsid = a3b9b0aa-01ab-4e1b-bba3-6f5317b0795b
mon_initial_members = ceph-231
mon_host = 192.168.217.231
auth_cluster_required = cephx
auth_service_required = cephx
auth_client_required = cephx
public_network = 192.168.217.231创建 ceph.mon.keyring
可以通过 ceph-authtool 命令生成
[root@ceph-231 ceph-cluster]# ceph-authtool --create-keyring /tmp/ceph.mon.keyring --gen-key -n mon. --cap mon allow *
creating /tmp/ceph.mon.keyring
[root@ceph-231 ~]# cat /tmp/ceph.mon.keyring
[mon.]
key = AQCzxEhZC7tICxAAuHK5GipD96enMuhv82CCLg==
caps mon = allow *将 /tmp/ceph.mon.keyring 内容复制到 ceph.mon.keyring
[root@ceph-231 ceph-cluster]# vi ceph.mon.keyring
[mon.]
key = AQCzxEhZC7tICxAAuHK5GipD96enMuhv82CCLg==
caps mon = allow以上是“ceph-deploy 中 new 模块有什么用”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注丸趣 TV 行业资讯频道！
正文完
