OpenStack单机环境搭建

# -*- coding: utf-8 -*-

from __future__ import print_function

import os
import sys

from textwrap import dedent

from fabric.api import env, settings
from fabric.api import run, cd
from fabric.api import local, lcd
from fabric.main import main

# 配置SSH信息
# env.hosts = [host for host in os.environ.get("OPEN_STACK_IP", "").split(",") if host]
env.hosts = ["10.0.1.105"]
env.user = os.environ.get("OPEN_STACK_USE", "root")
# 密钥对生成方式为  ssh-keygen -t rsa -b 4096 -C "email@email.com" -m PEM -f "/tmp/test_key"
# env.key_filename = os.environ.get("OPEN_STACK_KEY_FILE", "%s/.ssh/id_rsa" % os.environ["HOME"])
env.key_filename = "/tmp/test_key"
env.password = os.environ.get("OPEN_STACK_PASS", "")
env.port = os.environ.get("OPEN_STACK_PORT", 22)
print(
    "hosts: %s\n user: %s, port: %s, password: %s, key filename: %s" % (
        env.hosts, env.user, env.port, env.password, env.key_filename)
)


class OpenStackDeploy(object):
    def __init__(self, run_cmd, run_cd):
        self.run_cmd = run_cmd
        self.run_cd = run_cd

        self._stack_user = "stack"
        self._stack_home = "/opt/stack"
        self._stack_branch = "stable/queen"
        self._stack_origin = "https://git.openstack.org/openstack-dev/devstack"
        self._stack_root = os.path.join(self._stack_home, "devstack")

    @classmethod
    def get_deploy(cls):
        if env.hosts:
            run_cmd, run_cd = run, cd
        else:
            run_cmd, run_cd = local, lcd
        return cls(run_cmd, run_cd)

    def _check_os_version(self):
        self.run_cmd("cat /etc/issue")

    def _check_os_memory(self):
        self.run_cmd("free -g")

    def _check_os_disk(self):
        self.run_cmd("df -Th")

    def check(self):
        self._check_os_version()
        self._check_os_memory()
        self._check_os_disk()

    def backup_source(self):
        cmd = dedent("""\
        test -f /etc/apt/sources.list && mv /etc/apt/sources.list /etc/apt/sources.list.$(date +%s).bak
        cat >/etc/apt/sources.list <<EOF
        deb http://mirrors.aliyun.com/ubuntu/ xenial main
        deb-src http://mirrors.aliyun.com/ubuntu/ xenial main
        
        deb http://mirrors.aliyun.com/ubuntu/ xenial-updates main
        deb-src http://mirrors.aliyun.com/ubuntu/ xenial-updates main
        
        deb http://mirrors.aliyun.com/ubuntu/ xenial universe
        deb-src http://mirrors.aliyun.com/ubuntu/ xenial universe
        deb http://mirrors.aliyun.com/ubuntu/ xenial-updates universe
        deb-src http://mirrors.aliyun.com/ubuntu/ xenial-updates universe
        
        deb http://mirrors.aliyun.com/ubuntu/ xenial-security main
        deb-src http://mirrors.aliyun.com/ubuntu/ xenial-security main
        deb http://mirrors.aliyun.com/ubuntu/ xenial-security universe
        deb-src http://mirrors.aliyun.com/ubuntu/ xenial-security universe
        EOF
        """)
        self.run_cmd(cmd)

    def update_soft(self):
        self.run_cmd("sudo apt-get -y update")

    def sync_time(self):
        cmd_list = [
            'sudo apt-get install -y ntpdate',
            'sudo ntpdate cn.pool.ntp.org',
            'date +"%F %T"',
        ]
        for cmd in cmd_list:
            self.run_cmd(cmd)

    def create_user(self):
        with settings(warn_only=True):
            cmd = 'id %s >/dev/null 2&> 1 || sudo useradd -s /bin/bash -d %s -m stack' % (
                self._stack_user, self._stack_home)
            self.run_cmd(cmd)

        self.run_cmd('echo "stack ALL=(ALL) NOPASSWD: ALL" | sudo tee /etc/sudoers.d/stack')

    def clone_devstack(self):
        cmd = "test -f %s || git clone -b %s --depth=1 %s %s" % (
            self._stack_root, self._stack_branch, self._stack_origin, self._stack_root)
        self.run_cmd(cmd)

    def update_conf(self):
        sample_conf = os.path.join(self._stack_root, "samples/local.conf")
        local_conf = os.path.join(self._stack_root, "local.conf")
        self.run_cmd("scp %s %s" % (sample_conf, local_conf))

        cmd = dedent("""\
        cat >>/opt/stack/devstack/local.conf<<EOF

        HOST_IP=127.0.0.1
        
        # GIT mirror
        GIT_BASE=http://git.trystack.cn
        NOVNC_REPO=http://git.trystack.cn/kanaka/noVNC.git
        SPICE_REPO=http://git.trystack.cn/git/spice/spice-html5.git
        EOF
        """)
        self.run_cmd(cmd)

        self.run_cmd("scp %s %s" % (os.path.join(self._stack_root, "samples/local.sh"), self._stack_root))

    def deploy(self):
        self.check()
        self.backup_source()
        self.create_user()
        self.clone_devstack()
        self.update_conf()


def deploy():
    d = OpenStackDeploy.get_deploy()
    d.deploy()


if __name__ == '__main__':
    sys.argv = [os.path.abspath(__file__), "deploy"]
    main([os.path.abspath(__file__)])