Day 07

.gitignore

@@ -0,0 +1,54 @@
+*.py[cod]
+
+test.db
+test.txt
+sina.html
+
+# C extensions
+*.so
+
+# Packages
+*.egg
+*.egg-info
+dist
+build
+eggs
+parts
+bin
+var
+sdist
+develop-eggs
+.installed.cfg
+lib
+lib64
+__pycache__
+
+# Installer logs
+pip-log.txt
+
+# Unit test / coverage reports
+.coverage
+.tox
+nosetests.xml
+
+######################
+# OS generated files #
+######################
+.DS_Store
+.DS_Store?
+._*
+.Spotlight-V100
+.Trashes
+Icon?
+ehthumbs.db
+Thumbs.db
+dist
+MANIFEST
+
+# Translations
+*.mo
+
+# Mr Developer
+.mr.developer.cfg
+.project
+.pydevproject

README.md

@@ -0,0 +1,4 @@
+awesome-python3-webapp
+======================
+
+A python webapp tutorial.

www/apis.py

@@ -0,0 +1,41 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+__author__ = 'Michael Liao'
+
+'''
+JSON API definition.
+'''
+
+import json, logging, inspect, functools
+
+class APIError(Exception):
+ '''
+ the base APIError which contains error(required), data(optional) and message(optional).
+ '''
+ def __init__(self, error, data='', message=''):
+ super(APIError, self).__init__(message)
+ self.error = error
+ self.data = data
+ self.message = message
+
+class APIValueError(APIError):
+ '''
+ Indicate the input value has error or invalid. The data specifies the error field of input form.
+ '''
+ def __init__(self, field, message=''):
+ super(APIValueError, self).__init__('value:invalid', field, message)
+
+class APIResourceNotFoundError(APIError):
+ '''
+ Indicate the resource was not found. The data specifies the resource name.
+ '''
+ def __init__(self, field, message=''):
+ super(APIResourceNotFoundError, self).__init__('value:notfound', field, message)
+
+class APIPermissionError(APIError):
+ '''
+ Indicate the api has no permission.
+ '''
+ def __init__(self, message=''):
+ super(APIPermissionError, self).__init__('permission:forbidden', 'permission', message)

www/app.py

@@ -0,0 +1,126 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+__author__ = 'Michael Liao'
+
+'''
+async web application.
+'''
+
+import logging; logging.basicConfig(level=logging.INFO)
+
+import asyncio, os, json, time
+from datetime import datetime
+
+from aiohttp import web
+from jinja2 import Environment, FileSystemLoader
+
+import orm
+from coroweb import add_routes, add_static
+
+def init_jinja2(app, **kw):
+ logging.info('init jinja2...')
+ options = dict(
+ autoescape = kw.get('autoescape', True),
+ block_start_string = kw.get('block_start_string', '{%'),
+ block_end_string = kw.get('block_end_string', '%}'),
+ variable_start_string = kw.get('variable_start_string', '{{'),
+ variable_end_string = kw.get('variable_end_string', '}}'),
+ auto_reload = kw.get('auto_reload', True)
+ )
+ path = kw.get('path', None)
+ if path is None:
+ path = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'templates')
+ logging.info('set jinja2 template path: %s' % path)
+ env = Environment(loader=FileSystemLoader(path), **options)
+ filters = kw.get('filters', None)
+ if filters is not None:
+ for name, f in filters.items():
+ env.filters[name] = f
+ app['__templating__'] = env
+
+async def logger_factory(app, handler):
+ async def logger(request):
+ logging.info('Request: %s %s' % (request.method, request.path))
+ # await asyncio.sleep(0.3)
+ return (await handler(request))
+ return logger
+
+async def data_factory(app, handler):
+ async def parse_data(request):
+ if request.method == 'POST':
+ if request.content_type.startswith('application/json'):
+ request.__data__ = await request.json()
+ logging.info('request json: %s' % str(request.__data__))
+ elif request.content_type.startswith('application/x-www-form-urlencoded'):
+ request.__data__ = await request.post()
+ logging.info('request form: %s' % str(request.__data__))
+ return (await handler(request))
+ return parse_data
+
+async def response_factory(app, handler):
+ async def response(request):
+ logging.info('Response handler...')
+ r = await handler(request)
+ if isinstance(r, web.StreamResponse):
+ return r
+ if isinstance(r, bytes):
+ resp = web.Response(body=r)
+ resp.content_type = 'application/octet-stream'
+ return resp
+ if isinstance(r, str):
+ if r.startswith('redirect:'):
+ return web.HTTPFound(r[9:])
+ resp = web.Response(body=r.encode('utf-8'))
+ resp.content_type = 'text/html;charset=utf-8'
+ return resp
+ if isinstance(r, dict):
+ template = r.get('__template__')
+ if template is None:
+ resp = web.Response(body=json.dumps(r, ensure_ascii=False, default=lambda o: o.__dict__).encode('utf-8'))
+ resp.content_type = 'application/json;charset=utf-8'
+ return resp
+ else:
+ resp = web.Response(body=app['__templating__'].get_template(template).render(**r).encode('utf-8'))
+ resp.content_type = 'text/html;charset=utf-8'
+ return resp
+ if isinstance(r, int) and r >= 100 and r < 600:
+ return web.Response(r)
+ if isinstance(r, tuple) and len(r) == 2:
+ t, m = r
+ if isinstance(t, int) and t >= 100 and t < 600:
+ return web.Response(t, str(m))
+ # default:
+ resp = web.Response(body=str(r).encode('utf-8'))
+ resp.content_type = 'text/plain;charset=utf-8'
+ return resp
+ return response
+
+def datetime_filter(t):
+ delta = int(time.time() - t)
+ if delta < 60:
+ return u'1分钟前'
+ if delta < 3600:
+ return u'%s分钟前' % (delta // 60)
+ if delta < 86400:
+ return u'%s小时前' % (delta // 3600)
+ if delta < 604800:
+ return u'%s天前' % (delta // 86400)
+ dt = datetime.fromtimestamp(t)
+ return u'%s年%s月%s日' % (dt.year, dt.month, dt.day)
+
+async def init(loop):
+ await orm.create_pool(loop=loop, host='127.0.0.1', port=3306, user='www', password='www', db='awesome')
+ app = web.Application(loop=loop, middlewares=[
+ logger_factory, response_factory
+ ])
+ init_jinja2(app, filters=dict(datetime=datetime_filter))
+ add_routes(app, 'handlers')
+ add_static(app)
+ srv = await loop.create_server(app.make_handler(), '127.0.0.1', 9000)
+ logging.info('server started at http://127.0.0.1:9000...')
+ return srv
+
+loop = asyncio.get_event_loop()
+loop.run_until_complete(init(loop))
+loop.run_forever()

www/config.py

@@ -0,0 +1,56 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+'''
+Configuration
+'''
+
+__author__ = 'Michael Liao'
+
+import config_default
+
+class Dict(dict):
+ '''
+ Simple dict but support access as x.y style.
+ '''
+ def __init__(self, names=(), values=(), **kw):
+ super(Dict, self).__init__(**kw)
+ for k, v in zip(names, values):
+ self[k] = v
+
+ def __getattr__(self, key):
+ try:
+ return self[key]
+ except KeyError:
+ raise AttributeError(r"'Dict' object has no attribute '%s'" % key)
+
+ def __setattr__(self, key, value):
+ self[key] = value
+
+def merge(defaults, override):
+ r = {}
+ for k, v in defaults.items():
+ if k in override:
+ if isinstance(v, dict):
+ r[k] = merge(v, override[k])
+ else:
+ r[k] = override[k]
+ else:
+ r[k] = v
+ return r
+
+def toDict(d):
+ D = Dict()
+ for k, v in d.items():
+ D[k] = toDict(v) if isinstance(v, dict) else v
+ return D
+
+configs = config_default.configs
+
+try:
+ import config_override
+ configs = merge(configs, config_override.configs)
+except ImportError:
+ pass
+
+configs = toDict(configs)

www/config_default.py

@@ -0,0 +1,22 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+'''
+Default configurations.
+'''
+
+__author__ = 'Michael Liao'
+
+configs = {
+ 'debug': True,
+ 'db': {
+ 'host': '127.0.0.1',
+ 'port': 3306,
+ 'user': 'www',
+ 'password': 'www',
+ 'db': 'awesome'
+ },
+ 'session': {
+ 'secret': 'Awesome'
+ }
+}

www/config_override.py

@@ -0,0 +1,14 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+'''
+Override configurations.
+'''
+
+__author__ = 'Michael Liao'
+
+configs = {
+ 'db': {
+ 'host': '127.0.0.1'
+ }
+}