Job Scheduler     Erste Seite

  XML     API     Register

Job_chain  –  Jobkette zur Auftragsverarbeitung

Beispiel  

Job_chain my_job_chain = spooler.create_job_chain();
my_job_chain.set_name( "Jobkette" );
my_job_chain.add_job( "job_100", 100,  200, 999 );
my_job_chain.add_job( "job_200", 200, 1000, 999 );
my_job_chain.add_end_state(  999 );
my_job_chain.add_end_state( 1000 );
spooler.add_job_chain( my_job_chain );

Eine Jobkette (Job_chain) ist eine Kette von Jobs (Jobkettenknoten oder Stellen). Diese Kette wird von Aufträgen (Order) durchlaufen.

Jeder Stelle in der Jobkette ist ein Zustand und ein Job zugeordnet. Wenn ein Auftrag der Jobkette hinzugefügt wird, setzt der Scheduler ihn an die seinem Zustand entsprechende Stelle. Der dieser Stelle zugeordnete Job führt den Auftrag aus.

Jede Stelle hat außerdem einen Folgezustand und einen Fehlerzustand. Nach der Verarbeitung eines Auftrags durch einen Jobschritt ändert der Scheduler den Zustand des Auftrags. Wenn der Jobschritt (spooler_process) true liefert, stellt der Scheduler den Folgezustand, sonst den Fehlerzustand ein. Der Auftrag rutscht damit an eine andere Stelle der Jobkette, die dem neuen Zustand zugeordnet ist. Das gilt nicht, wenn der Zustand während der Ausführung mit Order.state verändert worden ist.

Sie erzeugen eine Jobkette mit Spooler.create_job_chain(), füllen sie mit Job_chain.add_job() und Job_chain.add_end_state() und machen sie schließlich mit Spooler.add_job_chain() bekannt.

Jeder Knoten ist eindeutig einem Zustand zugeordnet. Für jeden Zustand muss genau einmal Job_chain.add_job() oder Job_chain.add_end_state() aufgerufen werden.

add_end_state

Diesem Knoten ist kein Job zugeordnet. Ein Auftrag, der einen Endknoten erreicht, hat die Jobkette durchlaufen und wird vom Scheduler aus ihr entfernt.

Parameter

add_job

Parameter

add_or_replace_order

Hat die Jobkette bereits einen Auftrag mit gleicher Kennung, dann wird dieser ersetzt. Genauer: Er wird aus der Jobkette entfernt, und der neue Auftrag wird hinzugefügt.

Solange eine Task den vorhandenen Auftrag ausführt, sind im Scheduler zwei Aufträge mit gleicher Kennung vorhanden. Allerdings ist der vorhandene Auftrag aus der Jobkette und aus der Datenbank bereits entfernt. Er ist nur noch für die Task nutzbar und verschwindet nach der Ausführung.

In diesem Fall wartet der Scheduler die Ausführung des neuen Auftrags ab, bis die Ausführung des alten Auftrags beendet ist.

Siehe Job_chain.add_order() und Order.remove_from_job_chain()

Parameter

add_order

Wenn der Auftrag in einer anderen Jobkette enthalten ist, entfernt der Scheduler ihn daraus.

Der Auftrag wird in die Auftragswarteschlange des Jobs, der seinem Zustand entspricht, gemäß seiner Priorität eingeordnet.

Die Jobkette mit muss <job_chain> oder Spooler.add_job_chain() dem Scheduler bekannt gemacht worden sein.

Wenn die Jobkette bereits einen Auftrag mit gleicher Order.id enthält, wird eine Exception mit Fehlercode SCHEDULER-186 geliefert. Siehe aber Job_chain.add_or_replace_order().

Parameter

Rückgabe

name

Beispiel  

Job_chain job_chain = spooler.create_job_chain();
job_chain.set_name( "Jobkette" );

Parameter

node

Parameter

Rückgabe

order_count

order_queue

Liefert die Auftragswarteschlange des Jobs, der dem angegebenen Zustand zugeordnet ist.

Parameter

Rückgabe

orders_recoverable

Siehe <job_chain orders_recoverable="…">.

Parameter

remove

Wenn gerade Aufträge der Jobkette verarbeitet werden (in spooler_process()), dann entfernt der Scheduler die Jobkette, sobald der letzte Auftrag verarbeitet worden ist.

Die Aufträge bleiben in der Datenbank erhalten. Wenn später eine Jobkette mit gleichen Namen hinzugefügt wird (Spooler.add_job_chain()), dann lädt der Scheduler diese Aufträge erneut. Die Zustände der Aufträge müssen in der erneuerten Jobkette vorhanden sein.

Meldungen

title

Siehe <job_chain title="…">.

Parameter

Software- und Organisations-Service GmbH

Zuletzt geändert von Joacim Zschimmer, 2008-04-29