celery.py

from __future__ import absolute_import

from celery import Celery

app = Celery('my_project',
             broker='amqp://',
             backend='mongodb://',
             include=['tasks'])

# Optional configuration, see the application user guide.
app.conf.update(
    CELERY_TASK_SERIALIZER="json",
    CELERY_ACCEPT_CONTENT=["json"],
    CELERY_RESULT_SERIALIZER='json'
    # CELERY_TASK_RESULT_EXPIRES=3600,
    # CELERY_MONGODB_BACKEND_SETTINGS={
    #     "host": "localhost",
    #     "port": 27017,
    #     "database": "celery",
    #     "taskmeta_collection": "my_taskmeta_collection",
    # },
)

if __name__ == '__main__':
    app.start()