使用蟒蛇沒有Django的芹菜定期任務

你好，我是芹菜和蟒蛇的新手。我正在使用rabbitmq-server創建一個簡單的任務。但我不知道如何實現使用芹菜在python節拍的定期任務。我搜索，但每一個地方，我與Django的定期任務。使用蟒蛇沒有Django的芹菜定期任務

我用這個代碼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()

感謝您的時間。

來源

2016-12-28 Manish Yadav

最後經過一些更簡潔的搜索我已經找到解決方案

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

來源

2016-12-28 09:36:40

使用蟒蛇沒有Django的芹菜定期任務

回答

相關問題