OpenStack Nova 创建虚拟机:从 API 到实例的深度解析
OpenStack Nova 是 OpenStack 生态中的核心计算服务,负责管理和调度虚拟机实例。理解 Nova 创建虚拟机的完整流程,对云平台运维、二次开发或故障排查至关重要。本文将从架构原理切入,通过可运行代码示例,深入剖析从 API 请求到实例启动的全过程。### 1. Nova 架构与核心组件Nova 采用分布式架构,由多个服务组件协同工作:-nova-api:接收用户请求(如创建虚拟机),暴露 RESTful API。-nova-scheduler:根据资源策略,选择合适的计算节点。-nova-compute:运行在计算节点上,管理虚拟机生命周期(启动、停止、销毁)。-nova-conductor:处理数据库操作和复杂逻辑,减少 nova-compute 对数据库的直接访问。-Message Queue (RabbitMQ):各组件通过消息队列异步通信。创建虚拟机的核心流程如下:1. 客户端调用POST /serversAPI。2. nova-api 验证请求,写入数据库,并发布build_and_run_instance消息到队列。3. nova-scheduler 消费消息,通过过滤和权重算法选择目标计算节点。4. nova-compute 收到调度结果,调用虚拟化驱动(如 libvirt)创建实例。### 2. 创建虚拟机的关键步骤:从代码看原理为了深入理解,我们编写两个 Python 代码片段,模拟 Nova 内部逻辑。#### 2.1 模拟 nova-api 的请求处理以下代码展示 nova-api 如何接收用户请求并触发调度。它使用openstack库(需安装:pip install openstacksdk)直接调用 API,但这里我们关注内部逻辑。pythonimport uuidimport timefrom nova import contextfrom nova import objectsfrom nova.conductor import api as conductor_api# 模拟 nova-api 处理创建虚拟机的请求def create_instance_request(): # 创建请求上下文(模拟用户认证信息) ctxt = context.RequestContext(user_id='admin', project_id='demo') # 构建实例对象(模拟用户 API 输入) instance = objects.Instance(ctxt) instance.id = str(uuid.uuid4()) instance.display_name = 'test-vm' instance.flavor = objects.Flavor(ctxt, vcpus=2, memory_mb=2048, root_gb=20) instance.image_ref = 'cirros-0.5.2-x86_64-disk' # 镜像 UUID instance.user_id = ctxt.user_id instance.project_id = ctxt.project_id # 创建 conductor API 实例(模拟消息发送) conductor = conductor_api.API() # 核心:调用 build_and_run_instance 触发调度 # 实际中,此方法会发送消息到队列,scheduler 和 compute 依次处理 conductor.build_and_run_instance(ctxt, instance) print(f"实例 {instance.display_name} 已提交创建请求") return instance# 调用函数instance = create_instance_request()注释说明:-context.RequestContext模拟用户认证信息,实际部署中由 Keystone 提供。-objects.Instance是 Nova 的 Domain Model,封装了实例属性。-conductor.build_and_run_instance是核心入口,它会将实例信息写入数据库,并发布消息。#### 2.2 模拟 nova-compute 的实例启动流程当 nova-compute 接收到调度消息后,会调用虚拟化驱动创建虚拟机。以下代码使用libvirt库(需安装:pip install libvirt-python)模拟 KVM 虚拟机的创建。pythonimport libvirtfrom xml.etree import ElementTree# 模拟 nova-compute 的 spawn 方法def spawn_vm(instance_name, vcpus, memory_mb, disk_path): # 连接本地 QEMU 驱动 conn = libvirt.open('qemu:///system') if conn is None: raise Exception("无法连接到 libvirt") # 构建虚拟机 XML 配置 # 注意:实际 Nova 使用更复杂的配置,这里简化以说明原理 domain_xml = f""" <domain type='kvm'> <name>{instance_name}</name> <memory unit='MiB'>{memory_mb}</memory> <vcpu placement='static'>{vcpus}</vcpu> <devices> <disk type='file' device='disk'> <driver name='qemu' type='qcow2'/> <source file='{disk_path}'/> <target dev='vda' bus='virtio'/> </disk> <interface type='network'> <source network='default'/> <model type='virtio'/> </interface> <console type='pty'> <target type='serial' port='0'/> </console> </devices> </domain> """ # 创建并启动虚拟机 try: domain = conn.defineXML(domain_xml) domain.create() # 启动虚拟机 print(f"虚拟机 {instance_name} 已成功创建并启动") return domain except libvirt.libvirtError as e: print(f"创建失败: {e}") return None finally: conn.close()# 调用函数(假设已有镜像文件 /var/lib/libvirt/images/cirros.qcow2)spawn_vm('test-vm', 2, 2048, '/var/lib/libvirt/images/cirros.qcow2')注释说明:-libvirt.open('qemu:///system')连接到本地 QEMU 管理程序。- XML 配置定义了虚拟机的 CPU、内存、磁盘和网络,这是 Nova 通过libvirt_driver生成的实际配置。-domain.defineXML()和domain.create()分别完成定义和启动。### 3. 调度与资源分配原理Nova-scheduler 是创建流程的决策核心。它通过两阶段选择计算节点:-过滤阶段:根据主机状态(如可用内存、CPU 核数)过滤不满足要求的节点。常用过滤器包括RamFilter、CoreFilter和AvailabilityZoneFilter。-权重阶段:对剩余节点打分,选择最优节点。默认权重算法基于可用资源比例。例如,如果一个节点有 4 核 CPU、8 GB 内存,而请求是 2 核、2 GB 内存,则该节点会通过过滤,并根据剩余资源比例得到权重。### 4. 网络与存储集成创建虚拟机时,Nova 需与 Neutron(网络服务)和 Cinder(块存储服务)交互:-网络:Nova 调用 Neutron API 创建端口(port),并绑定到实例。端口配置包括 IP 地址、安全组等。-存储:如果使用卷启动,Nova 调用 Cinder API 创建卷,并作为根磁盘挂载到虚拟机。这一过程通过 Nova 的network_api和volume_api模块实现,它们也是异步消息驱动的。### 5. 总结从 API 请求到虚拟机启动,OpenStack Nova 的创建流程体现了分布式系统的设计精髓:组件解耦、异步通信、可插拔调度。通过本文的代码模拟,我们揭示了内部关键步骤:API 验证与消息发布、调度过滤与权重、计算节点 libvirt 调用。实际生产环境中,还需考虑高可用、资源配额、租户隔离等复杂场景。理解这些原理,有助于你更高效地运维 OpenStack 云平台,或在故障时快速定位问题。建议读者结合 OpenStack 源码(如nova/conductor/manager.py和nova/compute/manager.py)深入学习,并尝试在测试环境中部署,体验完整的创建流程。