Erstellen von Pipeline-Tasks - Cloud

Nutzungshandbuch für Talend Management Console
Version
Cloud
Language
Deutsch
Product
Talend Cloud
Module
Talend Management Console
Content
Administration und Überwachung > Verwaltung von Benutzern
Administration und Überwachung > Verwaltung von Projekten
Implementierung > Implementierung > Pipeline-Ausführung
Implementierung > Implementierung > Task-Ausführung
Implementierung > Planung > Task-Planung
Last publication date
2024-04-15
Bei Pipeline-Tasks handelt es sich um ausführbare Integrationsprozesse, die ein in Talend Cloud Pipeline Designer veröffentlichtes Pipeline-Artefakt enthalten.

Vorbereitungen

  • Sie benötigen die Berechtigung Author (Autor) für den Arbeitsbereich, in dem sich die Task befindet, um eine Pipeline-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

  1. Öffnen Sie die Seite Management.
  2. Gehen Sie zur Registerkarte Tasks.
  3. Wählen Sie eine Umgebung und einen Arbeitsbereich über die Facettensuche am oberen Seitenrand aus.
  4. Klicken Sie auf Add task (Task hinzufügen).
  5. Wählen Sie im Schritt Artifact (Artefakt) den Artefakt-Typ Pipeline aus.
  6. Wählen Sie das auszuführende Artefakt in der Dropdown-Liste aus.
    Die Details und eine Beschreibung des Artefakts werden angezeigt.
  7. Wählen Sie die Version des in der Task zu verwendenden Artefakts aus.
    Die Details und eine Beschreibung des Artefakts werden automatisch entsprechend aktualisiert.
  8. Wählen Sie den Arbeitsbereich für die Task aus.
  9. 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.
    Anmerkung: Tasks müssen innerhalb eines Arbeitsbereichs jeweils einen eindeutigen Namen aufweisen.
  10. 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.
  11. Klicken Sie auf Continue (Weiter).
  12. Optional: Geben Sie im Schritt Parameters (Parameter) neue Werte ein und klicken Sie dann auf Continue (Weiter).
    Sie können Kontextvariablen, die Sie in Ihrer Pipeline konfiguriert haben, vor deren Veröffentlichung in Talend Cloud Pipeline Designer überschreiben.
  13. Wählen Sie im Schritt Processing die Engine in der Dropdown-Liste Engine aus, auf der die Task ausgeführt werden soll.
    • Cloud Engine for Design
    • Vordefinierte Remote Engine Gen2
  14. Wählen Sie ein Run Profile (Ausführungsprofil) für die Ausführung aus.
  15. Klicken Sie auf Continue (Fortfahren).
  16. Wählen Sie im Schritt Schedule (Zeitplan) die Ausführungshäufigkeit aus.
    Sie können einen oder mehrere Trigger hinzufügen, um die Task zu planen, oder Sie starten die Task manuell ohne Trigger.
    Weitere Informationen finden Sie unter „Planen von Pipeline-Tasks“.
  17. 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.

Beispiel