您好,登錄后才能下訂單哦!
本篇文章給大家分享的是有關(guān)如何調(diào)用scheduler進(jìn)行異步執(zhí)行,小編覺(jué)得挺實(shí)用的,因此分享給大家學(xué)習(xí),希望大家閱讀完這篇文章后可以有所收獲,話不多說(shuō),跟著小編一起來(lái)看看吧。
RPC-API 的存在是為了快速的響應(yīng)進(jìn)程服務(wù)之間的調(diào)用請(qǐng)求。
PRC 調(diào)用的過(guò)程為:
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 異步調(diào)用, call 同步調(diào)用 # 通過(guò)cast方式的遠(yuǎn)程調(diào)用,請(qǐng)求發(fā)送后就直接返回了;通過(guò)call方式遠(yuǎn)程調(diào)用,需要等響應(yīng)從服務(wù)器返回。 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)
調(diào)用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)
以上就是如何調(diào)用scheduler進(jìn)行異步執(zhí)行,小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘9ぷ鲿?huì)見(jiàn)到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。