セロリの定期的な仕事は、ジャンゴなしでPythonを使用して

Question

こんにちはすべて私はセロリとpython初心者です。私はrabbitmq-serverを使用して簡単なタスクを作成しています。しかし、私はどのようにPythonでセロリのビートを使用して定期的なタスクを達成するための考えがありません。私は検索するが、いつどこで私はdjangoと定期的な仕事を得る。

私はtasks.pyとして、このコードを使用します。時間インポートのstrftimeからセロリのインポートセロリ から

app = Celery('tasks',broker='pyamqp://guest@localhost//') 

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

run_task.py：あなたの時間のために

from tasks import show_time 
show_time.delay() 

感謝。

Answer 1

最終的にいくつかより簡潔な検索後、私が見つけた解決策

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://guest@localhost//') 

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