Wie können wir eine neue Aufgabe in Sellerie ohne Stop Sellerie Instanz in Django Sellerie hinzufügen?

Question

@shared_task 
def forgot_email(subject,user_cipher,key_cipher,to): 
    print "comes here in the mail" 
    try: 
     email_content = {'user_cipher':user_cipher,'key_cipher': key_cipher} 
     message = render_to_string('forgot_password.txt',email_content) 
     send_mail(subject, message, settings.EMAIL,to, fail_silently=False) 
     except Exception,e: 
     print "Exception",e 
    except: 
     print 'exp' 

@shared_task 
def multiplesendmail(subject,body,first_name,to): 
    print "comes here in the mail" 
    try: 
     print 'subject',subject,'body',body,'first_name',first_name,'to',to 
     # email_content = {'first_name':first_name,'user_cipher':user_cipher,'key_cipher':key_cipher} 
     # message = render_to_string('email_verification.txt', email_content) 
     send_mail(subject,body,settings.EMAIL,to,fail_silently=False) 
    except Exception,e: 
     print "Exception",e 

Hinweis- Ich möchte eine neue Aufgabe hinzufügen, ohne Sellerie zu stoppen. Ich muss diesen ersten Halt Sellerie und dann

celery -A HealthBrio worker -l info 

Answer 1

Dies ist ein Link für was Sie wollen. Sie können crontab mit der Admin-Oberfläche von django einrichten. Es gibt zwei Möglichkeiten, eine Task zu starten:

Mit dem Scheduler wird die Task in jeder Zeit (zB 10 Sekunden) oder zu jeder bestimmten Zeit (wie crontab) aufgerufen. Vom Code, an der benötigten Stelle und unter den erforderlichen Bedingungen. Start Aufgabe von Scheduler Gehen Sie auf die Admin-Seite unter der Adresse http: // {Host}/admin/djcellery/periodictask/und drücken Sie "Periodische Aufgabe hinzufügen".

Füllen Sie die Felder wie im Screenshot gezeigt und drücken Sie auf Speichern.

Starten periodische Task alle 10 Sekunden

Zur Startzeit statt Zeit zu zeigen, das gleiche tun, wie in den vorhergehenden Fall, aber füllen Crontab (Intervall muss ausgeblendet werden):

Mehr Detail bei http://www.lexev.org/en/2014/django-celery-setup/