revised to accomodate celery development version and changed to simple example

Author: 1xch

README

@@ -0,0 +1,14 @@
+A simple example for the latest version of Celery (2.6.0rc4 as of this example)
+
+
+In your project directory start celery: 
+
+python tasks.py worker --loglevel=debug
+
+then start the application:
+
+python app.py
+
+<optional> then run the testing script
+
+python outside_test.py 

app.py

@@ -3,30 +3,12 @@
 from flask import Flask, Blueprint, abort, jsonify, request, session
 import settings
 from modules import myapi
-from flask.ext.celery import Celery
-
+from celery import Celery
+from tasks import add
 
 app = Flask(__name__)
 app.config.from_object(settings)
 
-
-app.register_blueprint(myapi.blueprint)
-
-def register_api(view, endpoint, url, pk ='id', pk_type='int'):
-    view_func = view.as_view(endpoint)
-    app.add_url_rule(url, defaults={pk: None}, view_func=view_func, methods=['GET',])
-    app.add_url_rule(url, view_func=view_func, methods=['POST',])
-    app.add_url_rule('{0}<{1}:{2}>'.format(url, pk_type, pk), view_func=view_func,
-                     methods=['GET', 'PUT', 'DELETE'])
-
-register_api(myapi.MyAPI, 'my_api', '/my_api/', 'resource_tag', pk_type='string')
-
-celery = Celery(app)
-
-@celery.task(name="myapp.add")
-def add(x, y):
-    return x + y
-
 @app.route("/test")
 def hello_world(x=16, y=16):
     x = int(request.args.get("x", x))

celeryconfig.py

@@ -0,0 +1,6 @@
+#celery
+#BROKER_URL = 'redis://localhost:6379/0'
+#CELERY_RESULT_BACKEND = "redis"
+#CELERY_REDIS_HOST = "localhost"
+#CELERY_REDIS_PORT = 6379
+#CELERY_REDIS_DB = 0

manager.py

@@ -0,0 +1,11 @@
+#testing basic celery setup
+import requests
+import random
+
+for i in range(100):
+    p = {'x':random.randrange(1,10000000), 'y':random.randrange(1,1000000000)}
+    r = requests.get('http://localhost:5000/test', params = p)
+    print r.json
+    r2 = requests.get("http://localhost:5000/test/result/{}".format(r.json['goto']) )
+    print r2.json
+

modules/__init__.py

@@ -1,8 +1 @@
-SECRET_KEY = 'hey_now_this_is_no_secret'
-
-#celery
-BROKER_URL = 'redis://localhost:6379/0'
-CELERY_RESULT_BACKEND = "redis"
-CELERY_REDIS_HOST = "localhost"
-CELERY_REDIS_PORT = 6379
-CELERY_REDIS_DB = 0
+SECRET_KEY = 'not_a_secret'

modules/myapi.py

@@ -0,0 +1,12 @@
+from celery import Celery
+
+celery = Celery("tasks",
+                broker='redis://localhost:6379/0',
+                backend='redis')
+
+@celery.task(name="tasks.add")
+def add(x, y):
+    return x + y
+
+if __name__ == "__main__":
+    celery.start()