Freigeben über


Überblick über Aktivitäten

Aktivitäten sind die Bausteine, mit denen Sie End-to-End-Datenworkflows in Microsoft Fabric erstellen können. Stellen Sie sich sie als die Aufgaben vor, die Ihre Daten verschieben und transformieren, um Ihren Geschäftlichen Anforderungen gerecht zu werden. Sie können eine Kopieraktivität verwenden, um Daten aus SQL Server in Azure Blob Storage zu verschieben. Anschließend können Sie eine Dataflow-Aktivität oder Notizbuchaktivität hinzufügen, um diese Daten zu verarbeiten und zu transformieren, bevor Sie sie in Azure Synapse Analytics für die Berichterstellung laden.

Aktivitäten werden in Pipelines gruppiert, um bestimmte Ziele zu erreichen. Sie können z. B. eine Pipeline erstellen, die:

  • Ruft Protokolldaten aus verschiedenen Quellen ab
  • Bereinigt und organisiert diese Daten
  • Führt Analysen aus, um Erkenntnisse zu finden

Wenn Sie Ihre Aktivitäten in einer Pipeline gruppieren, können Sie all diese Schritte als eine Einheit verwalten, anstatt jede Aktivität separat zu behandeln. Sie können die gesamte Pipeline gleichzeitig bereitstellen und planen, um sie bei Bedarf auszuführen.

Microsoft Fabric bietet drei Arten von Aktivitäten:

Datenverschiebungsaktivitäten

Diese Aktivitäten helfen Ihnen, Daten von einem Ort an eine andere in Ihrer Pipeline zu verschieben.

Bewegungsaktivität Description
Kopieren von Daten Sie können Daten aus jeder unterstützten Quelle auf jedes unterstützte Ziel kopieren. Sehen Sie sich die Übersicht über den Connector an, um zu sehen, was verfügbar ist.
Kopierauftrag Kopieraufträge sind eine vereinfachte Methode zum schnellen Verschieben von Daten.

Wenn Sie zwischen verschiedenen Datenbewegungsoptionen wählen müssen, lesen Sie den Artikel zum Entscheidungsleitfaden zur Datenbewegung.

Datentransformationsaktivitäten

Diese Aktivitäten helfen Ihnen, Ihre Daten zu verarbeiten und zu transformieren. Sie können sie einzeln verwenden oder mit anderen Aktivitäten verketten.

Weitere Informationen finden Sie im Artikel Datentransformationsaktivitäten.

Datentransformationsaktivität Compute-Umgebung
Kopieren von Daten Compute-Manager von Microsoft Fabric
Dataflow Gen2 Compute-Manager von Microsoft Fabric
Löschen von Daten Compute-Manager von Microsoft Fabric
Fabric-Notizbuch Apache Spark-Cluster, die von Microsoft Fabric verwaltet werden
HDInsight-Aktivität Apache Spark-Cluster, die von Microsoft Fabric verwaltet werden
Spark-Auftragsdefinition Apache Spark-Cluster, die von Microsoft Fabric verwaltet werden
Gespeicherte Prozedur Azure SQL, Azure Synapse Analytics oder SQL Server
SQL-Skript Azure SQL, Azure Synapse Analytics oder SQL Server

Ablaufsteuerungsaktivitäten

Mit diesen Aktivitäten können Sie steuern, wie Ihre Pipeline ausgeführt wird:

Steuern der Aktivität Description
Anfügevariable Ermöglicht das Hinzufügen eines Werts zu einer vorhandenen Arrayvariablen.
Azure Batch-Aktivität Führt ein Azure Batch-Skript aus.
Azure Databricks-Aktivität Führt einen Azure Databricks-Auftrag (Notebook, Jar, Python) aus.
Azure Machine Learning-Aktivität Führt einen Azure Machine Learning-Auftrag aus.
Aktivität deaktivieren Deaktiviert eine andere Aktivität.
Fail Bringen Sie die Pipelineausführung mit einer angepassten Fehlermeldung und einem Fehlercode zum Scheitern.
Filter Wende einen Filterausdruck auf ein Eingabearray an.
ForEach Mit der Aktivität "ForEach" wird der Ablauf in Ihrer Pipeline so gesteuert, dass er sich wiederholt. Diese Aktivität wird verwendet, um über eine Sammlung zu iterieren und die angegebenen Aktivitäten in einer Schleife auszuführen. Die Schleifenimplementierung dieser Aktivität ähnelt der Foreach-Schleifenstruktur in Programmiersprachen.
Funktionenaktivität Führt eine Azure Function aus.
Abrufen von Metadaten Die Aktivität „Metadaten abrufen“ kann zum Abrufen von Metadaten für alle Daten in einer Data Factory- oder Synapse-Pipeline verwendet werden.
Wenn-Bedingung Die „If Condition“ kann verwendet werden, um eine Verzweigung basierend auf einer Bedingung einzurichten, die als wahr oder falsch ausgewertet wird. Die Aktivität „If Condition“ bietet die gleiche Funktionalität wie eine If-Anweisung in Programmiersprachen. Sie wertet eine Aktivitätengruppe aus, wenn die Bedingung als true ausgewertet wird, und eine weitere Aktivitätengruppe, wenn die Bedingung als false ausgewertet wird.
Pipeline aufrufen Mit der Aktivität „Pipeline ausführen“ kann eine Data Factory- oder Synapse-Pipeline eine andere Pipeline aufrufen.
KQL-Aktivität Führt ein KQL-Skript für eine Kusto-Instanz aus.
Seehaus-Wartungsaktivitäten Durchführung von Routinewartungen für Tabellen in einem Lakehouse über eine Microsoft Fabric-Pipeline.
Nachschlageaktivität Mit der Lookup-Aktivität können Sie einen Datensatz, Tabellennamen oder Wert aus einer beliebigen externen Quelle abrufen oder nachschlagen. Auf die Ausgabe kann durch nachfolgende Aktivitäten verwiesen werden.
Aktualisieren der SQL-Endpunktaktivität Aktualisiert einen SQL-Endpunkt in Lakehouse, um die neuesten Daten widerzuspiegeln.
Variable festlegen Ermöglicht das Festlegen des Werts einer vorhandenen Variablen.
Switch-Aktivität Implementiert einen Wechselausdruck, der mehrere nachfolgende Aktivitäten für jedes potenzielle Ergebnis des Ausdrucks zulässt.
Teams-Aktivität Veröffentlicht eine Nachricht in einem Teams-Kanal oder Gruppenchat.
Bis zur Aktivität Es wird eine „Wiederholen bis“-Schleife implementiert, die der Struktur einer Do-Until-Schleife in Programmiersprachen ähnelt. Sie führt eine Reihe von Aktivitäten in einer Schleife aus, bis die der Aktivität zugeordnete Bedingung als „true“ ausgewertet wird. Sie können einen Timeoutwert für die Until-Aktivität angeben.
Warteaktivität Wenn Sie eine Warteaktivität in einer Pipeline verwenden, wartet die Pipeline den angegebenen Zeitraum, bevor sie die Ausführung nachfolgender Aktivitäten fortsetzt.
Webaktivität Die Webaktivität kann verwendet werden, um einen benutzerdefinierten REST-Endpunkt aus einer Pipeline aufzurufen.
Webhook-Aktivität Die Webhook-Aktivität ermöglicht das Aufrufen eines Endpunkts und das Übergeben einer Rückruf-URL. Der Pipeline-Durchlauf wartet, bis der Callback aufgerufen wird, bevor er mit der nächsten Aktivität fortfährt.

Hinzufügen von Aktivitäten zu einer Pipeline mit der Microsoft Fabric-Benutzeroberfläche

Hier erfahren Sie, wie Sie Aktivitäten in Ihrer Pipeline hinzufügen und konfigurieren:

  1. Erstellen Sie eine neue Pipeline in Ihrem Arbeitsbereich.
  2. Wechseln Sie zur Registerkarte "Aktivitäten", und durchsuchen Sie die verfügbaren Aktivitäten. Scrollen Sie nach rechts, um alle Optionen anzuzeigen, und wählen Sie dann eine Aktivität aus, um sie dem Pipeline-Editor hinzuzufügen.
  3. Wenn Sie eine Aktivität hinzufügen und auf der Canvas auswählen, werden die zugehörigen Allgemeinen Einstellungen im Eigenschaftenbereich unten angezeigt.
  4. Jede Aktivität verfügt über weitere Konfigurationsoptionen auf anderen Registerkarten im Eigenschaftenbereich.

Der Screenshot zeigt den Pipeline-Editor mit der Registerkarte „Aktivitäten“, der Symbolleiste, einer Kopieraktivität und der Registerkarte „Allgemein“ mit den Eigenschaften, alles hervorgehoben.

Allgemeine Einstellungen

Wenn Sie einer Pipeline eine neue Aktivität hinzufügen und diese auswählen, werden die Eigenschaften unten auf dem Bildschirm angezeigt. Dazu gehören "Allgemein", "Einstellungen" und manchmal auch andere Registerkarten.

Screenshot: Registerkarte „Allgemeine Einstellungen“ einer Aktivität.

Jede Aktivität enthält Die Felder "Name " und " Beschreibung " in den allgemeinen Einstellungen. Einige Aktivitäten haben auch folgende Optionen:

Setting Description
Timeout Wie lange eine Aktivität ausgeführt werden kann, bevor ein Timeout erfolgt. Der Standardwert ist 12 Stunden und die maximale Anzahl von sieben Tagen. Verwenden Sie das Format D.HH:MM:SS.
Retry Wie oft wiederholt werden soll, wenn die Aktivität fehlschlägt.
(Erweiterte Eigenschaften) Wiederholungsintervall (Sek.) Anzahl der Sekunden, die zwischen Wiederholungsversuchen gewartet werden sollen.
(Erweiterte Eigenschaften) Sichere Ausgabe Wenn diese Option ausgewählt ist, wird die Aktivitätsausgabe nicht in Protokollen angezeigt.
(Erweiterte Eigenschaften) Sichere Eingabe Wenn diese Option ausgewählt ist, werden die Aktivitätseingaben nicht in Protokollen angezeigt.

Note

Standardmäßig können sie bis zu 120 Aktivitäten pro Pipeline haben. Dazu gehören interne Vorgänge bei Containern.

Deaktivieren einer Aktivität

Sie können eine oder mehrere Aktivitäten aus einer Pipeline deaktivieren, um sie während der Überprüfung und Pipelineausführung zu überspringen. Dieses Feature verbessert die Effizienz von Pipelineentwicklern, sodass Sie einen Teil der Pipeline auskommentieren können, ohne ihn aus der Canvas zu löschen. Sie können Aktivitäten zu einem späteren Zeitpunkt reaktivieren.

Deaktivieren von Aktivitäten

Es gibt zwei Möglichkeiten zum Deaktivieren einer Aktivität: Deaktivieren einer einzelnen Aktivität über die Registerkarte " Allgemein " oder Deaktivieren mehrerer Aktivitäten mit der rechten Maustaste.

Speichern Sie die Änderungen, um die Aktivitäten während der nächsten geplanten Pipelineausführung zu deaktivieren.

Deaktivieren einer einzelnen Aktivität

  1. Wählen Sie die Aktivität aus, die Sie deaktivieren möchten.
  2. Wählen Sie auf der Registerkarte "Allgemein" die Option "Für den Aktivitätsstatusdeaktiviert" aus.
  3. Wählen Sie einen Status für "Aktivität markieren als" aus. Wählen Sie aus Erfolgreich, Fehlgeschlagen oder Übersprungen aus

Screenshot des Fabric Data Factory-Pipeline-Editors mit

Deaktivieren mehrerer Aktivitäten

  1. Drücken Sie die STRG-TASTE nach unten, um mehrfach auszuwählen. Klicken Sie mit der linken Maustaste auf alle Aktivitäten, die Sie deaktivieren möchten.
  2. Klicken Sie mit der rechten Maustaste, um das Dropdownmenü anzuzeigen.
  3. Wählen Sie "Deaktivieren" aus, um sie alle zu deaktivieren.
  4. Um die Einstellungen für "Aktivität markieren als" zu optimieren, wechseln Sie zur Registerkarte " Allgemein " der Aktivität, und nehmen Sie entsprechende Änderungen vor.

Screenshot, der zeigt, wie mehrere Aktivitäten gleichzeitig deaktiviert werden.

Reaktivieren von Aktivitäten

Wenn Sie die Aktivitäten reaktivieren möchten, wählen Sie "Für den Aktivitätsstatus aktiviert" aus, und kehren sie wie erwartet zu ihren vorherigen Verhaltensweisen zurück.

Inaktive Aktivitätsverhalten

Eine inaktive Aktivität verhält sich in einer Pipeline anders.

  • Auf der Leinwand ist die inaktive Aktivität abgeblendet, wobei das Inaktivitätszeichen neben dem Aktivitätstyp platziert wird.

  • Auf der Leinwand wird ein Statuszeichen (Erfolgreich, fehlgeschlagen oder übersprungen) auf dem Kästchen platziert, um die Aktivität als markieren-Einstellung zu visualisieren.

  • Die Aktivität wird von der Pipelineüberprüfung ausgeschlossen. Daher müssen Sie nicht alle erforderlichen Felder für eine inaktive Aktivität angeben.

  • Während des Debug-Modus und beim Pipeline-Lauf wird die Aktivität nicht wirklich ausgeführt. Stattdessen wird ein Platzhalterzeilenelement mit dem reservierten Status "Inaktiv" ausgeführt.

  • Die Verzweigungsoption wird durch die Option " Aktivität markieren" gesteuert. Anders ausgedrückt:

    • Wenn Sie die Aktivität als erfolgreich markieren, wird die UponSuccess- oder UponCompletion-Verzweigung ausgeführt.
    • Wenn Sie die Aktivität als fehlgeschlagen markieren, wird der UponFailure- oder UponCompletion-Zweig ausgeführt.
    • Wenn Sie die Aktivität als übersprungen markieren, wird die UponSkip-Verzweigung ausgeführt.

    Screenshot mit dem Ausführungsstatus einer inaktiven Aktivität.

Bewährte Methoden für die Deaktivierung

Die Deaktivierung ist ein leistungsfähiges Tool für Pipelineentwickler. Entwickler können einen Teil des Codes „auskommentieren“, ohne die Aktivitäten dauerhaft zu löschen. Es glänzt in folgenden Szenarien:

  • Bei der Entwicklung einer Pipeline kann der Entwickler Platzhalter für inaktive Aktivitäten hinzufügen, bevor er alle erforderlichen Felder ausfüllt. Ich benötige zum Beispiel eine Kopieraktivität von SQL Server zum Data Warehouse, habe aber noch nicht alle Verbindungen eingerichtet. Daher verwende ich eine inaktive Kopieraktivität als Platzhalter für iterative Entwicklungsprozesse.
  • Nach der Bereitstellung kann der Entwickler bestimmte Aktivitäten kommentieren, die immer Probleme verursachen, um kostspielige Wiederholungen zu vermeiden. Wenn zum Beispiel mein lokaler SQL-Server Probleme mit der Netzwerkverbindung hat, weiß ich, dass meine Kopiervorgänge mit Sicherheit fehlschlagen. Möglicherweise möchte ich die Kopieraktivität deaktivieren, um zu vermeiden, dass Wiederholungsanforderungen das spröde System überfluten.

Note

Eine inaktive Aktivität wird nie tatsächlich ausgeführt. Dies bedeutet, dass die Aktivität kein Fehlerfeld oder die typischen Ausgabefelder enthält. Alle Verweise auf fehlende Felder können Fehler nach unten auslösen.