Kursinhalt
Einführung in die Datenverarbeitung mit Azure
Einführung in die Datenverarbeitung mit Azure
Foreach-Aktivität
Die ForEach-Aktivität in Azure Data Factory ist ein leistungsstarkes Werkzeug, das es Ihnen ermöglicht, iterative Operationen durchzuführen, wie z.B. das Verarbeiten mehrerer Dateien oder das Durchlaufen einer Liste von Elementen.
Die Lookup-Aktivität wird oft in Kombination mit der ForEach-Aktivität verwendet, um eine Liste von Elementen, wie Dateinamen oder Tabellennamen, zur Iteration abzurufen. Indem Sie die Lookup-Ausgabe an die ForEach-Aktivität übergeben, können Sie jedes Element in der Sammlung dynamisch verarbeiten, was skalierbare und flexible Workflows in Azure Data Factory ermöglicht.
Wie man die ForEach-Aktivität verwendet
- Beginnen Sie mit der Verwendung einer Lookup-Aktivität, um Daten abzurufen;
- Ziehen Sie die ForEach-Aktivität aus dem Aktivitätenbereich auf die Pipeline-Leinwand;
- Stellen Sie im Einstellungen-Tab der ForEach-Aktivität das Items-Feld auf die Ausgabe der Lookup-Aktivität ein, wie zum Beispiel:
@activity('LookupActivityName').output.value
; - Fügen Sie innerhalb der ForEach-Aktivität eine Copy Data-Aktivität oder eine andere Aktivität hinzu, um jedes Element in der Liste dynamisch zu verarbeiten;
- Konfigurieren Sie im Source-Tab der Copy Data-Aktivität das Eingabedataset für die Daten, die Sie verarbeiten möchten, und verwenden Sie dynamischen Inhalt, um auf die aktuelle Iteration zu verweisen. In unserem Fall verwenden wir die folgende Abfrage:
SELECT * FROM CovidData WHERE "HHSRegion" = '@{item().HHSRegion}'
; - Konfigurieren Sie im Sink-Tab der Copy Data-Aktivität den Namen der Zieltabelle dynamisch mit dem Ausdruck:
TableName_@{item().ColumnName}
; - Validieren und testen Sie die Pipeline, um sicherzustellen, dass die Daten für jedes Element im Dataset korrekt verarbeitet werden.
@item() Ausdruck
In Azure Data Factory (ADF) wird der @item()
Ausdruck innerhalb der ForEach-Aktivität verwendet, um das aktuelle Element in der Schleife zu referenzieren, während es durch die Sammlung von Elementen iteriert. Der @item()
Ausdruck ermöglicht es Ihnen, Daten oder Werte aus der aktuellen Iteration dynamisch zuzugreifen und sie in nachfolgenden Aktivitäten innerhalb der ForEach-Schleife zu verwenden.
Seine Attribute beziehen sich auf die Eigenschaften des Elements, das iteriert wird. Zum Beispiel, wenn die Schleife durch eine Liste von Objekten iteriert, kann @item()
auf spezifische Attribute wie @item().Region
oder @item().FileName
zugreifen, was eine dynamische Referenzierung von Daten für jede Iteration ermöglicht.
Danke für Ihr Feedback!