python restful 框架_OpenStack Restful API框架介绍

傷城~ 2022-10-22 11:50 451阅读 0赞

1  pecan框架介绍

1.1  什么是pecan

pecan是一个轻量级的python web框架，最主要的特点是提供了简单的配置即可创建一个wsgi对象并提供了基于对象的路由方式。

主要提供的功能点：

(1)基于对象的路由分发

(2)支持restful接口方式

(3)可拓展的安全框架

(4)可拓展的模板语言支持

(5)可拓展的json支持

(6)简单的python配置

1.2  安装部署

为了不影响原有环境我们使用virtualenv工具创建一个隔离的python环境来做实验

$ virtualenv pecan-env$ cd pecan-env$ source bin/activate

安装pecan：

$ pip install pecan

我的实验环境是pecan 1.3.3的，可以用pecan --version命令查看

创建一个pecan项目：

$ pecan create pecan\_test\_project

用tree命令查看下生成的项目文件结构：

![bf22adde90be6fe4f35569a811c1a456.png][]

可以根据自己的需要筛减些，比如我只想要用pecan来帮我实现restful接口，那么public、templates等目录是可以去除掉的

这里介绍几个常用的文件或目录：

pecan\_test\_project/controllers：这个目录是用来存放要路由的对象类和要调用的对象方法的

pecan\_test\_project/model：用来存放模型的，比如一个数据库表的model，做ORM映射时会用到

pecan\_test\_project/tests：可以用来写一些单元测试

pecan\_test\_project/app.py：该文件用来控制如何构建你的pecan应用，该文件里会包含setup\_app函数用来生成和返回一个wsgi app，一般来说，该文件是不用再修改的

config.py：该文件定义了服务的ip和端口号、服务的根目录类等和日志设置等。

直接执行pecan serve config.py命令服务就开始跑起来了

默认监听IP是0.0.0.0，端口号是8080

然后直接在页面访问，比如我的服务器是192.168.0.107，则浏览器访问http://192.168.0.107:8080就会看到如下页面了

![5d9315df30163e03e83d0fa09438c286.png][]

这是因为我们访问的是它的根路径，根据pecan的基于对象的分发，它对调用如下的index方法，返回一个index.html页面了(这个index方法是被默认为当get请求分发到这个对象时会被路由到该方法，它其实是包裹在了expose里，可以理解它为get方法)：

![8d104148f599828afa9bf3141107f035.png][]

1.3  安装部署pecan的对象分发路由策略

Pecan的根路径是通过配置文件中指定的某个类开始的，比如上面的RootController类，并且会把请求路径按/分成多份，比如/test1/test2/test3，则会从RootController找test1对象，再从test1对象中找test2对象，再从test2对象中找test3对象，最后调用test3类对象的方法。

举个例子：

修改root.py文件为：

from pecan importexpose, redirectfrom webob.exc importstatus\_mapclassBooksController(object):

@expose()defindex(self):return "Welcome to book section."@expose()defbestsellers(self):return "We have 5 books in the top 10."

classCatalogController(object):

@expose()defindex(self):return "Welcome to the catalog."books=BooksController()classRootController(object):

@expose(generic=True, template='index.html')defindex(self):returndict()

@index.when(method='POST')defindex\_post(self, q):

redirect('https://pecan.readthedocs.io/en/latest/search.html?q=%s' %q)

@expose('error.html')deferror(self, status):try:

status=int(status)except ValueError: \#pragma: no cover

status = 500message= getattr(status\_map.get(status), 'explanation', '')return dict(status=status, message=message)

catalog= CatalogController()

则如下几个url就会对象如下几个方法：

http://192.168.0.107:8080/catalog  --> CatalogController类index方法

这里主要是通过expose装饰器将类对象的方法暴露出来，使得能够被路由到。Expose中还能指定要返回的对象格式，比如json的，则expose(‘json’)

基于http的请求方法来选择方法：

classBaseMethodController(object):\#HTTP GET /

@expose(generic=True, template='json')defindex(self):returndict()\#HTTP POST /

@index.when(method='POST', template='json')def index\_POST(self, \*\*kw):return kw

在RootController类下加上：

basemethod = BaseMethodController()

可以用curl命令来测试：

curl http://127.0.0.1:8080/basemethod/

curl http://127.0.0.1:8080/basemethod/ -X POST -d 'hello=world'

pecan也提供了一些额外的特殊方法来提高url处理的灵活性，有\_lookup()、\_default()和\_route()等方法。

\_lookup()：

它可以获取一个或多个参数并经过处理后返回一个新的控制器对象并把未处理的url保存于remainder中继续由新的控制器来路由。

classStudent(object):def \_\_init\_\_(self, name):

self.name=nameclassStudentController(object):def \_\_init\_\_(self, student):

self.student=student

@expose()defname(self):returnself.student.nameclassLookupTest(object):

@expose()def \_lookup(self, name, \*remainder):print 'enr'student=Student(name)ifstudent:returnStudentController(student), remainderelse:

abort(404)

在RootController类下加上：

look\_test = LookupTest()

测试：

curl http://127.0.0.1:8080/look\_test/66/name

\_default()：

当其它方法没匹配上时就调用\_default方法

\_route()：

该方法允许你完全覆盖pecan原有的路由机制，pecan也使用该方法实现了RestController。

1.4  pecan的请求和返回对象

我们知道每一个http都是有一个请求对象和相应对象的，这在pecan中是分别对应着pecan.request和pecan.response对象

比如我可以赋值pecan.response.status = 403

1.5  RestController

pecan已经帮我们封装好了RestController的接口，有如下：

![a77f95761887c821d85e22b61d6d0832.png][]

举一个简单的get例子：

classMyRestController(rest.RestController):

@expose()defget(self, id):return id

在RootController类下加上：

my\_restcontroller = MyRestController()

测试：

curl http://127.0.0.1:8080/my\_restcontroller/13579

1.6  一些常用配置项

hook机制配置

hook机制可以使得我们控制当一个http请求在被pecan框架执行过程中各个关键点上执行相对应的代码，以下是四个关键点：

on\_route：当url还没被路由前调用

before：路由到某个函数但执行代码之前调用

after：执行了代码之后调用

on\_error：执行代码过程中发生错误调用

举例：

在app.py的同级目录下创建my\_hooks.py文件：

from pecan.hooks importPecanHookclassSimpleHook(PecanHook):defon\_route(self, state):print 'it is on route'

defbefore(self, state):print 'it is before exec'

defafter(self, state):print 'it is after exec'

defon\_error(self, state, exc):print 'it is on error'

修改app.py文件，加上hoos：

![b6bc508af0aece870fda09287a674549.png][]

比如一个比较常用的是在这里获取数据库连接对象，在路由到的方法里就可以通过request获取到数据库连接对象进行操作了，省去了重复获取代码。比如：

![c48203f18d5b9fb89a7e0410a650c71a.png][]

日志配置：

修改config.py文件：

![a550aa1bbce2b0fd39513460059fc179.png][]

默认是console的，可以改成logfile形式

在controllers如下编写即可：

![f70302cd729d1a4df9872c89642eec6d.png][]

1.7  Pecan和WSGI

部署pecan的wsgi app一般有很多种方式，但一般来说，可以使用deploy()函数生成任何Pecan应用程序的WSGI入口点。

![82f260d9c78024ca1c86e808be607dd4.png][]

这里举我自己项目中部署的两种方式：

(1)使用Werkzeug通用库

![651d75261e25b6c39caaeddcfaafd79e.png][]

这里的第6行返回的就是使用pecan框架的deploy.loadapp()函数产生的wsgi app

Werkzeug就是用python对WSGI的实现一个通用库。它是Flask所使用的底层WSGI库

Serving是Werkzeug库的一个用来运行wsgi的函数，将wsgi app跑起来

![cb02f1918ae2731f07a1822756b66ac5.png][]

(2)Apache + mod\_wsgi的方式

这种方式通过依托于Apache服务的形式，随Apache启动时一同启动wsgi app。

这里以gnocchi-api服务为例讲解

查看该服务的.wsgi配置文件：

![7c4d28d8ae106460961b525aeb2a7f12.png][]

这里重点是看红框里的app文件，这个文件定义了怎么生成wsgi app

查看app文件：

![ad6bf9e8a816b1f894592d9217d15b21.png][]

再查看gnocchi.rest模块下的app文件：

![57f171bf85d825b05d4611abff761310.png][]

![d087f1011f230c1699662791b7a319dc.png][]

可以看到其实最后也是使用deploy.loadapp生成一个wsgi app，然后由appache来运行这个wsgi app。

这里我们用Apache + mod\_wsgi的方式来运行我们实例的pecan程序：

(1)首先安装httpd服务和mod\_wsgi包

yum install httpd mod\_wsgi -y

(2)部署pecan服务

cd pecan\_test\_project

python setup.py build

python setup.pyinstall

(3)创建好用户和配置文件

创建test1用户：

adduser test1

创建配置文件：

/etc/httpd/conf.d/simple\_wsgi.conf：

Listen 0.0.0.0:8080

ServerName thinstack-JxRcqm

\#\# Vhost docroot

DocumentRoot"/var/www/simpleapp/"

Options Indexes FollowSymLinks MultiViews

AllowOverride None

Require all granted\#\# Logging

ErrorLog"/var/log/httpd/simpleapp\_wsgi\_error.log"ServerSignature Off

CustomLog"/var/log/httpd/simpleapp\_wsgi\_access.log"combined

SetEnvIf X-Forwarded-Proto https HTTPS=1WSGIApplicationGroup%\{GLOBAL\}

WSGIDaemonProcess test1 display-name=simpleapp\_wsgi group=test1 processes=4 threads=4 user=test1

WSGIProcessGroup test1

WSGIScriptAlias/ "/var/www/simpleapp/app.wsgi"

/var/www/simpleapp/config.py：

\# Server Specific Configurations

from pecan\_test\_project.my\_hooks import SimpleHook

server=\{'port': '8080','host': '0.0.0.0'\}

\# Pecan Application Configurations

app=\{'root': 'pecan\_test\_project.controllers.root.RootController',

\#'hooks': lambda: \[SimpleHook\],'modules': \['pecan\_test\_project'\],'static\_root': '%(confdir)s/public','template\_path': '%(confdir)s/pecan\_test\_project/templates','debug': True,'errors': \{404: '/error/404','\_\_force\_dict\_\_': True

logging=\{'root': \{'level': 'INFO', 'handlers': \['console'\]\},'loggers': \{'pecan\_test\_project': \{'level': 'DEBUG', 'handlers': \['console'\], 'propagate': False\},'pecan': \{'level': 'DEBUG', 'handlers': \['console'\], 'propagate': False\},'py.warnings': \{'handlers': \['console'\]\},'\_\_force\_dict\_\_': True

\},'handlers': \{'console': \{'level': 'DEBUG','class': 'logging.StreamHandler','formatter': 'color'\},

\},'formatters': \{'simple': \{'format': ('%(asctime)s %(levelname)-5.5s \[%(name)s\]'

'\[%(threadName)s\] %(message)s')

\},'color': \{'()': 'pecan.log.ColorFormatter','format': ('%(asctime)s \[%(padded\_color\_levelname)s\] \[%(name)s\]'

'\[%(threadName)s\] %(message)s'),'\_\_force\_dict\_\_': True

/var/www/simpleapp/app.wsgi：

from pecan.deploy import deploy

application= deploy('/var/www/simpleapp/config.py')

(4)启动服务

systemctl start httpd

查看服务状态：

![ac455cb6bad0df398dbd2be0281d53bb.png][]

就可以看到响应值了

注意点：

Python setup.py install安装报这种错时：

![af4136559858c60518a67d56ce2e85f8.png][]

执行：

pip install soupsieve

1.8  实例项目下载地址

2  Paste + PasteDeploy + Routes

2.1  Paste + PasteDeploy + Routes

这里以nova项目来举例

在一些较老的openstack的核心组件中用的都是比较传统的Paste + PasteDeploy + Routes + WebOb的方式来实现Restful API，比如nova组件，后来openstack社区的人受不了这繁琐的方式，就在新的组件里采用了pecan框架来构建Restful API，这里以nova组件为例进行该种方式的解析

首先我们看下如何使用Paste + PasteDeploy来构建nova的wsgi应用，查看nova关于paste的配置文件，/etc/nova/api-paste.ini：

\#\#\#\#\#\#\#\#\#\#\#\#

\# Metadata \#

\#\#\#\#\#\#\#\#\#\#\#\#

\[composite:metadata\]

use=egg:Paste\#urlmap/: meta

\[pipeline:meta\]

pipeline=cors metaapp

\[app:metaapp\]

paste.app\_factory=nova.api.metadata.handler:MetadataRequestHandler.factory

\[composite:osapi\_compute\]

use=call:nova.api.openstack.urlmap:urlmap\_factory/: oscomputeversions/v2: openstack\_compute\_api\_v21\_legacy\_v2\_compatible/v2.1: openstack\_compute\_api\_v21

\[composite:openstack\_compute\_api\_v21\]

use=call:nova.api.auth:pipeline\_factory\_v21

noauth2=cors http\_proxy\_to\_wsgi compute\_req\_id faultwrap sizelimit osprofiler noauth2 osapi\_compute\_app\_v21

keystone=cors http\_proxy\_to\_wsgi compute\_req\_id faultwrap sizelimit osprofiler authtoken keystonecontext osapi\_compute\_app\_v21

\[composite:openstack\_compute\_api\_v21\_legacy\_v2\_compatible\]

use=call:nova.api.auth:pipeline\_factory\_v21

noauth2=cors http\_proxy\_to\_wsgi compute\_req\_id faultwrap sizelimit osprofiler noauth2 legacy\_v2\_compatible osapi\_compute\_app\_v21

keystone=cors http\_proxy\_to\_wsgi compute\_req\_id faultwrap sizelimit osprofiler authtoken keystonecontext legacy\_v2\_compatible osapi\_compute\_app\_v21

\[filter:request\_id\]

paste.filter\_factory=oslo\_middleware:RequestId.factory

\[filter:compute\_req\_id\]

paste.filter\_factory=nova.api.compute\_req\_id:ComputeReqIdMiddleware.factory

\[filter:faultwrap\]

paste.filter\_factory=nova.api.openstack:FaultWrapper.factory

\[filter:noauth2\]

paste.filter\_factory=nova.api.openstack.auth:NoAuthMiddleware.factory

\[filter:osprofiler\]

paste.filter\_factory=nova.profiler:WsgiMiddleware.factory

\[filter:sizelimit\]

paste.filter\_factory=oslo\_middleware:RequestBodySizeLimiter.factory

\[filter:http\_proxy\_to\_wsgi\]

paste.filter\_factory=oslo\_middleware.http\_proxy\_to\_wsgi:HTTPProxyToWSGI.factory

\[filter:legacy\_v2\_compatible\]

paste.filter\_factory=nova.api.openstack:LegacyV2CompatibleWrapper.factory

\[app:osapi\_compute\_app\_v21\]

paste.app\_factory=nova.api.openstack.compute:APIRouterV21.factory

\[pipeline:oscomputeversions\]

pipeline=cors faultwrap http\_proxy\_to\_wsgi oscomputeversionapp

\[app:oscomputeversionapp\]

paste.app\_factory=nova.api.openstack.compute.versions:Versions.factory

\#\#\#\#\#\#\#\#\#\#

\# Shared \#

\#\#\#\#\#\#\#\#\#\#

\[filter:cors\]

paste.filter\_factory=oslo\_middleware.cors:filter\_factory

oslo\_config\_project=nova

\[filter:keystonecontext\]

paste.filter\_factory=nova.api.auth:NovaKeystoneContext.factory

\[filter:authtoken\]

paste.filter\_factory= keystonemiddleware.auth\_token:filter\_factory

可以看到这个配置文件是ini格式的，都是由\[type:name\]这种形式为单元，在paste中，type包括以下几种类型：

(1)应用:app,application

(2)过滤器:filter,filte-app

(3)管道:pipeline，一般结合添加多个过滤器的时候使用(最后一个是wsgi应用)

(4)组合:composite，表示它由若干个应用和若干个过滤器构成

下面分析个nova比较熟悉的

\[composite:osapi\_compute\]

use=call:nova.api.openstack.urlmap:urlmap\_factory/: oscomputeversions/v2: openstack\_compute\_api\_v21\_legacy\_v2\_compatible/v2.1: openstack\_compute\_api\_v21

这是一个composite类型，看到它的key是use表明它使用了paste中的urlmap的功能，该功能是根据url前缀请求路由到不同的WSGI应用

其中use可以使用以下几种形式：

egg:使用一个URI指定的egg包中的对象

call:使用某个模块中的可调用对象

config:使用另外一个配置文件

osapi\_compute是的use用的是call，查看urlmap\_factory的实现：

def urlmap\_factory(loader, global\_conf, \*\*local\_conf):if 'not\_found\_app' inlocal\_conf:

not\_found\_app= local\_conf.pop('not\_found\_app')else:

not\_found\_app= global\_conf.get('not\_found\_app')ifnot\_found\_app:

not\_found\_app= loader.get\_app(not\_found\_app, global\_conf=global\_conf)

urlmap= URLMap(not\_found\_app=not\_found\_app)for path, app\_name inlocal\_conf.items():

path=paste.urlmap.parse\_path\_expression(path)

app= loader.get\_app(app\_name, global\_conf=global\_conf)

urlmap\[path\]=appreturn urlmap

这里的 local\_conf.items()是在枚举/、/v2和/v2.1

逐个加载生成app，并与path对应起来保存到urlmap中

这里以/v2.1作为分析

\[composite:openstack\_compute\_api\_v21\]

use=call:nova.api.auth:pipeline\_factory\_v21

noauth2=cors http\_proxy\_to\_wsgi compute\_req\_id faultwrap sizelimit osprofiler noauth2 osapi\_compute\_app\_v21

keystone= cors http\_proxy\_to\_wsgi compute\_req\_id faultwrap sizelimit osprofiler authtoken keystonecontext osapi\_compute\_app\_v21

查看pipeline\_factory\_v21实现：

def pipeline\_factory\_v21(loader, global\_conf, \*\*local\_conf):"""A paste pipeline replica that keys off of auth\_strategy."""

return\_load\_pipeline(loader, local\_conf\[CONF.api.auth\_strategy\].split())def\_load\_pipeline(loader, pipeline):

filters= \[loader.get\_filter(n) for n in pipeline\[:-1\]\]

app= loader.get\_app(pipeline\[-1\])

filters.reverse()for filter infilters:

app=filter(app)return app

可以看到pipeline\_factory\_v21函数中根据配置文件auth\_strategy的指定来选择对应配置，项目中默认是使用keystone，于是使用了这行的配置：

keystone = cors http\_proxy\_to\_wsgi compute\_req\_id faultwrap sizelimit osprofiler authtoken keystonecontext osapi\_compute\_app\_v21

接着调用\_load\_pipeline函数先生成osapi\_compute\_app\_v21的app，接着加载各个filter来按序封装app，最后返回一个经过filter封装后的app应用

这里看下生成osapi\_compute\_app\_v21的app

\[app:osapi\_compute\_app\_v21\]

paste.app\_factory= nova.api.openstack.compute:APIRouterV21.factory

查看factory实现：

@classmethoddef factory(cls, global\_config, \*\*local\_config):"""Simple paste factory, :class:\`nova.wsgi.Router\` doesn't have one."""

return cls()

生成一个APIRouterV21类实例，查看\_\_init\_\_实现方法：

def \_\_init\_\_(self):

self.\_loaded\_extension\_info=extension\_info.LoadedExtensionInfo()

super(APIRouterV21, self).\_\_init\_\_()

先通过加载扩展插件信息(一个controller可当做是一个扩展插件)保存到\_loaded\_extension\_info变量中，再调用父类\_\_init\_\_方法：

def \_\_init\_\_(self):def\_check\_load\_extension(ext):returnself.\_register\_extension(ext)

self.api\_extension\_manager=stevedore.enabled.EnabledExtensionManager(

namespace=self.api\_extension\_namespace(),

check\_func=\_check\_load\_extension,

invoke\_on\_load=True,

invoke\_kwds=\{"extension\_info": self.loaded\_extension\_info\})

mapper=ProjectMapper()

self.resources=\{\}\#NOTE(cyeoh) Core API support is rewritten as extensions

\#but conceptually still have core

iflist(self.api\_extension\_manager):\#NOTE(cyeoh): Stevedore raises an exception if there are

\#no plugins detected. I wonder if this is a bug.

self.\_register\_resources\_check\_inherits(mapper)

self.api\_extension\_manager.map(self.\_register\_controllers)

LOG.info(\_LI("Loaded extensions: %s"),

sorted(self.loaded\_extension\_info.get\_extensions().keys()))

super(APIRouterV21, self).\_\_init\_\_(mapper)

这里的关键点在于mapper 实例和\_register\_resources\_check\_inherits函数调用生成映射关系

在\_register\_resources\_check\_inherits函数中通过遍历加载每一个扩展插件并且通过调用\_register\_resources函数来生成该扩展插件的url映射关系保存到mapper 中

\_register\_resources函数实现关键代码：

![5c516d75b898b857b691954527c9f3a6.png][]

在收集了该扩展插件的信息比如collection和member信息后通过调用mapper实例的resource方法来生成url和controller类方法的对应关系，collection和member是在扩展插件里定义的方法名称，用来后面routes进行映射生成。

查看resource方法实现：

![00a01e4c7ec36a33a56abe3859f5896c.png][]

红框标注的是关键调用，通过调用routes模块的方法来生成映射关系。

routes模块根据用户传入的信息如collection和member信息生成url映射，如果没有传入也会默认生成常用的映射url，比如/xxx/的get请求对应到index方法、/xx/的put请求对应到update方法等。

所以这里生成一个app的过程其实也把url映射关系建立起来了

如果想了解它生成过程细节，可查看：

/usr/lib/python2.7/site-packages/routes/mapper.py文件的Mapper类的resource方法，这里列出一些关键注释和调用：

![d40d62636c8b3fe7e8031abde20861be.png][]

从注释中我们可以看到这些选项都是可选的，就算不传任何选项，它也会对controller生成一些常用的映射，collection主要用于给用户指定一些特定的跟get请求相关的，member主要用于给用户指定一些特定的跟post相关的，比如nova/api/openstack/compute/servers.py中的指定：

![f87c695751dbb778606e1da6002f92b0.png][]

函数关键代码：

![554157bc03e1ea46af99e8119aab28a7.png][]

通过调用connect方法来保存生成的映射，connect方法实现在：

nova/api/openstack/\_\_init\_\_.py该文件中：

![3ad5ef1af2ac3a38bf7dc47a82374b86.png][]

最后又是调回到routes模块中去保存url映射

再举一个filter keystonecontext的生成实现：

\[filter:keystonecontext\]

paste.filter\_factory= nova.api.auth:NovaKeystoneContext.factory

查看factory的实现(它继承了Middleware)：

![44926af60dca9552eabc28d0047455fa.png][]

![47217bd924ac6d47dc1263d20c69fe14.png][]

可以看到filter的特性是传入了app或filter对象给它，到最后它会在完成自己的调用后，调用下一个filter或者是app

2.2  查看url映射和查看请求解析结果

(1)列出当前所有url映射的方法

编辑文件：

/usr/lib/python2.7/site-packages/nova/api/openstack/\_\_init\_\_.py：

![6d9b0e7a9d13e1fd79b82ba71ad06fb6.png][]

保存退出后重启服务成功可在日志中找到如下日志：

![089856036043cd4eda11a7a8a389ee18.png][]

(2)获取具体controller类和方法名

查看某个请求通过url映射解析后得到的controller类和其对应的action方法从而找到具体的调用函数。

编辑该文件：

/usr/lib/python2.7/site-packages/nova/api/openstack/\_\_init\_\_.py：

![fa51192abb7ce6b17fa32460fab8c97c.png][]

重启nova-api服务

然后比如做列出云主机列表操作，就可以在日志中找到如下日志：

![79dde0076e825f7f04643c248fc8e65d.png][]

第一个红框是请求url，第二个红框是通过路由模块解析后生成的结果，可以看到它映射到的controller类是：nova.api.openstack.compute.servers.ServersController

方法是detail

我们可以很容易的找到该方法(nova/api/openstack/compute/servers.py文件中)：

![ffbe1ea31dfbf830f44f54d688ca0890.png][]

2.3  在原有controller上简单新增一个api

以Servers该controller为例，在上面添加一个创建快照的api

刚才我们看到nova/api/openstack/compute/servers.py文件的Servers的生成url映射的规则是这样写的：

![457e9118fd5e7159df8af2ae3f69891d.png][]

其实我们只要在member\_actions中加多一项就好了，比如修改为：

member\_actions = \{'action': 'POST', 'create\_snapshot\_test': 'POST'\}

然后重启服务，再通过我们2.2.1中说的列出所有映射url的方法来查看下是否生成映射了：

![2d655d3cabf9a3d65dea6a7fab1cc618.png][]

如果想要测试则可以在novaclient中写一个发起/server/\{server\_id\}/create\_snapshot\_test的url的http请求来测试

这里还有一点，我们看到Servers类只自定义了个action方法，但Servers类里有很多这种方法定义：

![d0ed82e29a24d2adea2b3ee60f5956e9.png][]

其实它们都是通过action引申的，也就是根据根据body中传的action的值来再路由到具体的方法，看红框中的wsgi.action装饰器就是起到这个功能的，所以一个action可以对应到多个方法，但url路径都是/nova/servers/action，但传的参数的action值可以指定，我们可以通过查看novaclient里构建http请求代码可以看出来：

![c4575391f1dc86aa21ffb818e4a99b08.png][]

![99c403206ac9d68da006214e7f286d55.png][]

可以看到url路径还是/servers/\{server\_id\}/action，但body数据中包含了action键的值为revertResize

所以我们也可以仿照实现一个api，比如加一个回滚快照的api：

![6447344a43c43c12cd0512efea5c889d.png][]

在novaclient对应的发请求里可以这样写：

![8dec21a60d0a8204aeab68376b4e32cd.png][]

2.4  创建一个扩展插件到nova组件上

这里我以创建一个名为groups的扩展插件举例如何在nova服务中添加扩展插件

创建控制资源文件

nova/api/openstack/compute/groups.py：

\#--\*-- coding:utf8 --\*--

importwebobfrom webob importexcfrom nova importcomputefrom nova.api.openstack.compute.schemas importgroupsfrom nova.api.openstack importextensionsfrom nova.api.openstack importwsgifrom nova.api importvalidationfrom nova importexceptionfrom nova importdbfrom nova.i18n import\_from nova.policies importgroups as groups\_policies\#from thvmware.manage import VCenterManagement

from nova importcontextfrom oslo\_log importlog as loggingfrom nova.console importtype as ctypeimportnova.conffrom oslo\_utils importuuidutilsfrom nova.consoleauth importrpcapi as consoleauth\_rpcapiimportrequestsimporttraceback

CONF=nova.conf.CONF

LOG= logging.getLogger(\_\_name\_\_)

ALIAS= 'groups'

classGroupsController(wsgi.Controller):def \_\_init\_\_(self):

super(GroupsController, self).\_\_init\_\_()

self.context=context.get\_admin\_context()

self.consoleauth\_rpcapi=consoleauth\_rpcapi.ConsoleAuthAPI()

self.compute\_api=compute.API()

@extensions.expected\_errors(404)

@validation.schema(groups.create)defcreate(self, req, body):

context= req.environ\['nova.context'\]

context.can(groups\_policies.BASE\_POLICY\_NAME)

context.can(groups\_policies.POLICY\_ROOT% 'create')

LOG.info(body)

@extensions.expected\_errors((400, 404))defadd\_group(self, req, body):

context= req.environ\['nova.context'\]

ret= \{'ret\_state':'failed'\}

values= body\['group'\]if not values.has\_key('group\_id') or values\['group\_id'\] == '':

values\['group\_id'\] =uuidutils.generate\_uuid()try:

db.add\_instance\_group(context, values)exceptException,e:

LOG.error('%s', traceback.format\_exc())

ret\['error'\] =e.messagereturnret

ret\['ret\_state'\] = 'success'

returnret

@extensions.expected\_errors(())defget\_groups(self, req):

ret= \{'ret\_state': 'failed'\}

context= req.environ\['nova.context'\]try:

groups=db.get\_groups(context)

ret\['data'\] =groupsexceptException, e:

LOG.error('%s', traceback.format\_exc())

ret\['error'\] =e.messagereturnret

ret\['ret\_state'\] = 'success'

returnretclassGroups(extensions.V21APIExtensionBase):"""extended common support."""name= "Groups"alias=ALIAS

version= 1

defget\_resources(self):

member\_actions= \{'update': 'POST', 'detail': 'GET'\}

collection\_actions= \{'add\_group': 'POST','get\_groups': 'GET'\}

resources=\[\]\#mapper = Route name Methods Path

\#mapper.connect = >

\#\# 示例：

\#\# map.resource("message", "messages", collection=\{"rss": "GET"\})

\#\# "GET /message/rss" => \`\`Messages.rss()\`\`.

\#\# map.resource('message', 'messages', member=\{'mark':'POST'\})

\#\# "POST /message/1/mark" => \`\`Messages.mark(1)\`\`

res =extensions.ResourceExtension(

ALIAS,

GroupsController(),

collection\_actions=collection\_actions,

member\_actions=member\_actions)

resources.append(res)returnresourcesdefget\_controller\_extensions(self):return \[\]

创建API会调用到的数据结构定义文件

nova/api/openstack/compute/schemas/groups.py：

from nova.api.validation importparameter\_types

create=\{'type': 'object','properties': \{'MyTest': \{'type': 'object','properties': \{'myhost': parameter\_types.hostname,

\},'additionalProperties': False,

\},

\},'additionalProperties': False,

创建权限设定文件：

nova/policies/groups.py：

from oslo\_policy importpolicyfrom nova.policies importbase

BASE\_POLICY\_NAME= 'os\_compute\_api:groups'POLICY\_ROOT= 'os\_compute\_api:groups:%s'groups\_policies=\[

policy.RuleDefault(

name=BASE\_POLICY\_NAME,

check\_str=base.RULE\_ADMIN\_API),

policy.RuleDefault(

name=POLICY\_ROOT % 'create',

check\_str=base.RULE\_ANY),

policy.RuleDefault(

name=POLICY\_ROOT % 'discoverable',

check\_str=base.RULE\_ANY),

policy.RuleDefault(

name=POLICY\_ROOT % 'show',

check\_str=base.RULE\_ANY),

\]deflist\_rules():return groups\_policies

注册API：

nova/policies/\_\_init\_\_.py：

from nova.policies importgroups

......deflist\_rules():returnitertools.chain(

......

groups.list\_rules(),

......

添加entry\_points:

nova.egg-info/entry\_points.txt：

\[nova.api.v21.extensions\]

........

groups=nova.api.openstack.compute.groups:Groups

........

重启nova-api服务：

可以在日志中看到Loaded extensions中加载的插件中包含了我们新加的插件名字：

![f7e72fb99e1688f57ee3ffe720cd9703.png][]

也可以使用命令nova list-extensions查看加载的插件

通过之前查看url映射的方法也可以看到建立的映射：

![6307df847a18bf1e10d62e9a15d02a6f.png][]

[bf22adde90be6fe4f35569a811c1a456.png]: /images/20221022/79bc6149e2c24721984069357f7c2ed5.png
[5d9315df30163e03e83d0fa09438c286.png]: /images/20221022/a9cd1932a349438b99a0bbb803fa75b6.png
[8d104148f599828afa9bf3141107f035.png]: /images/20221022/7041f02d4f9c4e0d8c231fe24f71ae66.png
[a77f95761887c821d85e22b61d6d0832.png]: /images/20221022/ad079449f39c4283928995a629e33142.png
[b6bc508af0aece870fda09287a674549.png]: /images/20221022/49bbfa58bb484c6caaed45d4d8e8f5c0.png
[c48203f18d5b9fb89a7e0410a650c71a.png]: /images/20221022/7261802a5aca46a2ac8817ed3b2d8cc3.png
[a550aa1bbce2b0fd39513460059fc179.png]: /images/20221022/775cdaf61a6f4e9b8fe8842bf0a59433.png
[f70302cd729d1a4df9872c89642eec6d.png]: /images/20221022/58d7c104d9e6407b8b7a90d9ba52fc8f.png
[82f260d9c78024ca1c86e808be607dd4.png]: /images/20221022/676cc63b432f43a3b10b6206ff09d489.png
[651d75261e25b6c39caaeddcfaafd79e.png]: /images/20221022/12d19f642b9a4b13a2b1cd05dacd8472.png
[cb02f1918ae2731f07a1822756b66ac5.png]: /images/20221022/41b060d3b43242a184a9fb8c82934eec.png
[7c4d28d8ae106460961b525aeb2a7f12.png]: /images/20221022/05937183edbd4053bfa6591d007f9862.png
[ad6bf9e8a816b1f894592d9217d15b21.png]: /images/20221022/51ffc1900a21414fbbb0b9f716856766.png
[57f171bf85d825b05d4611abff761310.png]: /images/20221022/7781c0bff6c34415884e2377a1f99ff6.png
[d087f1011f230c1699662791b7a319dc.png]: /images/20221022/08c8f0b0b7574055808ec8b24a0584d6.png
[ac455cb6bad0df398dbd2be0281d53bb.png]: /images/20221022/b946f74082be40d89d771ed4158749e6.png
[af4136559858c60518a67d56ce2e85f8.png]: /images/20221022/165742ad67d14f5a84d1a2de8d1a9064.png
[5c516d75b898b857b691954527c9f3a6.png]: /images/20221022/41041a8768404b8fbfb818f8cfc40a53.png
[00a01e4c7ec36a33a56abe3859f5896c.png]: /images/20221022/a2d050d92bcc43b5b12d1b5c5297ba09.png
[d40d62636c8b3fe7e8031abde20861be.png]: /images/20221022/85dd7548327f4f959c9c067f5454f778.png
[f87c695751dbb778606e1da6002f92b0.png]: /images/20221022/709b45dd2abb412e9b138c6f370bdcd2.png
[554157bc03e1ea46af99e8119aab28a7.png]: /images/20221022/e4d679ba8cf94c218a791eba1c8739ee.png
[3ad5ef1af2ac3a38bf7dc47a82374b86.png]: /images/20221022/e9dc1eeff8fa4992a609a203273597ca.png
[44926af60dca9552eabc28d0047455fa.png]: /images/20221022/6c3eb8bdd6974d8ca40faf3c5511ec9c.png
[47217bd924ac6d47dc1263d20c69fe14.png]: /images/20221022/d42d5ec3966c44ceaeb83d8202acd31c.png
[6d9b0e7a9d13e1fd79b82ba71ad06fb6.png]: /images/20221022/6801ac47aa2b4e61b7fa812241155eb5.png
[089856036043cd4eda11a7a8a389ee18.png]: /images/20221022/6a89fd6e95ae43e2aca7364935339dbb.png
[fa51192abb7ce6b17fa32460fab8c97c.png]: /images/20221022/ad318369ea114213b6a31e8b622ddc47.png
[79dde0076e825f7f04643c248fc8e65d.png]: /images/20221022/c28e57a01809454cb230d6b40eb22001.png
[ffbe1ea31dfbf830f44f54d688ca0890.png]: /images/20221022/bffbdffd332245b586be21ec5e2ab8e0.png
[457e9118fd5e7159df8af2ae3f69891d.png]: /images/20221022/daf943cab8c9437f9ca960161229d262.png
[2d655d3cabf9a3d65dea6a7fab1cc618.png]: /images/20221022/219f19d2c4134aa88fd868a0ae8552f1.png
[d0ed82e29a24d2adea2b3ee60f5956e9.png]: /images/20221022/561c76e85ee94384a0c3ed288be9a801.png
[c4575391f1dc86aa21ffb818e4a99b08.png]: /images/20221022/4baa0dbe04984cfe9d7702309c702fc0.png
[99c403206ac9d68da006214e7f286d55.png]: /images/20221022/fc13dc485d5649aa9ff804c132a8c161.png
[6447344a43c43c12cd0512efea5c889d.png]: /images/20221022/589698d19fca4ba58a6bda7e0c38b506.png
[8dec21a60d0a8204aeab68376b4e32cd.png]: /images/20221022/720cfc5b45cb4b949a4ab959f69ee9e9.png
[f7e72fb99e1688f57ee3ffe720cd9703.png]: /images/20221022/7e69b5af6ae34150b2c2d63dc74ba568.png
[6307df847a18bf1e10d62e9a15d02a6f.png]: /images/20221022/3a816353b82c4227af7264a10800d029.png