barebones structure with asynctasks and db

Author: lukasheinrich

MANIFEST.in

@@ -0,0 +1,3 @@
+recursive-include recastfrontend/templates *
+recursive-include recastfrontend/static *
+recursive-include recastfrontend/resources *

recastfrontend/__init__.py

@@ -0,0 +1,30 @@
+import click
+import IPython
+import os
+
+@click.group()
+def admincli():
+  pass
+  
+@admincli.command()
+@click.option('--config','-c')
+def dbshell(config):
+  if config:
+    os.environ['RECASTCONTROLCENTER_CONFIG'] = config
+  from recastfrontend.server import app
+  with app.app_context():
+    from recastfrontend.server import db
+    import recastfrontend.models as models
+    print "models and db modules are available"
+    IPython.embed()
+
+@admincli.command()
+@click.option('--config','-c')
+def create_db(config):
+  if config:
+    os.environ['RECASTCONTROLCENTER_CONFIG'] = config
+  from recastfrontend.server import app
+  with app.app_context():
+    from recastfrontend.server import db
+    db.create_all()
+    click.secho('created database at: {}'.format(db.engine.url), fg = 'green')

recastfrontend/admincli.py

@@ -0,0 +1,5 @@
+from celery import shared_task
+
+@shared_task
+def hello_world():
+  print "hello world"

recastfrontend/asynctasks.py

@@ -0,0 +1,3 @@
+from celery import Celery
+app = Celery('frontendcelery')
+app.config_from_object('recastfrontend.celeryconfig')

recastfrontend/celeryapp.py

@@ -0,0 +1,8 @@
+from recastfrontend.frontendconfig import config as frontendconf
+
+BROKER_URL = 'redis://' + frontendconf['HOSTNAME']
+CELERY_RESULT_BACKEND = "redis"
+CELERY_REDIS_HOST = frontendconf['HOSTNAME']
+CELERY_REDIS_PORT = 6379
+CELERY_REDIS_DB = 0
+CELERY_TRACK_STARTED = True

recastfrontend/celeryconfig.py

@@ -0,0 +1,2 @@
+from flask.ext.sqlalchemy import SQLAlchemy
+db = SQLAlchemy()

recastfrontend/database.py

@@ -0,0 +1,5 @@
+from recastfrontend.frontendconfig import config as frontendconf
+
+DEBUG = True
+SECRET_KEY = 'some_secret'
+SQLALCHEMY_DATABASE_URI = 'sqlite:///'+frontendconf['DBPATH']

recastfrontend/flaskconfig.py

@@ -0,0 +1,14 @@
+import click
+import os
+
+@click.group()
+def frontendcli():
+  pass
+
+@frontendcli.command()
+@click.option('--config','-c')
+def server(config):
+  if config:
+    os.environ['RECASTCONTROLCENTER_CONFIG'] = config
+  from server import app
+  app.run(host='0.0.0.0',port = 5000)

recastfrontend/frontendcli.py

@@ -0,0 +1,16 @@
+import os
+import pkg_resources
+import yaml
+
+def default_config():
+  return yaml.load(open(pkg_resources.resource_filename('recastfrontend','resources/defaultconfig.yaml')))
+
+
+def mk_config():
+  the_config = default_config()
+  if os.environ.has_key('RECASTCONTROLCENTER_CONFIG'):
+    custom_config = yaml.load(open(os.environ['RECASTCONTROLCENTER_CONFIG']))
+    the_config.update(**custom_config)
+  return the_config
+  
+config = mk_config()