Omówienie działań

Działania to bloki konstrukcyjne, które ułatwiają tworzenie pełnych przepływów pracy danych w usłudze Microsoft Fabric. Pomyśl o nich jako o zadaniach, które przenoszą i przekształcają dane zgodnie z potrzebami biznesowymi. Działanie kopiowania może służyć do przenoszenia danych z programu SQL Server do usługi Azure Blob Storage. Następnie możesz dodać działanie przepływu danych lub działanie Notesu, aby przetworzyć i przekształcić te dane przed załadowaniem ich do usługi Azure Synapse Analytics na potrzeby raportowania.

Działania są grupowane razem w pipeline'ach w celu osiągnięcia określonych celów. Możesz na przykład utworzyć potok, który:

  • Ściąga dane dziennika z różnych źródeł
  • Czyści i organizuje te dane
  • Uruchamia analizę w celu znalezienia szczegółowych informacji

Grupowanie działań w przepływ pracy pozwala zarządzać wszystkimi krokami jako jedną całością, zamiast obsługiwać każde działanie osobno. Możesz wdrażać i planować cały pipeline jednocześnie, aby uruchamiać go wtedy, gdy jest potrzebny.

Usługa Microsoft Fabric oferuje trzy typy działań:

Działania dotyczące przenoszenia danych

Te działania ułatwiają przenoszenie danych z jednego miejsca do drugiego w potoku.

Aktywność ruchowa Description
Kopiowanie danych Możesz skopiować dane z dowolnego obsługiwanego źródła do dowolnego obsługiwanego miejsca docelowego. Zobacz Omówienie łącznika , aby zobaczyć, co jest dostępne.
Zadanie kopiowania Zadania kopiowania to uproszczona metoda szybkiego przenoszenia danych.

Jeśli musisz wybrać różne opcje przenoszenia danych, zobacz artykuł Przewodnik po decyzjach dotyczących przenoszenia danych .

Działania dotyczące przekształcania danych

Te działania ułatwiają przetwarzanie i przekształcanie danych. Można ich używać pojedynczo lub łączyć je w łańcuchy razem z innymi działaniami.

Aby uzyskać więcej informacji, zobacz artykuł z działaniami dotyczącymi przekształcania danych.

Działanie przekształcania danych Środowisko obliczeniowe
Kopiowanie danych Menedżer obliczeń przez Fabric
Przepływ danych Gen2 Menedżer obliczeń w usłudze Fabric
Usuwanie danych Menedżer obliczeń w usłudze Fabric
Notebook z tkaniny Klastry Apache Spark zarządzane przez Fabric
Działanie usługi HDInsight Klastry Apache Spark zarządzane przez Fabric
definicja zadania Spark Klastry Apache Spark zarządzane przez Fabric
Procedura składowana Azure SQL, Azure Synapse Analytics lub SQL Server
Skrypt SQL Azure SQL, Azure Synapse Analytics lub SQL Server

Operacje sterowania przepływem

Te działania ułatwiają kontrolowanie sposobu uruchamiania potoku:

Działanie sterujące Description
Dodaj zmienną Dodaj wartość do istniejącej zmiennej tablicy.
Działanie zatwierdzania Wstrzymuje wykonywanie potoku i prosi wyznaczonych recenzentów o decyzję o zatwierdzeniu lub odrzuceniu.
Działanie usługi Azure Batch Uruchamia skrypt usługi Azure Batch.
Działanie usługi Azure Databricks Uruchamia zadanie usługi Azure Databricks (Notatnik, Jar, Python).
Działanie usługi Azure Machine Learning Uruchamia zadanie usługi Azure Machine Learning.
Wyłącz aktywność Dezaktywuje inne działanie.
Fail Spowodować niepowodzenie wykonania potoku z dostosowanym komunikatem błędu i kodem błędu.
Filter Zastosuj wyrażenie filtru do tablicy wejściowej.
ForEach Działanie ForEach definiuje powtarzający się przepływ kontrolny w twoim potoku. To działanie używane jest do iterowania kolekcji i wykonuje określone działania w sposób cykliczny. Implementacja pętli tego działania przypomina strukturę pętli Foreach w językach programowania.
Działanie funkcji Wykonuje funkcję platformy Azure.
Pobieranie metadanych Aktywność GetMetadata może służyć do pobierania metadanych dowolnych zasobów danych w potoku usługi Data Factory lub Azure Synapse.
Instrukcja if Działanie If Condition umożliwia tworzenie gałęzi na podstawie warunków, które są obliczane na wartość true lub false. Działanie If Condition pełni taką samą rolę, co instrukcja if w językach programowania. Powoduje ono obliczenie zestawu działań, gdy warunek zostanie obliczony na wartość true, oraz innego zestawu działań, gdy warunek zostanie obliczony na wartość false.
Wywołaj potok Aktywność Execute Pipeline pozwala potokowi Data Factory lub Azure Synapse wywołać inny potok.
Działanie KQL Wykonuje skrypt KQL na instancji Kusto.
Prace konserwacyjne Lakehouse Wykonuj rutynową konserwację stołu na domku nad jeziorem z rurociągu Fabric.
Aktywność wyszukiwania Działanie Lookup może być używane do odczytywania lub wyszukiwania rekordu/nazwy tabeli/wartości z dowolnego źródła zewnętrznego. Do tych danych wyjściowych mogą także odwoływać się kolejne działania.
Odświeżenie urzeczywistniło się w aktywności widokowej na jezioro Odświeża zmaterializowany widok jeziora w domku nad jeziorem, aby odzwierciedlić najnowsze dane.
Odśwież aktywność punktu końcowego analizy SQL Odświeża punkt końcowy analizy SQL w usłudze Lakehouse, aby odzwierciedlał najnowsze dane.
Ustaw zmienną Ustaw wartość istniejącej zmiennej.
Aktywność przełącznika Implementuje wyrażenie przełącznika, które umożliwia wiele kolejnych działań dla każdego potencjalnego wyniku wyrażenia.
Działanie aplikacji Teams Publikuje wiadomość w kanale usługi Teams lub czacie grupowym.
Do czasu aktywności Implementuje pętlę do-until podobną do struktury pętli do-until w językach programowania. Służy do wykonywania zestawu działań w pętli do momentu, gdy warunek skojarzony z działaniem zostanie obliczony na wartość true. Możesz określić wartość limitu czasu dla działania until.
Aktywność oczekiwania Gdy używasz działania oczekiwania w potoku, potok czeka określony czas, zanim kontynuuje wykonywanie kolejnych działań.
Działanie internetowe Aktywność sieciowa może być użyta do wywołania niestandardowego punktu końcowego REST z potoku.
Aktywność webhooka Za pomocą działania elementu webhook wywołaj punkt końcowy i przekaż adres URL wywołania zwrotnego. Uruchomienie potoku czeka na wywołanie zwrotne przed przejściem do następnego działania.

Dodawanie działań do potoku za pomocą interfejsu użytkownika platformy Microsoft Fabric

Oto jak dodać i skonfigurować działania w potoku przetwarzania:

  1. Utwórz nowy potok w obszarze roboczym.
  2. Przejdź do zakładki Aktywności i przeglądaj dostępne aktywności. Przewiń w prawo, aby wyświetlić wszystkie opcje, a następnie wybierz działanie, aby dodać je do edytora potoków.
  3. Po dodaniu działania i wybraniu go na kanwie zobaczysz jego ustawienia Ogólne w okienku właściwości poniżej.
  4. Każde działanie ma inne opcje konfiguracji na innych kartach w okienku właściwości.

Zrzut ekranu przedstawiający edytor potoku z kartą Działania, paskiem narzędzi, działaniem kopiuj oraz kartą Ogólne właściwości, wszystkie wyróżnione.

Ustawienia ogólne

Po dodaniu nowej aktywności do potoku i jej wybraniu zobaczysz właściwości na dole ekranu. Obejmują one Ogólne, Ustawienia, a czasami inne karty.

Zrzut ekranu przedstawiający zakładkę Ustawienia ogólne dla działania.

Każde działanie zawiera pola Nazwa i Opis w ustawieniach ogólnych. Niektóre działania mają również następujące opcje:

Setting Description
Timeout Jak długo działanie może działać przed upływem limitu czasu. Wartość domyślna to 12 godzin, a wartość maksymalna to siedem dni. Użyj formatu D.HH:MM:SS.
Włączanie ponownych prób Po wybraniu działania automatycznie ponawia próbę, jeśli zakończy się niepowodzeniem.
Retry Ile razy należy ponowić próbę, jeśli działanie zakończy się niepowodzeniem. Wartość domyślna to 1.
Warunki ponawiania prób (wersja zapoznawcza) Skonfiguruj określone warunki błędów, które wyzwalają ponowienie próby.
Interwał ponawiania prób (s) Ile sekund oczekiwania między ponownymi próbami. Wartość domyślna to 30 sekund.
(Właściwości zaawansowane) Bezpieczne dane wyjściowe Po wybraniu wynik działania nie będzie wyświetlany w logach.
(Właściwości zaawansowane) Bezpieczne dane wejściowe Gdy zostanie wybrane, dane wejściowe działania nie będą wyświetlane w dziennikach.

Note

Domyślnie można mieć maksymalnie 120 aktywności na pipeline. Obejmuje to działania wewnętrzne kontenerów.

Ponów próbę działania

Gdy działanie zakończy się niepowodzeniem podczas wykonywania potoku, można skonfigurować je tak, aby automatycznie ponowiło próbę przed oznaczeniem uruchomienia jako nieudanego. Ta funkcja jest przydatna do obsługi błędów przejściowych, takich jak przekroczenia limitu czasu sieci, tymczasowa niedostępność usługi lub sporadyczne problemy z połączeniem.

Dowiedz się więcej o ustawieniach powtórek i jak je skonfigurować tutaj.

Dezaktywowanie działania

Możesz dezaktywować jedną lub więcej aktywności z pipeline'u, aby pominąć je podczas walidacji i przebiegów pipeline'u. Ta funkcja zwiększa wydajność dewelopera potoku, umożliwiając komentowanie części potoku bez usuwania go z kanwy. Działania można ponownie uaktywnić w późniejszym czasie.

Dezaktywowanie działań

Istnieją dwa sposoby dezaktywowania działania: dezaktywowanie pojedynczego działania na karcie Ogólne lub dezaktywowaniewielu działań za pomocą kliknięcia prawym przyciskiem myszy.

Zapisz zmiany, aby wyłączyć aktywności podczas następnego zaplanowanego przebiegu potoku.

Dezaktywowanie pojedynczego działania

  1. Wybierz działanie, które chcesz dezaktywować
  2. Na karcie Ogólne wybierz pozycję Dezaktywowane dla stanu działania
  3. Wybierz stan dla Oznacz działanie jako. Wybierz jedną z opcji Powodzenie, Niepowodzenie lub Pominięto

Zrzut ekranu przedstawiający edytor potoku usługi Fabric Data Factory z działaniem ActivityDeactivated ustawionym na Nieaktywne w okienku Ustawienia ogólne.

Dezaktywowanie wielu działań

  1. Przytrzymaj klawisz Ctrl, aby wybrać wiele elementów. Za pomocą myszy kliknij lewym przyciskiem myszy wszystkie działania, które chcesz dezaktywować
  2. Kliknij prawym przyciskiem myszy, aby wyświetlić menu rozwijane
  3. Wybierz pozycję Dezaktywuj , aby dezaktywować je wszystkie
  4. Aby precyzyjnie dostosować ustawienia dla Oznacz aktywność jako, przejdź do karty Ogólne i wprowadź odpowiednie zmiany.

Zrzut ekranu przedstawiający sposób dezaktywowania wielu działań jednocześnie.

Ponowne aktywowanie działań

Aby ponownie uaktywnić działania, wybierz pozycję Aktywowano dla stanu działania i przywracają poprzednie zachowania zgodnie z oczekiwaniami.

Nieaktywne zachowania działań

Działanie nieaktywne działa inaczej w przepływie pracy.

  • Na płótnie, działanie nieaktywne jest wyświetlane w odcieniach szarości, a znak Nieaktywny umieszczony jest obok typu czynności.

  • Na polu umieszczany jest znak stanu (Powodzenie, Niepowodzenie lub Pominięto), aby zwizualizować ustawienie Oznacz czynność jako.

  • Działanie jest wykluczone z walidacji potoku. W związku z tym nie trzeba podawać wszystkich wymaganych pól dla nieaktywnej aktywności.

  • Podczas debugowania i przebiegu potoku działanie nie zostanie faktycznie wykonane. Zamiast tego uruchamia element zastępczy wiersza ze statusem Nieaktywny

  • Opcja rozgałęziania jest kontrolowana przez opcję Oznacz aktywność jako. Innymi słowy:

    • Jeśli oznaczysz działanie jako Powodzenie, zostanie uruchomiona gałąź UponSuccess lub UponCompletion
    • Jeśli oznaczysz działanie jako Niepowodzenie, zostanie uruchomiona gałąź UponFailure lub UponCompletion
    • Jeśli oznaczysz działanie jako pominięte, zostanie uruchomiona gałąź UponSkip

    Zrzut ekranu przedstawiający status wykonania nieaktywnej czynności.

Najlepsze rozwiązania dotyczące dezaktywacji

Dezaktywacja to potężne narzędzie dla deweloperów potoków. Dzięki niej deweloperzy mogą "komentować" część kodu bez trwałego usuwania działań. Świeci w następujących scenariuszach:

  • Podczas tworzenia potoku deweloper może dodać nieaktywne działania właściciela miejsca przed wypełnieniem wszystkich wymaganych pól. Na przykład potrzebuję działania Copy z programu SQL Server do hurtowni danych, ale nie skonfigurowałem jeszcze wszystkich połączeń. Dlatego używam nieaktywnej czynności kopiowania jako zastępnika miejsca do procesu rozwoju iteracyjnego.
  • Po wdrożeniu deweloper może komentować niektóre działania, które stale powodują problemy, aby uniknąć kosztowych ponownych prób. Na przykład lokalny serwer SQL ma problemy z połączeniem sieciowym i wiem, że działania kopiowania nie powiodły się w pewnym przypadku. Mogę chcieć dezaktywować aktywność kopiowania, aby uniknąć zalania kruchego systemu ponawianymi żądaniami.

Note

Nieaktywna aktywność nigdy nie działa. Oznacza to, że działanie nie będzie miało pola błędu ani typowych pól wyjściowych. Wszelkie odwołania do brakujących pól mogą powodować błędy na późniejszych etapach.