Κοινή χρήση μέσω

Γρήγορη εκκίνηση: Δημιουργία εργασίας ροής αέρα Apache

  • Άρθρο

Σημείωμα

Η εργασία Airflow Apache υποστηρίζεται από το Apache Airflow.
Το Apache Airflow είναι μια πλατφόρμα ανοιχτού κώδικα που χρησιμοποιείται για τη δημιουργία, τον προγραμματισμό και την παρακολούθηση σύνθετων εργασιών μέσω προγραμματισμού. Σας επιτρέπει να ορίσετε ένα σύνολο εργασιών, που ονομάζονται τελεστές, που μπορούν να συνδυαστούν σε κατευθυνμένα κυκλικά γραφήματα (DAGs) για την αναπαράσταση διοχετεύσεων δεδομένων.

Η εργασία Airflow Apache παρέχει έναν απλό και αποτελεσματικό τρόπο για να δημιουργείτε και να διαχειρίζεστε περιβάλλοντα Airflow Apache, δίνοντάς σας τη δυνατότητα να εκτελείτε εύκολα τις εργασίες ενορχήστρωσης σε κλίμακα. Σε αυτή τη γρήγορη εκκίνηση, ας δημιουργήσουμε μια απλή εργασία Airflow Apache για να εξοικειωθείτε με το περιβάλλον και τις λειτουργίες της εργασίας airflow Apache.

Προαπαιτούμενα στοιχεία

  • Ενεργοποιήστε την εργασία Airflow Apache στον μισθωτή σας.

Σημείωμα

Δεδομένου ότι η εργασία Airflow Apache βρίσκεται σε κατάσταση προεπισκόπησης, πρέπει να την ενεργοποιήσετε μέσω του διαχειριστή μισθωτή σας. Εάν βλέπετε ήδη την Εργασία airflow Apache, ο διαχειριστής μισθωτή σας μπορεί να την έχει ήδη ενεργοποιήσει.

  1. Μεταβείτε στην Πύλη διαχείρισης -> Ρυθμίσεις μισθωτή -> Στην περιοχή Microsoft Fabric -> Αναπτύξτε την ενότητα "Οι χρήστες μπορούν να δημιουργήσουν και να χρησιμοποιήσουν την εργασία ροής αέρα Apache (προεπισκόπηση)".
  2. Επιλέξτε Εφαρμογή.

Στιγμιότυπο οθόνης για την ενεργοποίηση της ροής αέρα Apache στον μισθωτή.

Δημιουργία εργασίας ροής αέρα Apache

  1. Μπορείτε να χρησιμοποιήσετε έναν υπάρχοντα χώρο εργασίας ή να δημιουργήσετε έναν νέο χώρο εργασίας.

  2. Ανάπτυξη + New αναπτυσσόμενης λίστας -> Κάντε κλικ στην ενότητα Περισσότερες επιλογές -> Στην Data Factory ενότητα -> Επιλέξτε Εργασία ροής αέρα Apache (προεπισκόπηση)

    Στιγμιότυπο οθόνης που εμφανίζει κλικ σε περισσότερες επιλογές.

    Στιγμιότυπο οθόνης για την επιλογή εργασίας airflow Apache.

  3. Δώστε ένα κατάλληλο όνομα στο έργο σας και κάντε κλικ στο κουμπί "Δημιουργία".

Δημιουργία αρχείου DAG

  1. Κάντε κλικ στην κάρτα "Νέο αρχείο DAG" -> δώστε το όνομα του αρχείου και κάντε κλικ στο κουμπί "Δημιουργία".

    Στιγμιότυπο οθόνης για το όνομα του αρχείου DAG.

  2. Σας παρουσιάζεται ένας κωδικός DAG με στερεότυπο. Μπορείτε να επεξεργαστείτε το αρχείο σύμφωνα με τις απαιτήσεις σας.

    Στιγμιότυπο οθόνης που παρουσιάζει το αρχείο DAG με λέβητα στο Microsoft Fabric.

  3. Κάντε κλικ στο κουμπί "Αποθήκευση εικονιδίου".

    Στιγμιότυπο οθόνης που παρουσιάζει τον τρόπο αποθήκευσης ενός αρχείου DAG στο Microsoft Fabric.

Εκτέλεση DAG

  1. Ξεκινήστε κάνοντας κλικ στο κουμπί "Εκτέλεση DAG".

    Στιγμιότυπο οθόνης για την εκτέλεση του DAG από περιβάλλον εργασίας δεδομένων.

  2. Όταν ξεκινήσει, θα εμφανιστεί αμέσως μια ειδοποίηση που υποδεικνύει ότι το DAG εκτελείται.

  3. Για να παρακολουθείτε την πρόοδο της εκτέλεσης DAG, απλώς κάντε κλικ στην επιλογή "Προβολή λεπτομερειών" στο κέντρο ειδοποιήσεων. Αυτή η ενέργεια θα σας ανακατευθύνει στο περιβάλλον εργασίας χρήστη του Airflow Apache, όπου μπορείτε να παρακολουθείτε εύκολα την κατάσταση και τις λεπτομέρειες της εκτέλεσης DAG.

    Στιγμιότυπο οθόνης για περιήγηση στο περιβάλλον εργασίας χρήστη του Apache Airflow από το κέντρο ειδοποιήσεων.

Παρακολούθηση του DAG ροής αέρα Apache στο περιβάλλον εργασίας χρήστη της ροής αέρα Apache

Τα αποθηκευμένα αρχεία dag φορτώνονται στο περιβάλλον εργασίας χρήστη του Airflow Apache. Μπορείτε να τις παρακολουθείτε κάνοντας κλικ στο κουμπί "Παρακολούθηση στην ροή αέρα Apache".

Στιγμιότυπο οθόνης για την παρακολούθηση του DAG ροής αέρα.

Στιγμιότυπο οθόνης που εμφανίζει το φορτωμένο DAG ροής αέρα.

Σχετικό περιεχόμενο