nova-conductor数据库远程对象模型
文章来自作者维护的社区微信公众号【虚拟化云计算】)
远程对象所实现的效果是:一个 A 服务中的远程对象实例,可以由消息队列传送到B 服务,B 服务能够使用这个实例,当调用实例的方法时,实际执行这个方法却是在A 服务中。
以 Instance 类的实例为例,nova-conductor 在收到创建虚拟机请求时生成了实例 instance = Instance(),之后将instance 通过消息队列发送到了 nova-compute,在 nova-compute 进行虚拟机创建的过程中,经常性地需要更改虚拟机的状态,所以经常出现类似这样的语句:
instance.task_state = task_states.XXX
instance.save()
nova-compute 不直接访问数据库,这个 save() 方法,就是由 nova-conductor 来执行的。
具体原理:
以instance的save()方法为例,(objects/instance.py ),他有一个修饰@base.remotable
@base.remotable
def save(self, expected_vm_state=None,
expected_task_state=None, admin_state_reset=False):
remotable的定义如下(dist-packages/oslo_versionedobjects/base.py),根据indirection_api的定义情况:如果有定义indirection_api,则把save()方法作为一个参数fn来运行indirection_api.object_action,如果没有定义则运行save()
def remotable(fn):
"""Decorator for remotable object methods."""
@six.wraps(fn)
def wrapper(self, *args, **kwargs):
......
if self.indirection_api:
updates, result = self.indirection_api.object_action(
ctxt, self, fn.__name__, args, kwargs)
......
else:
return fn(self, *args, **kwargs)
indirection_api在nova-compute服务中有赋值(cmd/compute.py ),而其他服务中没有:
def main():
......
if not CONF.conductor.use_local:
cmd_common.block_db_access('nova-compute')
objects_base.NovaObject.indirection_api = \
conductor_rpcapi.ConductorAPI()
所以:
nova-compute运行instance.save()时是把save方法以及save的参数作为参数去运行indirection_api.object_action,而其他服务则是直接运行save()。
而indirection_api.object_action的具体实现就是消息队列的call方法。
class ConductorAPI(object):
def object_action(self, context, objinst, objmethod, args, kwargs):
cctxt = self.client.prepare()
return cctxt.call(context, 'object_action', objinst=objinst,
objmethod=objmethod, args=args, kwargs=kwargs)
============================================================
关注微信公众号【虚拟化云计算】,阅读更多虚拟化云计算知识,纯技术干货更新不停。