DAG-k importálása az Azure Blob Storage használatával

Feljegyzés

Ez a funkció nyilvános előzetes verzióban érhető el. A Workflow Orchestration Managert az Apache Airflow működteti.

Ez a cikk részletesen bemutatja, hogyan importálhat irányított aciklikus gráfokat (DAG-ket) a Workflow Orchestration Managerbe az Azure Blob Storage használatával.

Előfeltételek

• Azure-előfizetés: Ha nem rendelkezik Azure-előfizetéssel, a kezdés előtt hozzon létre egy ingyenes Azure-fiókot .
• Azure Data Factory: Hozzon létre vagy válasszon ki egy meglévő Data Factory-példányt egy olyan régióban, ahol a Workflow Orchestration Manager előzetes verziója támogatott.
• Azure Storage-fiók: Ha nincs tárfiókja, a létrehozás lépéseit az Azure Storage-fiók létrehozása című témakörben találja. Győződjön meg arról, hogy a tárfiók csak a kiválasztott hálózatokról engedélyezi a hozzáférést.

A virtuális hálózatok mögötti Blob Storage nem támogatott az előzetes verzióban. Az Azure Key Vault konfigurációja storageLinkedServices nem támogatott a DAG-k importálásához.

DAG-k importálása

1. Másolja ki az Apache Airflow 2.x DAG-mintát vagy az Apache Airflow 1.10-s minta DAG-mintát a beállított Airflow-környezet alapján. Illessze be a tartalmat egy tutorial.py nevű új fájlba.

   Töltse fel a tutorial.py fájlt a Blob Storage-ba. További információ: Fájl feltöltése blobba.

   Feljegyzés

   Az Airflow-környezetbe való importáláshoz ki kell választania egy címtár elérési útját egy Blob Storage-fiókból, amely dagok és beépülő modulok nevű mappákat tartalmaz. A beépülő modulok használata nem kötelező. Rendelkezhet dags nevű tárolóval is, és feltöltheti benne az összes Airflow-fájlt.

2. A Manage Hub alatt válassza az Apache Airflow lehetőséget. Ezután vigye az egérmutatót a korábban létrehozott Airflow-környezet fölé, és válassza a Fájlok importálása lehetőséget az összes DAG és függőség Airflow-környezetbe való importálásához.

   

3. Hozzon létre egy új társított szolgáltatást az "Előfeltételek" szakaszban említett akadálymentes tárfiókhoz. Meglévőt is használhat, ha már rendelkezik saját DAG-kkel.

   

4. Használja azt a tárfiókot, ahová feltöltötte a DAG-t. (Ellenőrizze az "Előfeltételek" szakaszt.) Tesztelje a kapcsolatot, majd válassza a Létrehozás lehetőséget.

   

5. Tallózással válassza ki a légáramlást , ha a minta SAS URL-címet használja. A DAG-fájlokat tartalmazó dags mappát tartalmazó mappát is kijelölheti.

   Feljegyzés

   Ezen a felületen keresztül importálhatja a DAG-ket és azok függőségeit. Az Airflow-környezetbe való importáláshoz ki kell választania egy címtár elérési útját egy Blob Storage-fiókból, amely dagok és beépülő modulok nevű mappákat tartalmaz. A beépülő modulok használata nem kötelező.

   

   

6. Válassza az Importálás lehetőséget a fájlok importálásához.

   

   

A DAG-k importálása eltarthat néhány percig az előzetes verzióban. Az értesítési központ (a Data Factory felhasználói felületén található harang ikon) segítségével nyomon követheti az importálási állapotfrissítéseket.