parent
8a4d151917
commit
a9a3c244b1
2 changed files with 24 additions and 0 deletions
@ -0,0 +1,21 @@ |
|||||||
|
import os |
||||||
|
from celery import Celery |
||||||
|
|
||||||
|
# set the default Django settings module for the 'celery' program. |
||||||
|
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings') |
||||||
|
|
||||||
|
app = Celery('project') |
||||||
|
|
||||||
|
# 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('project.celery_settings') |
||||||
|
|
||||||
|
# Load task modules from all registered Django app configs. |
||||||
|
app.autodiscover_tasks() |
||||||
|
|
||||||
|
|
||||||
|
@app.task(bind=True) |
||||||
|
def debug_task(self): |
||||||
|
return f'Request: {self.request}' |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
broker_url = 'redis://redis:6379/0' |
||||||
|
result_backend = 'redis://redis:6379/1' |
||||||
|
task_serializer = 'json' |
||||||
Loading…
Reference in new issue