django 項目中的設(shè)置（proj代表項目目錄）

proj ?

settings.py?

CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672/' CELERY_ACCEPT_CONTENT = ['json'] CELERY_RESULT_BACKEND = 'db+sqlite:///results.sqlite' CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json'

proj

__init__.py

from __future__ import absolute_import, unicode_literals# This will make sure the app is always imported when # Django starts so that shared_task will use this app. from .celery import app as celery_app__all__ = ['celery_app']

proj

__celery.py

from __future__ import absolute_import, unicode_literals import os from celery import Celery# set the default Django settings module for the 'celery' program.os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')app = Celery('proj')# Using a string here means the worker don't have to serialize # the configuration object to child processes.# - namespace='CELERY' means all celery-related configuration keys# should have a `CELERY_` prefix.app.config_from_object('django.conf:settings', namespace='CELERY')# Load task modules from all registered Django app configs.app.autodiscover_tasks()@app.task(bind=True) def debug_task(self):print('Request: {0!r}'.format(self.request))

app

tasks.py

from __future__ import absolute_import, unicode_literals from celery import shared_task@shared_task def function(): pass

開啟命令

## rabbitmq service rabbitmq-server start ## celery celery -A OldboyCRM worker -l info (在OLDBOYCRM目錄內(nèi)) ## CRM python manage.py runserver (在OLDBOYCRM目錄內(nèi))

?

轉(zhuǎn)載于:https://www.cnblogs.com/CN-S/p/6274255.html

總結(jié)

以上是生活随笔為你收集整理的django+celery+rabitmq的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。