2016-12-28 2 views
0

안녕하세요 저는 셀러리와 파이썬에 초보자입니다. 나는 rabbitmq-server를 사용하여 간단한 작업을 만들고있다. 하지만 파이썬에서 셀러리 비트를 사용하여주기적인 작업을 수행하는 방법을 모르겠습니다. 내가 검색하지만 모든 곳에서 나는 장고와 주기적으로 일을한다.장고없는 파이썬을 사용하는 셀러리의 주기적 작업

은 내가 tasks.py으로이 코드를 사용 : 셀러리 수입 셀러리 에서 시간 가져 오기의 strftime에서

app = Celery('tasks',broker='pyamqp://[email protected]//') 

@app.task 
def show_time(): 
    return strftime('%Y-%m-%d %H:%M:%S') 

run_task.py :

from tasks import show_time 
show_time.delay() 

감사를 사용하면 시간.

답변

0

마지막으로 좀 더 간결 검색 후 내가 찾은 솔루션

from celery import Celery 
from kombu import Queue, Exchange 



class Config(object): 
    CELERY_QUEUES = (
     Queue(
      'try', 
      exchange=Exchange('try'), 
      routing_key='try', 
     ), 
    ) 
celery =Celery('tasks',broker='pyamqp://[email protected]//') 

celery.config_from_object(Config) 


celery.conf.beat_schedule = { 
    'planner': { 
     'task': 'task_planner.some_task', 
     'schedule': 5.0, 
    }, 
} 


@celery.task(queue='try') 
def some_task(): 
    print('Hooray') 

실행 명령을 셀러리 -A의 task_planner 노동자 -l 정보 -B

관련 문제