Festlegen des Pipelinerückgabewerts in Azure Data Factory und Azure Synapse Analytics
GILT FÜR:
Azure Data Factory Azure Synapse Analytics
Tipp
Testen Sie Data Factory in Microsoft Fabric, eine All-in-One-Analyselösung für Unternehmen. Microsoft Fabric deckt alle Aufgaben ab, von der Datenverschiebung bis hin zu Data Science, Echtzeitanalysen, Business Intelligence und Berichterstellung. Erfahren Sie, wie Sie kostenlos eine neue Testversion starten!
Im Paradigma „aufrufende Pipeline/untergeordnete Pipeline“ können Sie die Aktivität „Variable festlegen“ verwenden, um Werte aus der untergeordneten Pipeline an die aufrufende Pipeline zurückzugeben. Im folgenden Szenario steht eine untergeordnete Pipeline über die Aktivität „Pipeline ausführen“ zur Verfügung. Der Plan ist, Informationen aus der untergeordneten Pipeline abzurufen und sie dann in der aufrufenden Pipeline zu verwenden.
Führen Sie den Pipelinerückgabewert ein. Hierbei handelt es sich um ein Wörterbuch mit Schlüsselwertpaaren, das die Kommunikation zwischen untergeordneten Pipelines und der übergeordneten Pipeline ermöglicht.
Voraussetzung: Aufrufen einer untergeordneten Pipeline
Als Voraussetzung benötigt Ihr Entwurf eine Aktivität „Pipeline ausführen“, die eine untergeordnete Pipeline aufruft, wobei Auf Abschluss warten für die Aktivität aktiviert sein soll.
Konfigurieren des Pipelinerückgabewerts in der untergeordneten Pipeline
Wir haben die Aktivität „Variable festlegen“ erweitert, um den Pipelinerückgabewert von Systemvariablen einzuschließen. Sie müssen nicht auf Pipelineebene definiert werden (im Gegensatz zu anderen Variablen, die Sie in der Pipeline verwenden).
- Suchen Sie im Bereich mit den Pipelineaktivitäten nach Variable festlegen, und ziehen Sie eine Aktivität des Typs „Variable festlegen“ in den Pipelinebereich.
- Wählen Sie auf der Canvas die Aktivität „Variable festlegen“ aus, falls sie noch nicht ausgewählt ist, und wählen Sie anschließend die Registerkarte Variablen aus, um die Details zu bearbeiten.
- Wählen Sie als Variablentyp die Option Pipelinerückgabewert aus.
- Wählen Sie Neu aus, um ein neues Schlüssel-Wert-Paar hinzuzufügen.
- Die Anzahl der Schlüsselwertpaare, die hinzugefügt werden können, ist nur durch die Größenbeschränkung des zurückgegebenen JSON (4 MB) begrenzt.
Für Werttypen stehen mehrere Optionen zur Verfügung:
| Typname | BESCHREIBUNG |
|---|---|
| String | Ein konstanter Zeichenfolgenwert. Beispiel: „ADF ist großartig“ |
| Ausdruck | Ermöglicht die Bezugnahme auf die Ausgabe früherer Aktivitäten. Sie können hier die Zeichenfolgeninterpolation verwenden, um Inlineausdruckswerte wie "The value is @{guid()}" einzuschließen. |
| Array | Bei diesem Typ wird ein Array von Zeichenfolgenwerten erwartet. Drücken Sie die EINGABETASTE, um Werte im Array zu trennen. |
| Boolean | „true“ oder „false“ |
| NULL | Signalplatzhalterstatus (immer NULL). |
| Int | Ein numerischer ganzzahliger Wert. Beispiel: 42 |
| Gleitkomma | Ein numerischer Wert vom Float-Typ. Beispiel: 2.71828 |
| Objekt | Warnung: Nur für komplizierte Anwendungsfälle. Dieser Typ ermöglicht das Einbetten einer Liste vom Typ „Schlüssel-Wert-Paare“ für den Wert. |
Der Wert des Objekttyps wird wie folgt definiert:
[{"key": "myKey1", "value": {"type": "String", "content": "hello world"}},
{"key": "myKey2", "value": {"type": "String", "content": "hi"}}
]
Abrufen eines Werts in der aufrufenden Pipeline
Der Pipelinerückgabewert der untergeordneten Pipeline wird zur Aktivitätsausgabe der Aktivität „Pipeline ausführen“. Die Informationen können mit @activity('Execute Pipeline1').output.pipelineReturnValue.keyName abgerufen werden. Hierbei handelt es sich um einen uneingeschränkten Anwendungsfall. Sie können z. B. Folgendes verwenden
- Einen ganzzahligen Wert aus der untergeordneten Pipeline, um den Wartezeitraums für eine Warteaktivität zu definieren
- Ein Zeichenfolgenwert, der die URL für die Webaktivität definiert
- Die Nutzdaten eines Ausdruckswerts für eine Skriptaktivität zu Protokollierungszwecken
Bei Verweisen auf die Pipeline-Rückgabewerte gibt es zwei auffällige Zusatzinformationen.
- Beim Typ Objekt können Sie das geschachtelte JSON-Objekt weiter erweitern. Beispiel: @activity('Execute Pipeline1').output.pipelineReturnValue.keyName.nextLevelKey
- Beim Typ Array können Sie den Index in der Liste mit @activity('Execute Pipeline1').output.pipelineReturnValue.keyName[0] angeben. Die Nummer ist nullindiziert, was bedeutet, dass sie mit „0“ beginnt.
Hinweis
Stellen Sie sicher, dass der Schlüsselname (keyName), auf den Sie verweisen, in Ihrer untergeordneten Pipeline vorhanden ist. Der ADF-Ausdrucks-Generator kann die Referenzprüfung nicht für Sie bestätigen. Die Pipeline funktioniert nur, wenn der Schlüssel, auf den verwiesen wird, in den Nutzdaten enthalten ist.
Besondere Überlegungen
Sie können zwar mehrere „Pipeline-Rückgabewert festlegen“-Aktivitäten in eine Pipeline einschließen, doch ist unbedingt sicherzustellen, dass nur eine davon in der Pipeline ausgeführt wird.
Um das zuvor beschriebene Problem aufgrund eines fehlenden Schlüssels bei der Anrufpipeline zu vermeiden, wird empfohlen, für alle Zweige der untergeordneten Pipeline dieselbe Liste von Schlüsseln zu verwenden. Erwägen Sie die Verwendung von NULL-Typen für Schlüssel, die in einer bestimmten Verzweigung über keine Werte verfügen.
Zugehöriger Inhalt
Erfahren Sie mehr über eine verwandte Ablaufsteuerungsaktivität: