Erstellen von Job-Tasks

Bei Job-Tasks handelt es sich um ausführbare Integrationsprozesse, die ein in Talend Studio veröffentlichtes Job-Artefakt enthalten.

Wenn in Talend Studio Kontexte für dieses Job-Artefakt definiert wurden, wird mit dem Job-Artefakt automatisch der Standardkontext veröffentlicht. Empfohlene Regeln für die Definition dieser Kontexte in Talend Studio finden Sie unter „Verwenden von Kontexten und Variablen“.

Die Werte in dieser Kontextkonfiguration werden in den exportierten Dateien aus Sicherheitsgründen gelöscht. Sie müssen die Kontextwerte in Talend Management Console erneut eingeben.

Vorbereitungen

Sie benötigen die Berechtigung Author (Autor) für den Arbeitsbereich, in dem sich die Task befindet, um eine Job-Task erstellen oder bearbeiten und die zugehörige Konfiguration verwalten zu können.
Die Berechtigung Author (Autor) ermöglicht Ihnen bei der Erstellung bzw. Bearbeitung einer Task die Konfiguration von Schritten des Typs Artifact (Artefakt) und Parameters (Parameter).
Um die Konfiguration und Zeitplanung für die Ausführung verwalten zu können, beispielsweise um Engine, Logebene oder Ausführungs-Timeout festzulegen, müssen Sie über die Berechtigung Execute (Ausführen) für den Arbeitsbereich der Task verfügen.
Die Berechtigung Execute (Ausführen) ermöglicht Ihnen bei der Erstellung bzw. Bearbeitung einer Task die Konfiguration von Schritten des Typs Processing und Schedule (Zeitplan).

Prozedur

Öffnen Sie die Seite Management.
Gehen Sie zur Registerkarte Tasks.
Wählen Sie eine Umgebung und einen Arbeitsbereich über die Facettensuche am oberen Seitenrand aus.
Klicken Sie auf Add task (Task hinzufügen).
Wählen Sie im Schritt Artifact (Artefakt) den Artefakt-Typ Job aus.
Wählen Sie das auszuführende Artefakt in der Dropdown-Liste aus.
Die Details und eine Beschreibung des Artefakts werden angezeigt.
Wählen Sie die Version des in der Task zu verwendenden Artefakts aus.

Sie können Always use the latest available artifact version (Immer die neueste verfügbare Artefakt-Version verwenden) auswählen, wenn die Task bei jeder Veröffentlichung einer neuen Version des Artefakts automatisch aktualisiert werden soll. Sie können auch eine bestimmte Version auswählen und sie nach Bedarf manuell aktualisieren.

InformationshinweisAnmerkung: Diese Option überschreibt die Option Update corresponding job task (Zugehörige Job-Task aktualisieren) in Talend Studio.

Die Details und eine Beschreibung des Artefakts werden automatisch entsprechend aktualisiert.
Optional: Aktivieren Sie das Kontrollkästchen Override parameter values with artifact defaults (Parameterwerte mit Artefakt-Werten überschreiben).
Diese Option ist nur verfügbar, wenn Sie Always use the latest available artifact version (Immer die neueste verfügbare Artefakt-Version verwenden) im Feld Artifact version (Artefakt-Version) ausgewählt haben. Bei Auswahl der Option werden bei jeder Veröffentlichung einer neuen Version des Artefakts die in der Task definierten Parameter durch die Artefakt-Standardparameter ersetzt.
Wählen Sie den Arbeitsbereich für die Task aus.
Geben Sie einen Namen für die neue Task ein.
Standardmäßig erhält eine Task den Namen des Artefakts, von dem ausgehend sie erstellt wird.
InformationshinweisAnmerkung: Tasks müssen innerhalb eines Arbeitsbereichs jeweils einen eindeutigen Namen aufweisen.
Optional: Fügen Sie der Task ein Tag hinzu.
1. Wählen Sie ein vorhandenes Tag in der Dropdown-Liste aus.
2. Erstellen Sie ein neues Tag. Geben Sie dazu einen Tag-Namen ein und wählen Sie dann das Tag in der Dropdown-Liste aus.
Klicken Sie auf Continue (Weiter).
Geben Sie im Bereich Parameters (Parameter) den Wert für die Parameter des Jobs ein.
Die Beschreibung der einzelnen Parameter wird unter dem jeweiligen Feld angezeigt.

Wenn in diesem Schritt die Option Show order as in Studio (Reihenfolge aus Studio anzeigen) deaktiviert ist, können Sie nur für diejenigen Parameter Werte festlegen, die Sie in Talend Studio mit dem Präfix parameter_ definiert haben.

InformationshinweisAnmerkung: Verwenden Sie \\ anstelle von \, wenn der Wert als Sonderzeichen interpretiert werden soll, z. B. \t.

Bei der Anzeige in Talend Management Console werden die ersten Buchstaben jedes Worts in den Parameternamen automatisch in Großbuchstaben und Unterstreichungen (_) in Leerzeichen geändert. Beispiel: city_name wird zu City Name.

Dies dient ausschließlich der Anzeige. Wenn Sie in ihren Programmen einen Parameternamen verwenden müssen, z. B. in einem API-Request, verwenden Sie nicht den Anzeigenamen, sondern stattdessen den Namen aus Talend Studio.
Optional: Geben Sie im Bereich Advanced parameters (Erweiterte Parameter) die Werte für die von Ihnen in Talend Studio ohne Präfix definierten Parameter sowie für nicht im Job definierte connection_-Parameter ein. Dieser Bereich ist verfügbar, wenn die Option Show order as in Studio (Reihenfolge aus Studio übernehmen) deaktiviert ist. Andernfalls sind alle Parameter im Schritt Parameters (Parameter) enthalten.

InformationshinweisAnmerkung: Verwenden Sie \\ anstelle von \, wenn der Wert als Sonderzeichen interpretiert werden soll, z. B. \t.
Optional: Wählen Sie im Schritt Connections (Verbindungen) die entsprechende Verbindung aus der Dropdown-Liste aus.
Sie können auch eine neue Verbindung ausgehend von den Parametern erstellen, die bereits im Artefakt definiert sind.
Optional: Wählen Sie im Schritt Resources (Ressourcen) die zutreffende Ressource aus, die in der Task verwendet werden soll.
Wählen Sie im Schritt Processing die Engine bzw. das Engine-Cluster in der Dropdown-Liste Engine aus, auf der bzw. in dem die Task ausgeführt werden soll.
- Cloud
- Cloud Exclusive
- Remote Engine
- Remote Engine-Cluster
Optional: Wählen Sie ein Ausführungsprofil aus.
Sie können ein zuvor erstelltes Ausführungsprofil für die ausgewählte Remote Engine bzw. das Cluster auswählen, um die JVM-Parameter für die Taskauführung festzulegen.

Bei Verwendung einer Remote Engine bzw. eines Clusters wird diese Funktion ab Remote Engine 2.9.1 unterstützt.
Stellen Sie die Log-Ebene ein. Ihre Logs können fünf Ebenen umfassen, aber nicht alle sind als eigenständige Optionen verfügbar.
- Drei Log-Ebenen können direkt in der Dropdown-Liste ausgewählt werden: Info, Warnung und Fehler.
- Die Ebene Debug, die in der Liste nicht verfügbar ist, wird automatisch verwendet, wenn Sie eine fehlgeschlagene Task manuell als Debug-Ausführung starten. Weitere Informationen finden Sie unter „Debugging von Job-Tasks“.
- Die Ebene Nicht behebbar ist nicht als eigenständige Option verfügbar, aber in jede der anderen Log-Ebenen eingeschlossen.
- Ebenenüberlappung.
  - Debug ist die niedrigste Ebene.
    In der Debug-Ausführung sind alle Logs (vom niedrigsten zum höchsten) eingeschlossen: Debug, Info, Warnung, Fehler und Nicht behebbar.
  - Info schließt Logs für Info, Warnung, Fehler und Nicht behebbar, jedoch keine Logs für Debug ein.
  - Fehler ist die höchste der drei Ebenen, die direkt ausgewählt werden können. Diese Ebene schließt nur Logs für Fehler und Nicht behebbar ein.
    Standardmäßig werden Fehler mit dem Status Nicht behebbar als Fehler-Logs angezeigt. Damit sie ausdrücklich als Logs für Nicht behebbar in Talend Management Console angezeigt werden, gewährleisten Sie, dass der Parameter job.log.fatal.level in der Datei <RemoteEngineInstallationDirectory>/etc/org.talend.ipaas.rt.jobserver.client.cfg vorhanden ist und sein Wert true ist.
- Empfohlene Log-Ebene für eine Produktionsumgebung.
  Um den Log-Generierungsprozess nicht zu überlasten, was zu potenziellem Datenverlust und Prozessverzögerungen führt, legen Sie die Log-Ebene für Jobs, die in der Produktion implementiert werden, auf Warnung fest. Diese Ebene schließt Warnung, Fehler und Nicht behebbar ein.
- Wenn Sie Off (Aus) auswählen, werden auf Engine-Seite gar keine Jobausführungs-Logs generiert. Nur die Zusammenfassungs-Logs einer Taskausführung werden generiert und an Talend Management Console gesendet. Diese Logs enthalten eine Zusammenfassung der Taskausführung, z. B. Start und Ende und Erfolgs- oder Fehlerstatus.
  InformationshinweisTipp: Einige Informationen zu Standardausgaben (stdout) und Standardfehlern (stderr) können zwar in eine Datei stdOutErr_.log im Verzeichnis JobServer auf Ihrer Engine geschrieben werden, werden aber nicht an Talend Management Console gesendet.
Optional: Wählen Sie die Option Allow parallel run of this task (Parallele Ausführung dieser Task zulassen) aus, sodass die Task bei Verwendung einer Cloud Engine, von Cloud Exclusive, einer Remote Engine oder eines Clusters parallel ausgeführt werden kann.

Wenn Sie eine Remote Engine zur gleichzeitigen Ausführung identischer Tasks verwenden, wird diese Funktion ab Remote Engine 2.12.0 unterstützt.

Standardmäßig könen auf einer einzelnen Remote Engine drei unterschiedliche oder identische Tasks parallel ausgeführt werden. Weitere Informationen über die entsprechende Konfiguration finden Sie unter Paralleles Ausführen von Tasks auf einer einzelnen Remote Engine.

Bevor Sie diese Option deaktivieren, halten Sie die Task an oder wwarten Sie auf das Ende der Ausführung. Andernfalls ist die parallele Ausführung nach wie vor zulässig.
Optional: Wenn Sie eine Remote Engine oder ein Cluster ausgewählt haben, können Sie Ihren Job als ein anderer Benutzer ausführen. Geben Sie dazu den entsprechenden Benutzernamen im Feld Run as impersonated user (Als impersonifizierter Benutzer ausführen) ein.
Diese Funktion wird nur unterstützt, wenn die Remote Engine unter Unix oder vergleichbaren Umgebungen installiert wurde.

Weitere Informationen zur Benutzerimpersonifizierung finden Sie unter „Konfigurieren der Benutzerimpersonifizierung für Talend Remote Engine“.
Optional: Legen Sie das Ausführungs-Timeout der Task durch Auswahl von Custom (Benutzerdefiniert) und Eingabe eines Werts fest.

Der Standardwert ist 5 Minuten, der Mindestwert ist 1.
Optional: Wählen Sie im Schritt Schedule (Zeitplan) die Ausführungshäufigkeit und nach Bedarf das Trigger-Timeout aus.

Sie können einen oder mehrere Trigger hinzufügen, um die Task zu planen, oder Sie starten die Task manuell ohne Trigger.

Standardmäßig ist der Wert des Trigger-Timeouts mit dem Task-Timeout identisch.
Das Trigger-Timeout überschreibt das Task-Timeout.

Weitere Informationen finden Sie unter „Planen von Job-Tasks“.
Klicken Sie auf Save and close (Speichern und schließen).

Ergebnisse

Die Task kann jetzt in Talend Management Console ausgeführt werden.

Anmerkung:

Es wurde ein exponentielles Backoff-Wiederholungsmuster eingeführt, um die erste und zweite Wiederholung zu beschleunigen (1 Minute bzw. 3 Minuten nach dem ursprünglichen gescheiterten Versuch) und gleichzeitig das globale Verhalten bei maximaler Arbeitslast zu verbessern.

Wenn Sie beispielsweise versuchen, eine bereits aktive Task auszuführen, schlägt die Ausführung fehl. Talend Management Console wiederholt den Ausführungsversuch in schrittweise erhöhten Intervallen, d. h. die erste Wiederholung erfolgt bereits nach Ablauf 1 Minute, die zweite nach 2 Minuten und dann nach 4 und 8 Minuten.

Wenn der vierte Versuch fehlschlägt, erhalten Sie die Fehlermeldung Exceeded the limit of deployment attempts: another instance of the same task was running on the engine at same time (Zulässige Anzahl der Implementierungsversuche überschritten: Eine andere Instanz derselben Task wurde gleichzeitig auf der Engine ausgeführt). Versuchen Sie die Taskausführung zu einem späteren Zeitpunkt erneut.

Troubleshooting: Bei einem Zeitplan mit zu häufiger Taskausführung kann es zu einer parallelen Ausführung derselben Task auf zwei verschiedenen Cloud Engines bzw. in zwei verschiedenen Remote Engine-Clustern kommen. Um dieses Problem zu vermeiden, führen Sie Ihre Task in einer Umgebung aus, der nur eine einzelne Cloud Engine zugewiesen wurde, oder planen Sie die Task auf einer Remote Engine.

Hat diese Seite Ihnen geholfen?

Wenn Sie ein Problem mit dieser Seite oder ihrem Inhalt feststellen, sei es ein Tippfehler, ein ausgelassener Schritt oder ein technischer Fehler, informieren Sie uns bitte!

Geben Sie hier Ihr Feedback ab