Kann ich Sellerie für jede Sekunde verwenden?

Question

Ich leite jede Sekunde, und es scheint, Sellerie führt nicht wirklich jede Aufgabe aus.

Ich denke, Sellerie könnte ein guter Scheduler für jede 1 Minute Aufgabe sein, aber möglicherweise nicht für jede zweite Aufgabe geeignet.

Hier ist das Bild, das wird zeigen, was ich

Ich verwende die folgenden Optionen

 'schedule': 1.0, 
    'args': [], 
    'options': { 
     'expires': 3 
    } 

Und ich bin mit Sellerie 4.0.0

Answer 1

bedeuten Ja , Sellerie behandelt tatsächlich Zeiten so niedrig wie 1 Sekunde und möglicherweise niedriger, da es einen Schwimmer benötigt. Siehe diesen Eintrag von periodischen Aufgaben in der Dokumentation http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html:

from celery import Celery 
from celery.schedules import crontab 

app = Celery() 

@app.on_after_configure.connect 
def setup_periodic_tasks(sender, **kwargs): 
    # Calls test('hello') every 10 seconds. 
    sender.add_periodic_task(10.0, test.s('hello'), name='add every 10') 

    # Calls test('world') every 30 seconds 
    sender.add_periodic_task(30.0, test.s('world'), expires=10) 

    # Executes every Monday morning at 7:30 a.m. 
    sender.add_periodic_task(
     crontab(hour=7, minute=30, day_of_week=1), 
     test.s('Happy Mondays!'), 
    ) 

@app.task 
def test(arg): 
    print(arg) 

Ein besseren geschriebenes Beispiel 1/3 den Weg nach unten https://github.com/celery/celery/issues/3589 gefunden werden kann:

# file: tasks.py 
from celery import Celery 

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

@celery.task 
def add(x, y): 
    return x + y 


@celery.on_after_configure.connect 
def add_periodic(**kwargs): 
    celery.add_periodic_task(10.0, add.s(2,3), name='add every 10') 

sender So ist der tatsächliche Sellerie-Broker, dh app = Celery()