· 7 years ago · Dec 03, 2018, 06:20 AM
1- django_celery/
2 - my_app/
3 - __init__.py
4 - task.py
5 - proj/
6 - __Init__.py
7 - celery.py
8 - settings.py
9 - manage.py
10
11from __future__ import absolute_import, unicode_literals
12from .celery import app as celery_app
13
14__all__ = ('celery_app',)
15
16from __future__ import absolute_import,unicode_literals
17import os
18from celery import Celery
19from django.conf import settings
20from django_celery_beat.models import PeriodicTasks
21
22os.environ.setdefault('DJANGO_SETTINGS_MODULE','proj.settings')
23app = Celery('proj')
24
25app.config_from_object('django.conf:settings')
26app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
27
28import os
29os.urandom(24)
30
31SECRET_KEY = os.urandom(24)
32
33BROKER_URL = 'redis://localhost:6379/0'
34CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
35CELERY_ACCEPT_CONTENT = ['application/json']
36CELERY_RESULT_SERIALIZER = 'json'
37CELERY_TIMEZONE = 'Asia/Seoul'
38
39CELERY_BEAT_SCHEDULE = {
40 'task-number-one': {
41 'task': 'my_app.tasks.add',
42 'schedule': 10,
43 'args': (10,5)
44 },
45}
46INSTALLED_APPS = (
47 'django_celery_beat',
48)
49
50from __future__ import absolute_import,unicode_literals
51from celery import shared_task,task
52
53@task
54def add(x, y):
55 return x + y