Differences between revisions 2 and 8 (spanning 6 versions)

Celery

Celery is an asynchronous task queue/job queue based on distributed message passing.

http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html

Slackware 14 installation

easy_install celery
pip install celery

Check installation:

   1 python
   2 Python 2.7.3 (default, Jul  3 2012, 19:58:39) 
   3 [GCC 4.7.1] on linux2
   4 Type "help", "copyright", "credits" or "license" for more information.
   5 >>> import celery
   6 >>> celery.__version__
   7 '3.1.7'
   8 >>>

Test app with Redis

Run redis:

   1 $redis-server & 
   2 $redis-cli     
   3 redis 127.0.0.1:6379> quit

App:

   1 from celery import Celery
   2 
   3 app = Celery('tasks', broker='redis://localhost')
   4 app.conf.update(CELERY_RESULT_BACKEND="redis://")
   5 
   6 @app.task
   7 def add(x, y):
   8     return x + y

   1 $celery -A celeryTest worker --loglevel=info

Run task

   1 $ python
   2 Python 2.7.3 (default, Jul  3 2012, 19:58:39) 
   3 [GCC 4.7.1] on linux2
   4 Type "help", "copyright", "credits" or "license" for more information.
   5 >>> from celeryTest import add
   6 >>> xx=add.delay(3,3)
   7 >>> xx.ready()
   8 True
   9 >>> print(xx.result)
  10 6

-  ⇤ ← Revision 2 as of 2014-01-08 17:42:08 → 
  Size: 688
  Editor: bl13-13-184
  Comment:
+   ← Revision 8 as of 2017-03-10 18:26:08 → ⇥
  Size: 1271
  Editor: localhost
  Comment:
-Deletions are marked like this.
+Additions are marked like this.
 Line 1:
+## page was renamed from Celery
-Line 8:
+Line 9:
+ * pip install celery
-Line 22:
+Line 24:
+Run redis:
{{{#!highlight bash
$redis-server & 
$redis-cli     
redis 127.0.0.1:6379> quit
}}}

App:
-Line 26:
+Line 36:
+app.conf.update(CELERY_RESULT_BACKEND="redis://")
-Line 31:
+Line 42:
+{{{#!highlight bash
$celery -A celeryTest worker --loglevel=info
}}}

Run task
{{{#!highlight bash
$ python
Python 2.7.3 (default, Jul  3 2012, 19:58:39) 
[GCC 4.7.1] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> from celeryTest import add
>>> xx=add.delay(3,3)
>>> xx.ready()
True
>>> print(xx.result)
6
}}}