DAG's importeren met behulp van Azure Blob Storage
Notitie
Deze functie is beschikbaar voor openbare preview. Workflow Orchestration Manager wordt mogelijk gemaakt door Apache Airflow.
In dit artikel vindt u stapsgewijze instructies voor het importeren van gerichte acyclische grafieken (DAG's) in Workflow Orchestration Manager met behulp van Azure Blob Storage.
Vereisten
- Azure-abonnement: Als u geen Azure-abonnement hebt, maakt u een gratis Azure-account voordat u begint.
- Azure Data Factory: maak of selecteer een bestaand Data Factory-exemplaar in een regio waarin de preview-versie van Workflow Orchestration Manager wordt ondersteund.
- Azure Storage-account: Als u geen opslagaccount hebt, raadpleegt u Een Azure Storage-account maken voor stappen om er een te maken. Zorg ervoor dat het opslagaccount alleen toegang toestaat vanuit geselecteerde netwerken.
Blob Storage achter virtuele netwerken wordt niet ondersteund tijdens de preview. Azure Key Vault-configuratie wordt storageLinkedServices niet ondersteund voor het importeren van DAG's.
DAG's importeren
Kopieer voorbeeld van Apache Airflow v2.x DAG of Voorbeeld van Apache Airflow v1.10 DAG op basis van de Airflow-omgeving die u hebt ingesteld. Plak de inhoud in een nieuw bestand met de naam tutorial.py.
Upload het tutorial.py-bestand naar Blob Storage. Zie Een bestand uploaden naar een blob voor meer informatie.
Notitie
U moet een mappad selecteren in een Blob Storage-account met mappen met de naam dags en invoegtoepassingen om deze te importeren in de Airflow-omgeving. Invoegtoepassingen zijn niet verplicht. U kunt ook een container met de naam dags hebben en alle Airflow-bestanden erin uploaden .
Selecteer Apache Airflow onder de hub Beheren. Beweeg vervolgens de muisaanwijzer over de eerder gemaakte Airflow-omgeving en selecteer Bestanden importeren om alle DAG's en afhankelijkheden te importeren in de Airflow-omgeving.
Maak een nieuwe gekoppelde service voor het toegankelijke opslagaccount dat wordt vermeld in de sectie Vereisten. U kunt ook een bestaande gebruiken als u al uw eigen DAG's hebt.
Gebruik het opslagaccount waar u de DAG hebt geüpload. (Controleer de sectie Vereisten.) Test de verbinding en selecteer Vervolgens Maken.
Blader en selecteer airflow als u de SAS-voorbeeld-URL gebruikt. U kunt ook de map met de dags-map met DAG-bestanden selecteren.
Notitie
U kunt DAG's en hun afhankelijkheden importeren via deze interface. U moet een mappad selecteren in een Blob Storage-account met mappen met de naam dags en invoegtoepassingen om deze te importeren in de Airflow-omgeving. Invoegtoepassingen zijn niet verplicht.
Selecteer Importeren om bestanden te importeren.
Het importeren van DAG's kan enkele minuten duren tijdens de preview. U kunt het meldingencentrum (belpictogram in de gebruikersinterface van Data Factory) gebruiken om importstatusupdates bij te houden.