mirror of
https://github.com/frappe/gunicorn.git
synced 2026-01-14 11:09:11 +08:00
Update custom application example.
It's running on both Python 2 and 3 now.
This commit is contained in:
parent
fd5c2e99fb
commit
1c68516fd7
@ -10,52 +10,7 @@ Sometimes, you want to integrate Gunicorn with your WSGI application. In this
|
|||||||
case, you can inherit from :class:`gunicorn.app.base.BaseApplication`.
|
case, you can inherit from :class:`gunicorn.app.base.BaseApplication`.
|
||||||
|
|
||||||
Here is a small example where we create a very small WSGI app and load it with a
|
Here is a small example where we create a very small WSGI app and load it with a
|
||||||
custom Application::
|
custom Application:
|
||||||
|
|
||||||
#!/usr/bin/env python
|
.. literalinclude:: ../../examples/standalone_app.py
|
||||||
import gunicorn.app.base
|
:lines: 11-60
|
||||||
|
|
||||||
def handler_app(environ, start_response):
|
|
||||||
response_body = 'Works fine'
|
|
||||||
status = '200 OK'
|
|
||||||
|
|
||||||
response_headers = [
|
|
||||||
('Content-Type', 'text/plain'),
|
|
||||||
('Content-Length', str(len(response_body)))
|
|
||||||
]
|
|
||||||
|
|
||||||
start_response(status, response_headers)
|
|
||||||
|
|
||||||
return [response_body]
|
|
||||||
|
|
||||||
class StandaloneApplication(gunicorn.app.base.BaseApplication):
|
|
||||||
def __init__(self, app, options=None):
|
|
||||||
self.options = dict(options or {})
|
|
||||||
self.application = app
|
|
||||||
super(StandaloneApplication, self).__init__()
|
|
||||||
|
|
||||||
def load_config(self):
|
|
||||||
tmp_config = map(
|
|
||||||
lambda item: (item[0].lower(), item[1]),
|
|
||||||
self.options.iteritems()
|
|
||||||
)
|
|
||||||
|
|
||||||
config = dict(
|
|
||||||
(key, value)
|
|
||||||
for key, value in tmp_config
|
|
||||||
if key in self.cfg.settings and value is not None
|
|
||||||
)
|
|
||||||
|
|
||||||
for key, value in config.iteritems():
|
|
||||||
self.cfg.set(key.lower(), value)
|
|
||||||
|
|
||||||
def load(self):
|
|
||||||
return self.application
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
options = {
|
|
||||||
'bind': '%s:%s' % ('127.0.0.1', '8080'),
|
|
||||||
'workers': 4,
|
|
||||||
# 'pidfile': pidfile,
|
|
||||||
}
|
|
||||||
StandaloneApplication(handler_app, options).run()
|
|
||||||
|
|||||||
@ -8,21 +8,25 @@
|
|||||||
# This file is part of gunicorn released under the MIT license.
|
# This file is part of gunicorn released under the MIT license.
|
||||||
# See the NOTICE for more information.
|
# See the NOTICE for more information.
|
||||||
|
|
||||||
import gunicorn
|
from __future__ import unicode_literals
|
||||||
import gunicorn.app.base
|
|
||||||
import multiprocessing
|
import multiprocessing
|
||||||
|
|
||||||
|
import gunicorn.app.base
|
||||||
|
|
||||||
|
from gunicorn.six import iteritems
|
||||||
|
|
||||||
|
|
||||||
def number_of_workers():
|
def number_of_workers():
|
||||||
return (multiprocessing.cpu_count() * 2) + 1
|
return (multiprocessing.cpu_count() * 2) + 1
|
||||||
|
|
||||||
|
|
||||||
def handler_app(environ, start_response):
|
def handler_app(environ, start_response):
|
||||||
response_body = 'Works fine'
|
response_body = b'Works fine'
|
||||||
status = '200 OK'
|
status = '200 OK'
|
||||||
|
|
||||||
response_headers = [
|
response_headers = [
|
||||||
('Content-Type', 'text/plain'),
|
('Content-Type', 'text/plain'),
|
||||||
('Content-Lenfth', str(len(response_body))),
|
|
||||||
]
|
]
|
||||||
|
|
||||||
start_response(status, response_headers)
|
start_response(status, response_headers)
|
||||||
@ -31,24 +35,16 @@ def handler_app(environ, start_response):
|
|||||||
|
|
||||||
|
|
||||||
class StandaloneApplication(gunicorn.app.base.BaseApplication):
|
class StandaloneApplication(gunicorn.app.base.BaseApplication):
|
||||||
|
|
||||||
def __init__(self, app, options=None):
|
def __init__(self, app, options=None):
|
||||||
self.options = dict(options or {})
|
self.options = options or {}
|
||||||
self.application = app
|
self.application = app
|
||||||
super(StandaloneApplication, self).__init__()
|
super(StandaloneApplication, self).__init__()
|
||||||
|
|
||||||
def load_config(self):
|
def load_config(self):
|
||||||
tmp_config = map(
|
config = dict([(key, value) for key, value in iteritems(self.options)
|
||||||
lambda item: (item[0].lower(), item[1]),
|
if key in self.cfg.settings and value is not None])
|
||||||
self.options.iteritems()
|
for key, value in iteritems(config):
|
||||||
)
|
|
||||||
|
|
||||||
config = dict(
|
|
||||||
(key, value)
|
|
||||||
for key, value in tmp_config
|
|
||||||
if key in self.cfg.settings and value is not None
|
|
||||||
)
|
|
||||||
|
|
||||||
for key, value in config.iteritems():
|
|
||||||
self.cfg.set(key.lower(), value)
|
self.cfg.set(key.lower(), value)
|
||||||
|
|
||||||
def load(self):
|
def load(self):
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user