2012-12-04 12 views
8

Mam skonfigurować seler, który wykorzystuje dwa różne serwery do przetwarzania zadań. Próbuję znaleźć najlepszy sposób dopasowania serwera, na którym zostało wykonane zadanie. Przeglądałem dokumenty i nie widziałem niczego na temat pobierania nazwy hosta z AsyncResult.Seler AsyncResult uzyskać nazwę hosta

Wszelkie uwagi w tej sprawie są mile widziane. Inną opcją, o której myślałem, było po prostu umieszczenie nazwy hosta w każdej konfiguracji selera, chociaż ta metoda nie jest pożądana, ponieważ jest jeszcze jedna rzecz do zapamiętania.

Odpowiedz

5

Możliwe obejście wraca nazwę hosta z wartości zwracanej zadanie

from celery import current_task 

@celery.task 
def hello(x, y): 
    return dict(hostname=current_task.request.hostname, result='hello') 
+0

Dziękuję za odpowiedź. Jest to podejście, które wykorzystałem. Zapomniałem zaktualizować ten wpis. Główną kwestią, na którą zwróciłem uwagę, jest to, że uważam, że nazwa hosta jest wartościową informacją, którą należy podać w każdej odpowiedzi. – user1595702