本篇文章给大家分享的是有关如何调用scheduler进行异步执行，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
创新互联专注为客户提供全方位的互联网综合服务，包含不限于成都网站制作、做网站、丰都网络推广、成都微信小程序、丰都网络营销、丰都企业策划、丰都品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联为所有大学生创业者提供丰都建站搭建服务，24小时服务热线：028-86922220，官方网址：www.cdcxhl.com
RPC-API 的存在是为了快速的响应进程服务之间的调用请求。
PRC 调用的过程为：
graph LR A(api.py)-->B(rpcapi.py) B(rpcapi.py)-->C(manager.py)
cinder\cinder\scheduler\rpcapi.py
class SchedulerAPI(rpc.RPCAPI): """省略代码""" def say_hello(self, ctxt): version = '3.0' cctxt = self.client.prepare(version=version) # cast 异步调用, call 同步调用 # 通过cast方式的远程调用，请求发送后就直接返回了；通过call方式远程调用，需要等响应从服务器返回。 cctxt.cast(ctxt, 'say_hello')
cinder\cinder\scheduler\manager.py
class _SchedulerV3Proxy(object):
"""省略代码"""
def say_hello(self, context):
"""Demo function. test say hello."""
LOG.debug('===========manager say_hello==============hello,wangyue========================')
#通知ceilmeter
rpc.get_notifier("volume", CONF.host).info(context, '======scheduler say hello to you, wangyue======', None)调用rpcapi
from cinder.scheduler import rpcapi
"""省略代码"""
def say_hello(self, req):
LOG.debug('=============say hello begin===================')
context = req.environ['cinder.context']
authorize(context, 'storages')
rpc = rpcapi.SchedulerAPI()
rpc.say_hello(context)
return webob.Response(status_int=202)以上就是如何调用scheduler进行异步执行，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。
