Trigger verwenden

Auf dieser Seite wird beschrieben, wie Sie einen Trigger für Ihre Cloud Data Fusion-Pipeline erstellen und verwenden. Sie erstellen einen Trigger für eine Datenpipeline, die als Downstream-Pipeline bezeichnet wird, um sie am Ende einer anderen Pipeline auszuführen, der sogenannten Upstream-Pipeline. Beim Erstellen eines Triggers können Sie auswählen, wann die nachgelagerte Pipeline ausgeführt wird, also wenn die vorgelagerte Pipeline erfolgreich ausgeführt wird, fehlschlägt, beendet oder beendet wird.

Trigger sind für Folgendes hilfreich:

  • Daten bereinigen und für mehrere nachgelagerte Pipelines verfügbar machen.
  • Informationen wie Laufzeitargumente und Plug-in-Konfigurationen zwischen Pipelines teilen Dieser Vorgang wird als Nutzlastkonfiguration bezeichnet.
  • Eine Reihe dynamischer Pipelines, die mit den Daten der Stunde/Tag/Woche/Monat ausgeführt werden können, statt einer statischen Pipeline, die für jede Ausführung aktualisiert werden muss.

Hinweis

Stellen Sie in Pipeline Studio die Pipelines bereit, die Ihre vor- und nachgelagerten Pipelines sind.

(Optional) Laufzeitargumente für die vorgelagerte Pipeline festlegen

Wenn Sie die Nutzlastkonfiguration als Laufzeitargumente übergeben möchten, legen Sie die Laufzeitargumente für die vorgelagerte Pipeline fest:

  1. Rufen Sie die Seite Liste auf. Klicken Sie auf dem Tab Bereitgestellt auf den Namen der vorgelagerten Pipeline. Die Ansicht "Deploy" (Bereitstellen) für diese Pipeline wird angezeigt.

  2. Klicken Sie auf den Pfeil rechts neben der Schaltfläche Ausführen.

  3. Klicken Sie auf die Schaltfläche + und geben Sie den Schlüssel und den Wert für Ihr Laufzeitargument ein.

  4. Klicken Sie auf Speichern.

Eingehenden Trigger für eine nachgelagerte Pipeline erstellen

Erstellen Sie einen Trigger für die nachgelagerte Pipeline, damit er nach Abschluss der vorgelagerten Pipeline ausgeführt wird.

  1. Rufen Sie die Seite Liste auf. Klicken Sie auf dem Tab Bereitgestellt auf den Namen der nachgelagerten Pipeline. Die Ansicht "Deploy" (Bereitstellen) für diese Pipeline wird angezeigt.

  2. Klicken Sie in der Mitte der Seite auf Eingehende Trigger. Eine Liste der verfügbaren Pipelines wird angezeigt.

  3. Klicken Sie auf die vorgelagerte Pipeline. Wählen Sie einen oder mehrere Status der abgeschlossenen Streamingpipeline (Succees, Fails oder Stops) als Bedingung für den Zeitraum aus, für den sollte die nachgelagerte Pipeline ausgeführt werden.

  4. Wenn die vorgelagerte Pipeline Informationen freigebenNutzlastkonfiguration ) mit der nachgelagerten Pipeline klickenTriggerkonfiguration und folgen Sie der AnleitungNutzlastkonfiguration als Laufzeitargumente übergeben auf. Klicken Sie andernfalls auf Trigger aktivieren.

Nutzlastkonfiguration als Laufzeitargumente übergeben

Die Nutzlastkonfiguration ermöglicht die Freigabe von Informationen aus der vorgelagerten Pipeline für die nachgelagerte Pipeline. Diese Informationen können beispielsweise das Ausgabeverzeichnis, das Datenformat oder der Tag sein, an dem die Pipeline ausgeführt wurde. Diese Informationen werden dann von der nachgelagerten Pipeline für Entscheidungen verwendet, um beispielsweise das richtige Dataset für den Lesen zu ermitteln.

Um Informationen aus der vorgelagerten Pipeline an die nachgelagerte Pipeline zu übergeben, legen Sie die Laufzeitargumente der nachgelagerten Pipeline mit den Werten der Laufzeitargumente oder der Konfiguration eines Plug-ins in der vorgelagerten Pipeline fest.

Bei der Ausführung der nachgelagerten Pipeline (ausgelöst) wird die Nutzlastkonfiguration mithilfe der Laufzeitargumente der spezifischen Ausführung der vorgelagerten Pipeline festgelegt.

So übergeben Sie die Nutzlastkonfiguration als Laufzeitargumente:

  1. Weiter da weitermachen, wo Sie im Abschnitt Eingehenden Trigger erstellen aufgehört haben, nachdem Sie auf Triggerkonfiguration geklickt haben, und alle Laufzeitargumente, die Sie bereits festgelegt haben wird für Ihre vorgelagerte Pipeline angezeigt. Wählen Sie die Laufzeitargumente aus, die Sie von der vorgelagerten Pipeline an die nachgelagerte Pipeline übergeben möchten, wenn dieser Trigger ausgeführt wird.

  2. Klicken Sie auf den Tab Plugin config (Plug-in-Konfiguration), um zu sehen, was von Ihrer vorgelagerten Pipeline an die nachgelagerte Pipeline übergeben wird, wenn sie ausgelöst wird.

  3. Klicken Sie auf Trigger konfigurieren und aktivieren.

Downstream-Pipeline-Trigger testen

So testen Sie den Trigger:

  1. Rufen Sie die Seite Liste auf. Klicken Sie auf dem Tab Bereitgestellt auf den Namen der vorgelagerten Pipeline. Die Ansicht "Deploy" (Bereitstellen) für diese Pipeline wird angezeigt.

  2. Klicken Sie auf Ausführen.

  3. Warten Sie, bis die Ausführung der vorgelagerten Pipeline abgeschlossen ist. Wechseln Sie in der Ansicht Liste zur nachgelagerten Pipeline. Sie sollten sie nun als Ergebnis des von Ihnen erstellten Triggers sehen.