Celery - Come inviare attività dalla macchina remota?

Abbiamo un server che esegue i lavoratori del sedano e una coda Redis. Le attività sono definite su quel server.
Devo essere in grado di chiamare queste attività da una macchina remota.
So che è stato fatto usando send_task ma non ho ancora capito come? Come si dice a send_task dove si trova la coda? Dove posso passare i parametri di connessione (o qualsiasi altra cosa necessaria)? Ho cercato per ore e tutto quello che posso trovare è questo:Celery - Come inviare attività dalla macchina remota?

from celery.execute import send_task 
send_task('tasks.add')

Bene, questo significa che ho bisogno celery sulla mia macchina chiamata pure. Ma cos'altro ho bisogno di impostare?

fonte

2013-08-25 user1102018

Questo può essere un modo: Creazione di un oggetto Celery e utilizzando send_task da tale oggetto, l'oggetto può avere la configurazione per trovare il broker.

from celery import Celery 
celery = Celery() 
celery.config_from_object('celeryconfig') 
celery.send_task('tasks.add', (2,2))

celeryconfig è un file contenente la configurazione del sedano, ci sono altri modi stabiliti config sull'oggetto sedano.

fonte

2013-10-08 20:36:55

Recentemente ho avuto un problema simile in cui la chiamata send_task era corretta, tuttavia l'attività non è stata trovata dal server. Ho ricevuto un messaggio di errore "Ricevuta attività non registrata di tipo ...". Per risolvere questo, nel tuo decoratore di definizioni di compiti aggiungi l'argomento 'nome'. Esempio può essere trovato [qui] (https://gist.github.com/johnpaulhayes/8403108) – johnpaulhayes

OK, questo è un grande uomo ... ora un vero test. Come si utilizza una richiamata con quella in modo da poter ottenere il valore effettivo restituito dall'attività ?? – chuckjones242

Qualcosa che mi ha buttato fuori per qualche ora era che avevo bisogno di definire quale coda la mia sceneggiatura produceva i "lavori". finito con 'celery.send_task ('tasks.the_remote_task_name', ([argomenti, ...]), queue = 'name_of_queue')' ottenuto da questo [collegamento] (https://www.marshut.net/ipwtin /seguendo-task-da-a-machine-and-running-celery-workers-on-another-machine.html) – lukik

Esistono diversi modi per definire le regole di instradamento, la più generale delle quali è l'oggetto router personalizzato. In tutti i casi, il chiamante fornisce solo un parametro routing_key in send_task, delay o apply_async e il router determina in quale coda inviare l'attività.

fonte

2013-08-26 01:52:56

Grazie, ma questo mi porta di nuovo al punto di partenza. Dove posso definire questa chiave di percorso? Ho bisogno di un file di configurazione sul chiamante? O c'è qualcos'altro che devo configurare prima di chiamare 'send_task'? – user1102018

Gli esempi in http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html#id13 mostrano come creare un file di configurazione e come definire le rotte nel file di configurazione . È necessario il file di configurazione sul computer chiamante poiché il broker è REDIS. (Se stavate usando AMQP, avreste invece la possibilità di definire le regole di routing nel livello Rabbit). –

Il documento che hai menzionato non spiega come dire a send_task di usare redis. Spiega solo come configurare il lavoratore. Facendo ciò, send_task restituisce l'errore "Connessione rifiutata" (almeno per me) – AliBZ

sulla macchina remota, avviare il sedano con broker_url che punta alla macchina su cui si desidera eseguire le attività. Quindi invia semplicemente le attività (se hai code specifiche da inviare, quindi aggiungi le chiavi di routing appropriate).

fonte

2013-12-09 18:52:39

-2

Quello che hai trovato era giusto.

from celery.execute import send_task 

send_task('tasks.add')

Se alcuni argomenti necessari

send_taks('tasks.add', kwargs={'a'=1, 'b'=2})

fonte

2016-09-27 07:37:10 D0neZer0

Celery - Come inviare attività dalla macchina remota?

risposta

Problemi correlati