Django 비동기 및 정시 작업 관련 설정

.\redis-server.exe redis.windows.conf   (windows )

celery                             3.1.26.post2
celery-with-redis                  3.0

# redis    
BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Asia/Shanghai'

from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app

__all__ = ['celery_app']

from __future__ import absolute_import
import os
from celery import Celery
from django.conf import settings

# set the default Django settings module for the 'celery_proj' program.
#             
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'Data_forwarding.settings')
app = Celery('forwarding')
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)


@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

├─Data_forwarding
│  │  celery.py
│  │  settings.py
│  │  urls.py
│  │  wsgi.py
│  │  __init__.py 
│          
├─forwarding
│  │  admin.py
│  │  apps.py
│  │  models.py
│  │  tasks.py
│  │  tests.py
│  │  views.py
│  │  __init__.py
│          
├─static
│      __init__.py
│      
└─templates

from celery import task

@task
def your_task():
"""
      
"""

your_task.delay()

# celery -A       （  APP ） worker -l info
celery -A Data_forwarding worker -l info

E:\PycharmProjects\Data_forwarding>celery -A Data_forwarding worker -l info

 -------------- celery@ihona-PC v3.1.26.post2 (Cipater)
---- **** -----
--- * ***  * -- Windows-10-10.0.17134-SP0
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app:         forwarding:0x2d8cff9f4a8
- ** ---------- .> transport:   redis://localhost:6379//
- ** ---------- .> results:     redis://localhost:6379/
- *** --- * --- .> concurrency: 8 (prefork)
-- ******* ----
--- ***** ----- [queues]
 -------------- .> celery           exchange=celery(direct) key=celery


[tasks]
  . Data_forwarding.celery.debug_task
  . forwarding.tasks.save_xml

pip install APScheduler==2.1.2

from apscheduler.scheduler import Scheduler
from forwarding import views
#     
sched = Scheduler()
#         
@sched.interval_schedule(seconds=10)
def send():
    # views.    
    views.send_status0()

sched.start()