Zdieľať cez

Rýchla konfigurácia: Vytvorenie úlohy v toku vzduchu Apache

  • Článok

Poznámka

Úlohu apache airflow poháňa apache airflow.
Apache Airflow je platforma typu open-source, ktorá sa používa na programové vytváranie, plánovanie a monitorovanie zložitých úloh. Umožňuje definovať množinu úloh, nazývaných operátory, ktoré možno skombinovať do smerovaných cyklických grafov (DAGs), ktoré predstavujú údajové kanály.

Apache Airflow Job poskytuje jednoduchý a efektívny spôsob na vytvorenie a spravovanie prostredí toku vzduchu Apache, čo vám umožňuje jednoducho spúšťať funkcie orchestrácie. V tomto stručnom úvode vytvoríme jednoduchú úlohu v toku údajov Apache Airflow, ktorá sa zoznámi s prostredím a funkciami služby Apache Airflow Job.

Požiadavky

  • Povoľte úlohu toku vzduchu Apache v nájomníkovi.

Poznámka

Keďže úloha Apache Airflow je v stave ukážky, musíte ju povoliť prostredníctvom správcu nájomníka. Ak sa vám už zobrazuje funkcia Apache Airflow Job, správca nájomníka ju už pravdepodobne povolil.

  1. Prejdite na stránku Portál na správu –> Nastavenia nájomníka –> v časti Microsoft Fabric –> rozbaľte časť Používatelia môžu vytvárať a používať úlohu toku vzduchu Apache (preview).
  2. Vyberte Použiť.

Snímka obrazovky na povolenie toku údajov Apache Airflow v nájomníkovi.

Vytvorenie úlohy toku vzduchu v Apache

  1. Môžete použiť existujúci pracovný priestor alebo Vytvoriť nový pracovný priestor.

  2. Rozbaľovací zoznam rozbalenia + New –> kliknite na položku Ďalšie možnosti –> v Data Factory časti -> Select Apache Airflow Job (Ukážka)

    Snímka obrazovky znázorňuje kliknutie na ďalšie možnosti.

    Snímka obrazovky s výberom položky Apache Airflow Job .

  3. Zadajte vhodný názov projektu a kliknite na tlačidlo Vytvoriť.

Vytvorenie súboru DAG

  1. Kliknite na kartu Nový súbor DAG –> zadajte názov súboru a kliknite na tlačidlo "Vytvoriť".

    Snímka obrazovky s názvom súboru DAG.

  2. Komický kód DAG je určený pre vás. Súbor môžete upraviť podľa svojich požiadaviek.

    Snímka obrazovky predstavuje súbor DAG s kotlami v službe Microsoft Fabric.

  3. Kliknite na ikonu Uložiť.

    Snímka obrazovky uvádza, ako uložiť súbor DAG v službe Microsoft Fabric.

Spustenie jazyka DAG

  1. Začnite kliknutím na tlačidlo Spustiť DAG.

    Snímka obrazovky na spustenie jazyka DAG z používateľského rozhrania pracovných postupov údajov.

  2. Po spustení sa okamžite zobrazí oznámenie s oznámením, že je dag spustený.

  3. Ak chcete monitorovať priebeh spustenia nástroja DAG, jednoducho v centre oznámení kliknite na položku Zobraziť podrobnosti. Táto akcia vás presmeruje do používateľského rozhrania služby Apache Airflow, kde môžete pohodlne sledovať stav a podrobnosti o spustení DAG.

    Snímka obrazovky na prechod na používateľské rozhranie toku vzduchu Apache z centra oznámení.

Monitorovanie apache airflow DAG v rozhraní Apache Airflow UI

Uložené súbory DAG sa načítajú do používateľského rozhrania toku údajov Apache Airflow. Môžete ich sledovať kliknutím na tlačidlo "Monitor in Apache Airflow" (Sledovať v toku Apache Airflow).

Snímka obrazovky na monitorovanie jazyka DAG toku vzduchu.

Snímka obrazovky zobrazuje načítaný tok vzduchu DAG.

Súvisiaci obsah