Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-3-3 / python3-dmapi deb
Repository URL to install this package:
|
Version:
3.3.42 ▾
|
Ú ]¹@ ã @ sÑ d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m
Z d d l m
Z
d d l m Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z m Z m Z d d l m Z e j j! Z! e j" e# Z$ Gd
d d e
j% Z& Gd d
d
e j' Z' Gd d d e( Z) Gd d d e) Z* Gd d d e* Z+ Gd d d e( Z, Gd d d e( Z- d S)z.Utility methods for working with WSGI servers.é N)Úlog)Úservice)Úexcutils)Údeploy)Ú exception)Ú_Ú_LEÚ_LI)Úutilsc @ sy e Z d Z d Z e j j Z d d d e j j d d d d d Z d d
Z
d d Z d
d Z d d Z
d S)ÚServerzAServer class to manage a WSGI server, serving a WSGI application.z0.0.0.0r Né Fc
C sà t j j t j _ | | _ | | _ d | _ | | _ | pB | j | _
t j | j
| _ t
j d | j | _ | | _ | | _ t j j p d | _ | d k rÁ t j d t d | | f }
yB t j |
d |
d t j t j d } | d } | d }
Wn t k
r,t j } Yn Xy t j |
| d | | _ Wn7 t k
r
t j t! d d | d
| i Yn X| j j" d d
\ | _# | _$ t j% t& d d
| j d | j# d
| j$ i d S)a Initialize, but do not start, a WSGI server.
:param name: Pretty name for logging.
:param app: The WSGI application to serve.
:param host: IP address to serve the application.
:param port: Port number to server the application.
:param pool_size: Maximum number of eventlets to spawn concurrently.
:param backlog: Maximum number of queued connections.
:param max_url_len: Maximum length of permitted URLs.
:returns: None
:raises: dmapi.exception.InvalidInput
Nzdmapi.%s.wsgi.serveré Úreasonz The backlog must be more than 0r Úbacklogz#Could not bind to %(host)s:%(port)sÚhostÚporté z'%(name)s listening on %(host)s:%(port)sÚnameéÿÿÿÿ)'ÚCONFÚwsgiZmax_header_lineÚeventletZMAX_HEADER_LINEr ÚappÚ_serverÚ _protocolÚdefault_pool_sizeÚ pool_sizeZ GreenPoolÚ_poolÚloggingÚ getLoggerÚ_loggerÚ_use_sslÚ _max_url_lenÚclient_socket_timeoutr Z InvalidInputr ÚsocketÚ getaddrinfoÚ AF_UNSPECÚ SOCK_STREAMÚ ExceptionÚAF_INETÚlistenÚ_socketÚEnvironmentErrorÚLOGÚerrorr Ú getsocknamer r Úinfor )
Úselfr r r r r Úprotocolr Zuse_sslZ max_url_lenZ bind_addrr0 Úfamily© r4 ú,/usr/lib/python3/dist-packages/dmapi/wsgi.pyÚ__init__( sB
%zServer.__init__c ! C s | j j } | j t j t j d | j t j t j d t t d ro | j t j t j t
j j | j
ry4t
j j } t
j j } t
j j } | rÎ t j j | rÎ t t d | | rý t j j | rý t t d | | r,t j j | r,t t d | | j
rU| sC| rUt t d d d d | d
| d t j i } t
j j r| | d <t j | d <t j | | } WnW t k
rt j 6 t j t d
d | j! d | j" d | j# i Wd QRXYn Xd t j j$ d | d | j% d | j& d | j' d | j( d t
j j) d d d t
j j* d | j+ i
} | j, r| j, | d <t- j. | | _/ d S) zBStart serving a WSGI application.
:returns: None
r
Ú TCP_KEEPIDLEz Unable to find cert_file : %szUnable to find ca_file : %sz Unable to find key_file : %szwWhen running server in SSL mode, you must specify both a cert_file and key_file option value in your configuration fileÚ server_sideTÚcertfileÚkeyfileÚ cert_reqsÚca_certsz>Failed to start %(name)s on %(host)s:%(port)s with SSL supportr r r NÚfuncÚsockÚsiter2 Z custom_poolr Z
log_formatÚdebugFÚ keepaliveÚsocket_timeoutZurl_length_limit)0r+ ÚdupÚ
setsockoptr$ Ú
SOL_SOCKETÚ SO_REUSEADDRÚ SO_KEEPALIVEÚhasattrÚ IPPROTO_TCPr7 r r Z tcp_keepidler! Z ssl_ca_fileZ
ssl_cert_fileZ ssl_key_fileÚosÚpathÚexistsÚ RuntimeErrorr ÚsslÚ CERT_NONEÚ
CERT_REQUIREDr Zwrap_sslr( r Zsave_and_reraise_exceptionr- r. r r r r Úserverr r r r Zwsgi_log_formatZ
keep_aliver# r" r
Úspawnr )r1 Z
dup_socketZca_fileÚ cert_fileÚkey_fileZ
ssl_kwargsZ wsgi_kwargsr4 r4 r5 Ústarta sj
z Server.startc C s | j j | j d S)zIReset server greenpool size to default.
:returns: None
N)r Úresizer )r1 r4 r4 r5 Úreset´ s z Server.resetc C sC t j t d | j d k r? | j j d | j j d S)zµStop this server.
This is not a very nice action, as currently the method by which a
server is stopped is by killing its eventlet.
:returns: None
zStopping WSGI server.Nr )r- r0 r r r rV Úkill)r1 r4 r4 r5 Ústop¼ s z Server.stopc C s\ y- | j d k r, | j j | j j Wn( t j k
rW t j t d Yn Xd S)zBlock, until the server has stopped.
Waits on the server's eventlet to finish, then returns.
:returns: None
NzWSGI server has stopped.) r r ZwaitallÚwaitÚgreenletZ GreenletExitr- r0 r )r1 r4 r4 r5 rZ Ì s
z Server.wait)Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r r r Z HttpProtocolr6 rU rW rY rZ r4 r4 r4 r5 r # s 7 S r c s" e Z d Z f d d Z S)ÚRequestc sQ t j j r1 | j t j j } | r1 | | d <t t | j | | | d S)Nzwsgi.url_scheme)r r Zsecure_proxy_ssl_headerÚgetÚsuperr` r6 )r1 ÚenvironÚargsÚkwargsÚscheme)Ú __class__r4 r5 r6 Ý s
zRequest.__init__)r\ r] r^ r6 r4 r4 )rg r5 r` Ü s r` c @ s4 e Z d Z d Z e d d Z d d Z d S)Ú ApplicationzEBase WSGI application wrapper. Subclasses need to implement __call__.c K s
| | S)aÄ Used for paste app factories in paste.deploy config files.
Any local configuration (that is, values under the [app:APPNAME]
section of the paste config) will be passed into the `__init__` method
as kwargs.
A hypothetical configuration would look like:
[app:wadl]
latest_version = 1.3
paste.app_factory = dmapi.api.fancy_api:Wadl.factory
which would result in a call to the `Wadl` class as
import dmapi.api.fancy_api
fancy_api.Wadl(latest_version='1.3')
You could of course re-implement the `factory` method in subclasses,
but using the kwarg passing it shouldn't be necessary.
r4 )ÚclsÚ
global_configÚ local_configr4 r4 r5 Úfactoryè s zApplication.factoryc C s t t d d S)a\ Subclasses will probably want to implement __call__ like this:
@webob.dec.wsgify(RequestClass=Request)
def __call__(self, req):
# Any of the following objects work as responses:
# Option 1: simple string
res = 'message\n'
# Option 2: a nicely formatted HTTP exception page
res = exc.HTTPForbidden(explanation='Nice try')
# Option 3: a webob Response object (in case you need to play with
# headers, or you want to be treated like an iterable, or ...)
res = Response()
res.app_iter = open('somefile')
# Option 4: any wsgi app to be run next
res = self.application
# Option 5: you can get a Response object for a wsgi app, too, to
# play with headers etc
res = req.get_response(self.application)
# You can then just return your response...
return res
# ... or set req.response and return None.
req.response = res
See the end of http://pythonpaste.org/webob/modules/dec.html
for more info.
zYou must implement __call__N)ÚNotImplementedErrorr )r1 rc Zstart_responser4 r4 r5 Ú__call__ s "zApplication.__call__N)r\ r] r^ r_ Ú classmethodrl rn r4 r4 r4 r5 rh å s rh c @ sm e Z d Z d Z e d d Z d d Z d d Z d d Z e j
j d
e d d Z
d
S)Ú
MiddlewarezòBase WSGI middleware.
These classes require an application to be
initialized that will be called next. By default the middleware will
simply call its wrapped app, or you can override __call__ to customize its
behavior.
c s f d d } | S)aõ Used for paste app factories in paste.deploy config files.
Any local configuration (that is, values under the [filter:APPNAME]
section of the paste config) will be passed into the `__init__` method
as kwargs.
A hypothetical configuration would look like:
[filter:analytics]
redis_host = 127.0.0.1
paste.filter_factory = dmapi.api.analytics:Analytics.factory
which would result in a call to the `Analytics` class as
import dmapi.api.analytics
analytics.Analytics(app_from_paste, redis_host='127.0.0.1')
You could of course re-implement the `factory` method in subclasses,
but using the kwarg passing it shouldn't be necessary.
c s
| S)Nr4 )r )ri rk r4 r5 Ú_factoryG s z$Middleware.factory.<locals>._factoryr4 )ri rj rk rq r4 )ri rk r5 rl 0 s zMiddleware.factoryc C s
| | _ d S)N)Ú application)r1 rr r4 r4 r5 r6 K s zMiddleware.__init__c C s d S)záCalled on each request.
If this returns None, the next application down the stack will be
executed. If it returns a response then that response will be returned
and execution will stop here.
Nr4 )r1 Úreqr4 r4 r5 Úprocess_requestN s zMiddleware.process_requestc C s | S)z'Do whatever you'd like to the response.r4 )r1 Úresponser4 r4 r5 Úprocess_responseX s zMiddleware.process_responseÚ RequestClassc C s8 | j | } | r | S| j | j } | j | S)N)rt Ú get_responserr rv )r1 rs ru r4 r4 r5 rn \ s
zMiddleware.__call__N)r\ r] r^ r_ ro rl r6 rt rv ÚwebobÚdecÚwsgifyr` rn r4 r4 r4 r5 rp & s
rp c @ sI e Z d Z d Z e j j d e d d Z e d d Z
d S)ÚDebugz Helper class for debugging a WSGI application.
Can be inserted into any WSGI application chain to get information
about the request and response.
rw c C sÉ t d d d x3 t | j j D] \ } } t | d | q( Wt | j | j } t d d d x3 t | j j D] \ } } t | d | q Wt | j | j | _ | S)NÚ*é( z REQUEST ENVIRONú=z RESPONSE HEADERS) ÚprintÚlistrc Úitemsrx rr ÚheadersÚprint_generatorÚapp_iter)r1 rs ÚkeyÚvalueÚrespr4 r4 r5 rn m s ""zDebug.__call__c c sY t d d d x9 | D]1 } t j j t j | t j j | Vq Wt d S)z6Iterator that prints the contents of a wrapper string.r} r~ z BODYN)r ÚsysÚstdoutÚwriteÚsixÚ text_typeÚflush)r
Úpartr4 r4 r5 r ~ s
zDebug.print_generatorN) r\ r] r^ r_ ry rz r{ r` rn Ú staticmethodr r4 r4 r4 r5 r| e s !r| c @ sj e Z d Z d Z d d Z e j j d e d d Z e
e j j d e d d Z d S)
ÚRouterz9WSGI middleware that maps incoming requests to WSGI apps.c C s+ | | _ t j j | j | j | _ d S)a Create a router for the given routes.Mapper.
Each route in `mapper` must specify a 'controller', which is a
WSGI app to call. You'll probably want to specify an 'action' as
well and have your controller be an object that can route
the request to the action-specific method.
Examples:
mapper = routes.Mapper()
sc = ServerController()
# Explicit mapping of one route to a controller+action
mapper.connect(None, '/svrlist', controller=sc, action='list')
# Actions are all implicitly defined
mapper.resource('server', 'servers', controller=sc)
# Pointing to an arbitrary WSGI app. You can specify the
# {path_info:.*} parameter so the target app can be handed just that
# section of the URL.
mapper.connect(None, '/v1.0/{path_info:.*}', controller=BlogApp())
N)ÚmapÚroutesZ
middlewareZRoutesMiddlewareÚ _dispatchÚ_router)r1 Zmapperr4 r4 r5 r6 s zRouter.__init__rw c C s | j S)zkRoute the incoming request to a controller based on self.map.
If no match, return a 404.
)r )r1 rs r4 r4 r5 rn ¨ s zRouter.__call__c C s2 | j d d } | s$ t j j S| d } | S)a Dispatch the request to the appropriate controller.
Called by self._router after matching the incoming request to a route
and putting the information into req.environ. Either returns 404
or the routed WSGI app's response.
zwsgiorg.routing_argsr
Z
controller)rc ry ÚexcZ HTTPNotFound)rs Úmatchr r4 r4 r5 r ± s
zRouter._dispatchN) r\ r] r^ r_ r6 ry rz r{ r` rn r r r4 r4 r4 r5 r s
! r c @ s1 e Z d Z d Z d d d Z d d Z d S)ÚLoaderz9Used to load WSGI applications from paste configurations.Nc C s| d | _ | p t j j } t j j | sB t j | | _ n t j j | r] | | _ | j sx t j
d | d S)zInitialize the loader, and attempt to find the config.
:param config_path: Full or relative path to the paste config.
:returns: None
NrK ) Ú config_pathr r Zdmapi_api_paste_configrJ rK ÚisabsZ find_filerL r ZConfigNotFound)r1 r r4 r4 r5 r6 Å s zLoader.__init__c C s y= t j d d | d | j i t j d | j d | SWnC t k
r t j t d | t j d | d | j Yn Xd S)zðReturn the paste URLMap wrapped WSGI application.
:param name: Name of the application to load.
:returns: Paste URLMap object wrapping the requested application.
:raises: `dmapi.exception.PasteAppNotFound`
z"Loading app %(name)s from %(path)sr rK z config:%szCouldn't lookup app: %sN) r- r@ r r ZloadappÚ LookupErrorr r ZPasteAppNotFound)r1 r r4 r4 r5 Úload_app× s
zLoader.load_app)r\ r] r^ r_ r6 r r4 r4 r4 r5 r  s r ).r_ Úos.pathrJ r$ rN r r Z
eventlet.wsgir[ Zoslo_logr r Z oslo_servicer Z
oslo_utilsr Zpaster Zroutes.middlewarer r Z webob.decry Z webob.excZ
dmapi.confÚdmapir Z
dmapi.i18nr r r r
Úconfr r r\ r- Z ServiceBaser r` Úobjectrh rp r| r r r4 r4 r4 r5 Ú<module> s8 ¹ A?$9