Udostępnij za pośrednictwem

Szybki start: tworzenie zadania platformy Apache Airflow

  • Artykuł

Uwaga

Zadanie apache Airflow jest obsługiwane przez platformę Apache Airflow.
Apache Airflow to platforma typu open source używana do programowego tworzenia, planowania i monitorowania złożonych zadań. Umożliwia zdefiniowanie zestawu zadań nazywanych operatorami, które można połączyć w skierowane grafy acykliczne (DAG) do reprezentowania potoków danych.

Zadanie apache Airflow zapewnia prosty i wydajny sposób tworzenia środowisk Apache Airflow i zarządzania nimi, umożliwiając łatwe uruchamianie zadań aranżacji na dużą skalę. W tym przewodniku Szybki start utworzymy proste zadanie platformy Apache Airflow, aby zapoznać się ze środowiskiem i funkcjami zadania apache Airflow.

Wymagania wstępne

  • Włącz zadanie platformy Apache Airflow w dzierżawie.

Uwaga

Ponieważ zadanie platformy Apache Airflow jest w wersji zapoznawczej, należy włączyć je za pośrednictwem administratora dzierżawy. Jeśli widzisz już zadanie platformy Apache Airflow, administrator dzierżawy mógł go już włączyć.

  1. Przejdź do pozycji Portal administracyjny —> Ustawienia dzierżawy —> w obszarze Microsoft Fabric —> rozwiń sekcję "Użytkownicy mogą tworzyć zadania platformy Apache Airflow (wersja zapoznawcza)".
  2. Wybierz Zastosuj.

Zrzut ekranu przedstawiający włączanie platformy Apache Airflow w dzierżawie.

Tworzenie zadania platformy Apache Airflow

  1. Możesz użyć istniejącego obszaru roboczego lub utworzyć nowy obszar roboczy.

  2. Rozwiń + New listę rozwijaną —> kliknij pozycję Więcej opcji —> w Data Factory sekcji —> Wybieranie zadania Apache Airflow (wersja zapoznawcza)

    Zrzut ekranu przedstawia kliknięcie większej liczby opcji.

    Zrzut ekranu przedstawiający wybieranie zadania platformy Apache Airflow.

  3. Nadaj projektowi odpowiednią nazwę i kliknij przycisk "Utwórz".

Tworzenie pliku DAG

  1. Kliknij kartę "Nowy plik DAG" —> nadaj nazwę pliku i kliknij przycisk "Utwórz".

    Zrzut ekranu przedstawiający nazwę pliku DAG.

  2. Prezentowany jest standardowy kod DAG. Plik można edytować zgodnie z wymaganiami.

    Zrzut ekranu przedstawia standardowy plik DAG w usłudze Microsoft Fabric.

  3. Kliknij pozycję "Zapisz ikonę".

    Zrzut ekranu przedstawia sposób zapisywania pliku DAG w usłudze Microsoft Fabric.

Uruchamianie grupy dag

  1. Zacznij od kliknięcia przycisku "Uruchom dag".

    Zrzut ekranu przedstawiający uruchamianie grupy DAG z interfejsu użytkownika przepływów pracy danych.

  2. Po zainicjowaniu zostanie wyświetlone powiadomienie z informacją, że grupa DAG jest uruchomiona.

  3. Aby monitorować postęp przebiegu grupy DAG, po prostu kliknij pozycję "Wyświetl szczegóły" w centrum powiadomień. Ta akcja spowoduje przekierowanie do interfejsu użytkownika platformy Apache Airflow, w którym można wygodnie śledzić stan i szczegóły przebiegu grupy DAG.

    Zrzut ekranu przedstawiający przechodzenie do interfejsu użytkownika platformy Apache Airflow z centrum powiadomień.

Monitorowanie języka DAG platformy Apache Airflow w interfejsie użytkownika platformy Apache Airflow

Zapisane pliki dag są ładowane w interfejsie użytkownika platformy Apache Airflow. Możesz je monitorować, klikając przycisk "Monitoruj w systemie Apache Airflow".

Zrzut ekranu przedstawiający monitorowanie grupy DAG airflow.

Zrzut ekranu przedstawia załadowaną grupę DAG przepływu powietrza.

Powiązana zawartość