Basic beaker caching functionality added to the application.
This commit is contained in:
parent
12c340fc07
commit
0533f117a9
@ -25,7 +25,7 @@ from mediagoblin.mg_globals import setup_globals
|
|||||||
from mediagoblin.init.celery import setup_celery_from_config
|
from mediagoblin.init.celery import setup_celery_from_config
|
||||||
from mediagoblin.init import (get_jinja_loader, get_staticdirector,
|
from mediagoblin.init import (get_jinja_loader, get_staticdirector,
|
||||||
setup_global_and_app_config, setup_workbench, setup_database,
|
setup_global_and_app_config, setup_workbench, setup_database,
|
||||||
setup_storage)
|
setup_storage, setup_beaker_cache)
|
||||||
|
|
||||||
|
|
||||||
class MediaGoblinApp(object):
|
class MediaGoblinApp(object):
|
||||||
@ -71,6 +71,9 @@ class MediaGoblinApp(object):
|
|||||||
# set up staticdirector tool
|
# set up staticdirector tool
|
||||||
self.staticdirector = get_staticdirector(app_config)
|
self.staticdirector = get_staticdirector(app_config)
|
||||||
|
|
||||||
|
# set up caching
|
||||||
|
self.cache = setup_beaker_cache()
|
||||||
|
|
||||||
# Setup celery, if appropriate
|
# Setup celery, if appropriate
|
||||||
if setup_celery and not app_config.get('celery_setup_elsewhere'):
|
if setup_celery and not app_config.get('celery_setup_elsewhere'):
|
||||||
if os.environ.get('CELERY_ALWAYS_EAGER'):
|
if os.environ.get('CELERY_ALWAYS_EAGER'):
|
||||||
|
@ -46,6 +46,12 @@ base_url = string(default="/mgoblin_media/")
|
|||||||
base_dir = string(default="%(here)s/user_dev/media/queue")
|
base_dir = string(default="%(here)s/user_dev/media/queue")
|
||||||
|
|
||||||
|
|
||||||
|
[beaker.cache]
|
||||||
|
type = string(default="file")
|
||||||
|
data_dir = string(default="%(here)s/user_dev/beaker/cache/data")
|
||||||
|
lock_dir = string(default="%(here)s/user_dev/beaker/cache/lock")
|
||||||
|
|
||||||
|
|
||||||
[celery]
|
[celery]
|
||||||
# known booleans
|
# known booleans
|
||||||
celery_result_persistent = boolean()
|
celery_result_persistent = boolean()
|
||||||
|
@ -14,7 +14,10 @@
|
|||||||
# You should have received a copy of the GNU Affero General Public License
|
# You should have received a copy of the GNU Affero General Public License
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
from beaker.cache import CacheManager
|
||||||
|
from beaker.util import parse_cache_config_options
|
||||||
import jinja2
|
import jinja2
|
||||||
|
|
||||||
from mediagoblin import staticdirect
|
from mediagoblin import staticdirect
|
||||||
from mediagoblin.init.config import (
|
from mediagoblin.init.config import (
|
||||||
read_mediagoblin_config, generate_validation_report)
|
read_mediagoblin_config, generate_validation_report)
|
||||||
@ -135,3 +138,16 @@ def setup_workbench():
|
|||||||
workbench_manager = WorkbenchManager(app_config['workbench_path'])
|
workbench_manager = WorkbenchManager(app_config['workbench_path'])
|
||||||
|
|
||||||
setup_globals(workbench_manager = workbench_manager)
|
setup_globals(workbench_manager = workbench_manager)
|
||||||
|
|
||||||
|
|
||||||
|
def setup_beaker_cache():
|
||||||
|
"""
|
||||||
|
Setup the Beaker Cache manager.
|
||||||
|
"""
|
||||||
|
cache_config = mg_globals.global_config['beaker.cache']
|
||||||
|
cache_config = dict(
|
||||||
|
[(u'cache.%s' % key, value)
|
||||||
|
for key, value in cache_config.iteritems()])
|
||||||
|
cache = CacheManager(**parse_cache_config_options(cache_config))
|
||||||
|
setup_globals(cache=cache)
|
||||||
|
return cache
|
||||||
|
@ -31,6 +31,9 @@ db_connection = None
|
|||||||
# mongokit.Connection
|
# mongokit.Connection
|
||||||
database = None
|
database = None
|
||||||
|
|
||||||
|
# beaker's cache manager
|
||||||
|
cache = None
|
||||||
|
|
||||||
# should be the same as the
|
# should be the same as the
|
||||||
public_store = None
|
public_store = None
|
||||||
queue_store = None
|
queue_store = None
|
||||||
|
@ -19,5 +19,8 @@ base_url = /mgoblin_media/
|
|||||||
[storage:queuestore]
|
[storage:queuestore]
|
||||||
base_dir = %(here)s/test_user_dev/media/queue
|
base_dir = %(here)s/test_user_dev/media/queue
|
||||||
|
|
||||||
|
[beaker.cache]
|
||||||
|
enabled = false
|
||||||
|
|
||||||
[celery]
|
[celery]
|
||||||
celery_always_eager = true
|
celery_always_eager = true
|
||||||
|
Loading…
x
Reference in New Issue
Block a user