使用蟒蛇没有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的芹菜定期任务

回答

相关问题