flask-celery

by ask

Celery integration for Flask (SINCE CELERY 3.0 THIS IS NO LONGER NEEDED)

200 Stars 35 Forks Last release: Not found BSD 3-Clause "New" or "Revised" License 58 Commits 3 Releases

Available items

No Items, yet!

The developer of this repository has not created any items for sale yet. Need a bug fixed? Help with integration? A different license? Create a request here:

==============================

Flask <-> Celery Integration

:Version: 2.4.3

FROM CELERY 3.0 THIS LIBRARY IS NO LONGER NECESSARY, INSTEAD YOU SHOULD USE THE STANDARD CELERY API

.. _Celery: http://celeryproject.org

Using Flask with Celery

From Celery 3.0 the Flask-Celery integration package is no longer recommended and you should use the standard Celery API instead.

Please read the Celery getting started tutorial::

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

You can easily add Celery to your flask application like this:

myapp.py
::
from celery import Celery

celery = Celery('myapp', broker='amqp://[email protected]//')

@celery.task def add(x, y): return x + y

To start the worker you can then launch the

celery worker
command by pointing to your
celery
app instance::
$ celery -A myapp:celery worker -l info

See the commands help screen for more information::

$ celery help

If you want use the flask configuration as a source for the celery configuration you can do that like this::

celery = Celery('myapp')
celery.conf.add_defaults(app.config)

If you need access to the request inside your task then you can use the test context::

from flask import Flask
from celery import Celery

app = Flask('myapp') celery = Celery('myapp') celery.conf.add_defaults(app.config)

@celery.task def hello(): with app.test_request_context() as request: print('Hello {0!r}.format(request))

We use cookies. If you continue to browse the site, you agree to the use of cookies. For more information on our use of cookies please see our Privacy Policy.