Megosztás a következőn keresztül:

Rövid útmutató: Apache Airflow-feladat létrehozása

  • Cikk

Feljegyzés

Az Apache Airflow-feladatot az Apache Airflow működteti.
Az Apache Airflow egy nyílt forráskódú platform, amellyel programozott módon hozhat létre, ütemezhet és figyelhet összetett feladatokat. Lehetővé teszi, hogy definiáljon egy olyan feladatkészletet, úgynevezett operátort, amely az adatfolyamokat ábrázoló irányított aciklikus grafikonokba (DAG-k) kombinálható.

Az Apache Airflow-feladat egyszerű és hatékony módot kínál az Apache Airflow-környezetek létrehozására és kezelésére, így könnyedén futtathatja vezénylési feladatait. Ebben a rövid útmutatóban hozzunk létre egy egyszerű Apache Airflow-feladatot az Apache Airflow-feladat környezetének és funkcióinak megismeréséhez.

Előfeltételek

  • Engedélyezze az Apache Airflow-feladatot a bérlőben.

Feljegyzés

Mivel az Apache Airflow-feladat előzetes verziójú, engedélyeznie kell azt a bérlői rendszergazdán keresztül. Ha már megjelenik az Apache Airflow-feladat, lehetséges, hogy a bérlői rendszergazda már engedélyezte azt.

  1. Nyissa meg a Felügyeleti portált –> Bérlői beállítások –> A Microsoft Fabric alatt bontsa> ki a "Felhasználók létrehozhatják és használhatják az Apache Airflow-feladatot (előzetes verzió)" szakaszt.
  2. Válassza az Alkalmazás lehetőséget.

Képernyőkép az Apache Airflow bérlői engedélyezéséről.

Apache Airflow-feladat létrehozása

  1. Használhat meglévő munkaterületet, vagy létrehozhat egy új munkaterületet.

  2. Bontsa ki + New a legördülő menüt –> Kattintson a További beállítások elemre –> A szakasz alatt Data Factory –> Az Apache Airflow-feladat kiválasztása (előzetes verzió)

    Képernyőkép a további lehetőségekre való kattintásról.

    Képernyőkép az Apache Airflow-feladat kiválasztásáról.

  3. Adjon megfelelő nevet a projektnek, és kattintson a "Létrehozás" gombra.

DAG-fájl létrehozása

  1. Kattintson az "Új DAG-fájl" kártyára –> adja meg a fájl nevét, majd kattintson a "Létrehozás" gombra.

    Képernyőkép a DAG-fájl elnevezéséhez.

  2. Megjelenik egy kazánlemez DAG-kódja. A fájlt a követelményeknek megfelelően szerkesztheti.

    Képernyőkép a Microsoft Fabricben található bojlerplate DAG-fájlról.

  3. Kattintson a "Mentés ikon" elemre.

    Képernyőkép a DAG-fájl Microsoft Fabricben való mentéséről.

DAG futtatása

  1. Kezdje a "DAG futtatása" gombra kattintva.

    Képernyőkép a DAG futtatásához az adat-munkafolyamatok felhasználói felületéről.

  2. A kezdeményezést követően azonnal megjelenik egy értesítés, amely jelzi, hogy a DAG fut.

  3. A DAG-futtatás előrehaladásának figyeléséhez egyszerűen kattintson a "Részletek megtekintése" elemre az értesítési központban. Ez a művelet átirányítja az Apache Airflow felhasználói felületére, ahol kényelmesen nyomon követheti a DAG-futtatás állapotát és részleteit.

    Képernyőkép az Apache Airflow felhasználói felületére való navigáláshoz az értesítési központból.

Az Apache Airflow DAG monitorozása az Apache Airflow felhasználói felületén

A mentett dagfájlok betöltve vannak az Apache Airflow felhasználói felületén. A monitorozásukhoz kattintson a "Monitorozás az Apache Airflow-ban" gombra.

Képernyőkép az Airflow DAG figyeléséhez.

Képernyőkép a betöltött Airflow DAG-ról.

Kapcsolódó tartalom