Периодическая задача в сельдерее с использованием python без django

Question

Привет всем, я новичок в сельдерее и питоне. Я создаю простую задачу с помощью rabbitmq-сервера. Но я понятия не имею, как добиться периодической задачи, используя бинт сельдерея в 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