mmautner · October 22, 2019 18:09 · May 29, 2014 · May 29, 2014 · May 29, 2014
diff --git a/test.py b/test.py
@@ -0,0 +1,5 @@
+import requests
+# first time is uncached:
+print requests.get('http://localhost:5000/api/person').json()
+# second time is cached:
+print requests.get('http://localhost:5000/api/person').json()
diff --git a/app.py b/app.py
@@ -23,21 +23,21 @@ class Person(db.Model):
 def get_cache_key():
     return hashlib.md5(request.path + request.query_string).hexdigest()
 
-def some_preprocessor(**kwargs):
+def cache_preprocessor(**kwargs):
     key = get_cache_key()
     if cache.get(key):
         print 'returning cached result'
         raise ProcessingException(description=cache.get(key), code=200)
 
-def some_postprocessor(result, **kwargs):
+def cache_postprocessor(result, **kwargs):
     cache.set(get_cache_key(), json.dumps(result))
     print 'result cached.'
 
 
 manager = flask.ext.restless.APIManager(app, flask_sqlalchemy_db=db)
 manager.create_api(Person,
                    methods=['GET'],
-                   preprocessors={'GET_MANY': [some_preprocessor]},
-                   postprocessors={'GET_MANY': [some_postprocessor]})
+                   preprocessors={'GET_MANY': [cache_preprocessor]},
+                   postprocessors={'GET_MANY': [cache_postprocessor]})
 
 app.run()
diff --git a/app.py b/app.py
@@ -0,0 +1,43 @@
+import json
+import hashlib
+import flask
+import flask.ext.sqlalchemy
+import flask.ext.restless
+from flask.ext.restless import ProcessingException
+
+app = flask.Flask(__name__)
+app.config['DEBUG'] = True
+app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:////tmp/test.db'
+db = flask.ext.sqlalchemy.SQLAlchemy(app)
+
+# using memcached:
+from werkzeug.contrib.cache import MemcachedCache
+cache = MemcachedCache(['127.0.0.1:11211'])
+
+class Person(db.Model):
+    id = db.Column(db.Integer, primary_key=True)
+
+db.create_all()
+from flask import request
+
+def get_cache_key():
+    return hashlib.md5(request.path + request.query_string).hexdigest()
+
+def some_preprocessor(**kwargs):
+    key = get_cache_key()
+    if cache.get(key):
+        print 'returning cached result'
+        raise ProcessingException(description=cache.get(key), code=200)
+
+def some_postprocessor(result, **kwargs):
+    cache.set(get_cache_key(), json.dumps(result))
+    print 'result cached.'
+
+
+manager = flask.ext.restless.APIManager(app, flask_sqlalchemy_db=db)
+manager.create_api(Person,
+                   methods=['GET'],
+                   preprocessors={'GET_MANY': [some_preprocessor]},
+                   postprocessors={'GET_MANY': [some_postprocessor]})
+
+app.run()