Import dagů pomocí služby Azure Blob Storage

Poznámka:

Tato funkce je ve verzi Public Preview. Správce orchestrace pracovních postupů využívá Apache Airflow.

Tento článek ukazuje podrobné pokyny k importu směrovaných acyklických grafů (DAG) do Orchestration Manageru pracovních postupů pomocí služby Azure Blob Storage.

Požadavky

• Předplatné Azure: Pokud nemáte předplatné Azure, vytvořte si před zahájením bezplatný účet Azure.
• Azure Data Factory: Vytvořte nebo vyberte existující instanci služby Data Factory v oblasti, ve které je podporována verze Preview Orchestration Manageru pracovního postupu.
• Účet služby Azure Storage: Pokud účet úložiště nemáte, přečtěte si téma Vytvoření účtu služby Azure Storage, kde najdete postup jeho vytvoření. Ujistěte se, že účet úložiště umožňuje přístup jenom z vybraných sítí.

Blob Storage za virtuálními sítěmi se ve verzi Preview nepodporuje. Konfigurace storageLinkedServices služby Azure Key Vault není podporovaná pro import dagů.

Import dagů

1. Zkopírujte buď Ukázkové Apache Airflow v2.x DAG , nebo Sample Apache Airflow v1.10 DAG na základě prostředí Airflow, které jste nastavili. Vložte obsah do nového souboru s názvem tutorial.py.

   Nahrajte soubor tutorial.py do služby Blob Storage. Další informace najdete v tématu Nahrání souboru do objektu blob.

   Poznámka:

   Abyste je mohli importovat do prostředí Airflow, musíte vybrat cestu k adresáři z účtu služby Blob Storage, který obsahuje složky s názvem dags a moduly plug-in. Moduly plug-in nejsou povinné. Můžete také mít kontejner s názvem dags a nahrát do něj všechny soubory Airflow.

2. V části Spravovat centrum vyberte Apache Airflow. Pak najeďte myší na dříve vytvořené prostředí Airflow a výběrem možnosti Importovat soubory naimportujte všechny daG a závislosti do prostředí Airflow.

   

3. Vytvořte novou propojenou službu pro přístupný účet úložiště uvedený v části Požadavky. Existující můžete použít také v případě, že už máte vlastní skupiny DAG.

   

4. Použijte účet úložiště, do kterého jste nahráli daG. (Zkontrolujte část Požadavky.) Otestujte připojení a pak vyberte Vytvořit.

   

5. Pokud používáte ukázkovou adresu URL SAS, vyhledejte a vyberte tok vzduchu. Můžete také vybrat složku, která obsahuje složku dags se soubory DAG.

   Poznámka:

   Pomocí tohoto rozhraní můžete importovat skupiny DAG a jejich závislosti. Abyste je mohli importovat do prostředí Airflow, musíte vybrat cestu k adresáři z účtu služby Blob Storage, který obsahuje složky s názvem dags a moduly plug-in. Moduly plug-in nejsou povinné.

   

   

6. Vyberte Importovat , chcete-li importovat soubory.

   

   

Import dagů může během verze Preview trvat několik minut. Ke sledování aktualizací stavu importu můžete použít centrum oznámení (ikona zvonku v uživatelském rozhraní služby Data Factory).