Επισκόπηση δραστηριότητας
Αυτό το άρθρο σάς βοηθά να κατανοήσετε τις δραστηριότητες στο Microsoft Fabric και να τις χρησιμοποιήσετε για τη δημιουργία ροών εργασιών βάσει δεδομένων από άκρο σε άκρο για τα σενάρια μετακίνησης δεδομένων και επεξεργασίας δεδομένων.
Επισκόπηση
Ένας χώρος εργασίας Microsoft Fabric μπορεί να έχει μία ή περισσότερες διοχετεύσεις. Μια διοχέτευση είναι μια λογική ομαδοποίηση των δραστηριοτήτων που εκτελούν μαζί μια εργασία. Για παράδειγμα, μια διοχέτευση μπορεί να περιέχει ένα σύνολο δραστηριοτήτων κατά την πρόσληψη και εκκαθάριση δεδομένων αρχείου καταγραφής και, στη συνέχεια, να εκκινεί μια ροή δεδομένων για να αναλύσει τα δεδομένα αρχείου καταγραφής. Η διοχέτευση σάς επιτρέπει να διαχειρίζεστε τις δραστηριότητες ως σύνολο αντί για κάθε μία ξεχωριστά. Αναπτύσσετε και προγραμματίζετε τη διοχέτευση αντί για τις δραστηριότητες ανεξάρτητα.
Οι δραστηριότητες σε μια διοχέτευση ορίζουν ενέργειες για εκτέλεση στα δεδομένα σας. Για παράδειγμα, μπορείτε να χρησιμοποιήσετε μια δραστηριότητα αντιγραφής για να αντιγράψετε δεδομένα από τον SQL Server σε έναν χώρο αποθήκευσης αντικειμένων blob Azure. Στη συνέχεια, χρησιμοποιήστε μια δραστηριότητα ροής δεδομένων ή μια δραστηριότητα Σημειωματάριου για να επεξεργαστείτε και μετασχηματίσετε δεδομένα από τον χώρο αποθήκευσης αντικειμένων blob σε έναν χώρο συγκέντρωσης Azure Synapse Analytics, επιπλέον των λύσεων αναφοράς επιχειρηματικής ευφυΐας που δημιουργούνται.
Το Microsoft Fabric διαθέτει τρεις τύπους δραστηριοτήτων: δραστηριότητες μετακίνησης δεδομένων, δραστηριότητες μετασχηματισμού δεδομένων και δραστηριότητες ελέγχου.
Δραστηριότητες μετακίνησης δεδομένων
Αντιγραφή δραστηριότητας στο Microsoft Fabric αντιγράφει δεδομένα από έναν χώρο αποθήκευσης δεδομένων προέλευσης σε έναν χώρο αποθήκευσης δεδομένων βύθισης. Το Fabric υποστηρίζει τους χώρους αποθήκευσης δεδομένων που αναφέρονται στο άρθρο Επισκόπηση συνδέσεων. Τα δεδομένα από οποιαδήποτε προέλευση μπορούν να εγγραφούν σε οποιονδήποτε νιπτήρα.
Για περισσότερες πληροφορίες, ανατρέξτε στο θέμα Τρόπος αντιγραφής δεδομένων με χρήση της δραστηριότητας αντιγραφής.
Δραστηριότητες μετασχηματισμού δεδομένων
Το Microsoft Fabric υποστηρίζει τις ακόλουθες δραστηριότητες μετασχηματισμού που μπορούν να προστεθούν είτε μεμονωμένα είτε να συνδεθούν με άλλη δραστηριότητα.
Για περισσότερες πληροφορίες, ανατρέξτε στο άρθρο Δραστηριότητες μετασχηματισμού δεδομένων.
| Δραστηριότητα μετασχηματισμού δεδομένων | Υπολογιστικό περιβάλλον |
|---|---|
| Αντιγραφή δεδομένων | Διαχείριση υπολογιστικής λειτουργίας από το Microsoft Fabric |
| Dataflow Gen2 | Διαχείριση υπολογιστικής λειτουργίας από το Microsoft Fabric |
| Διαγραφή δεδομένων | Διαχείριση υπολογιστικής λειτουργίας από το Microsoft Fabric |
| Fabric Notebook | Συμπλέγματα Apache Spark με διαχείριση από το Microsoft Fabric |
| Δραστηριότητα HDInsight | Συμπλέγματα Apache Spark με διαχείριση από το Microsoft Fabric |
| Ορισμός εργασίας Spark | Συμπλέγματα Apache Spark με διαχείριση από το Microsoft Fabric |
| Αποθηκευμένη διαδικασία | Azure SQL, Azure Synapse Analytics ή SQL Server |
| Δέσμη ενεργειών SQL | Azure SQL, Azure Synapse Analytics ή SQL Server |
Έλεγχος δραστηριοτήτων ροής
Υποστηρίζονται οι ακόλουθες δραστηριότητες ροής ελέγχου:
| Δραστηριότητα ελέγχου | Περιγραφή |
|---|---|
| Προσάρτηση μεταβλητής | Προσθέστε μια τιμή σε μια υπάρχουσα μεταβλητή πίνακα. |
| Δραστηριότητα δέσμης Azure | Εκτελεί μια δέσμη ενεργειών Azure Batch. |
| Δραστηριότητα Azure Databricks | Εκτελεί μια εργασία Azure Databricks (Notebook, Jar, Python). |
| Δραστηριότητα εκμάθησης μηχανής Azure | Εκτελεί μια εργασία εκμάθησης μηχανής Azure. |
| Απενεργοποίηση δραστηριότητας | Απενεργοποιεί μια άλλη δραστηριότητα. |
| Αποτυχαίνω | Προκαλέστε την αποτυχία της εκτέλεσης διοχέτευσης με ένα προσαρμοσμένο μήνυμα σφάλματος και κωδικό σφάλματος. |
| Φίλτρο | Εφαρμόστε μια παράσταση φίλτρου σε έναν πίνακα εισόδου. |
| ForEach | Η Δραστηριότητα ForEach ορίζει μια επαναλαμβανόμενη ροή στοιχείου ελέγχου στη διοχέτευση. Αυτή η δραστηριότητα χρησιμοποιείται για να επαναλαμβάνεται σε μια συλλογή και εκτελεί καθορισμένες δραστηριότητες σε έναν βρόχο. Η υλοποίηση βρόχου αυτής της δραστηριότητας είναι παρόμοια με τη δομή βρόχων Foreach στις γλώσσες προγραμματισμού. |
| Δραστηριότητα συναρτήσεων | Εκτελεί μια συνάρτηση Azure. |
| Λήψη μετα-δεδομένων | Η δραστηριότητα GetMetadata μπορεί να χρησιμοποιηθεί για την ανάκτηση μετα-δεδομένων οποιωνδήποτε δεδομένων σε ένα εργοστάσιο δεδομένων ή μια διοχέτευση Synapse. |
| Συνθήκη If | Η Συνθήκη If μπορεί να χρησιμοποιηθεί για διακλάδωση βάσει της συνθήκης που αξιολογείται ως true ή false. Η δραστηριότητα Εάν η δραστηριότητα Συνθήκη παρέχει την ίδια λειτουργικότητα που παρέχει μια δήλωση if σε γλώσσες προγραμματισμού. Αξιολογεί ένα σύνολο δραστηριοτήτων όταν η συνθήκη αξιολογείται true και ένα άλλο σύνολο δραστηριοτήτων όταν η συνθήκη αξιολογείται σε false. |
| Κλήση διοχέτευσης | Η εκτέλεση δραστηριότητας διοχέτευσης επιτρέπει σε μια διοχέτευση Data Factory ή Synapse να καλέσει μια άλλη διοχέτευση. |
| Δραστηριότητα KQL | Εκτελεί μια δέσμη ενεργειών KQL σε σχέση με μια παρουσία Kusto. |
| Δραστηριότητα αναζήτησης | Η δραστηριότητα αναζήτησης μπορεί να χρησιμοποιηθεί για την ανάγνωση ή την αναζήτηση ενός ονόματος/τιμής πίνακα εγγραφής/πίνακα από οποιαδήποτε εξωτερική προέλευση. Αυτό το αποτέλεσμα μπορεί να αναφέρεται περαιτέρω με επιτυχημένες δραστηριότητες. |
| Ορισμός μεταβλητής | Ορίστε την τιμή μιας υπάρχουσας μεταβλητής. |
| Εναλλαγή δραστηριότητας | Υλοποιεί μια παράσταση εναλλαγής που επιτρέπει πολλές επόμενες δραστηριότητες για κάθε πιθανό αποτέλεσμα της παράστασης. |
| Δραστηριότητα ομάδων | Δημοσιεύει ένα μήνυμα σε ένα κανάλι Teams ή συνομιλία ομάδας. |
| Δραστηριότητα Until | Υλοποιεί το βρόχο Do-Until που είναι παρόμοιο με τη δομή βρόχων Do-Until σε γλώσσες προγραμματισμού. Εκτελεί ένα σύνολο δραστηριοτήτων σε βρόχο, μέχρι η συνθήκη που σχετίζεται με τη δραστηριότητα να αξιολογείται ως true. Μπορείτε να καθορίσετε μια τιμή λήξης χρονικού ορίου για τη δραστηριότητα until. |
| Δραστηριότητα αναμονής | Όταν χρησιμοποιείτε μια δραστηριότητα αναμονής σε μια διοχέτευση, η διοχέτευση αναμένει τον καθορισμένο χρόνο πριν συνεχίσει με την εκτέλεση επόμενων δραστηριοτήτων. |
| Δραστηριότητα Web | Η Δραστηριότητα Web μπορεί να χρησιμοποιηθεί για την κλήση ενός προσαρμοσμένου τελικού σημείου REST από μια διοχέτευση. |
| Δραστηριότητα webhook | Χρησιμοποιώντας τη δραστηριότητα webhook, καλέστε ένα τελικό σημείο και διαβιβάστε μια διεύθυνση URL επιστροφής κλήσης. Η εκτέλεση διοχέτευσης αναμένει την κλήση της επιστροφής κλήσης πριν προχωρήσει στην επόμενη δραστηριότητα. |
Προσθήκη δραστηριοτήτων σε μια διοχέτευση με το περιβάλλον εργασίας χρήστη του Microsoft Fabric
Χρησιμοποιήστε αυτά τα βήματα για να προσθέσετε και να ρυθμίσετε τις παραμέτρους δραστηριοτήτων σε μια διοχέτευση Microsoft Fabric:
- Δημιουργήστε μια νέα διοχέτευση στον χώρο εργασίας σας.
- Στην καρτέλα Δραστηριότητες για τη διοχέτευση, περιηγηθείτε στις δραστηριότητες που εμφανίζονται, κάνοντας κύλιση στα δεξιά, εάν είναι απαραίτητο, για να δείτε όλες τις δραστηριότητες. Επιλέξτε μια δραστηριότητα για να την προσθέσετε στο πρόγραμμα επεξεργασίας διοχέτευσης.
- Όταν προσθέτετε μια δραστηριότητα και την επιλέγετε στον καμβά του προγράμματος επεξεργασίας διοχέτευσης, οι γενικές ρυθμίσεις της θα εμφανίζονται στο τμήμα παραθύρου ιδιοτήτων κάτω από τον καμβά.
- Κάθε δραστηριότητα περιέχει επίσης προσαρμοσμένες ιδιότητες ειδικά για τη ρύθμιση παραμέτρων της σε άλλες καρτέλες στο τμήμα παραθύρου ιδιοτήτων.
Γενικές ρυθμίσεις
Όταν προσθέτετε μια νέα δραστηριότητα σε μια διοχέτευση και την επιλέγετε, θα δείτε τα τμήματα παραθύρου ιδιοτήτων της στην περιοχή στο κάτω μέρος της οθόνης. Αυτά τα τμήματα παραθύρου ιδιοτήτων περιλαμβάνουν τα πεδία Γενικά, Ρυθμίσεις, καθώς και άλλα τμήματα παραθύρου.
Οι γενικές ρυθμίσεις θα περιλαμβάνουν πάντα πεδία Όνομα και Περιγραφή για κάθε δραστηριότητα. Ορισμένες δραστηριότητες περιλαμβάνουν επίσης τα εξής:
| Ρύθμιση | Περιγραφή |
|---|---|
| Timeout | Ο μέγιστος χρόνος που μπορεί να εκτελεστεί μια δραστηριότητα. Η προεπιλογή είναι 12 ώρες και το μέγιστο επιτρεπόμενο χρονικό διάστημα είναι επτά ημέρες. Η μορφή για το χρονικό όριο είναι σε D.HH:MM:SS. |
| Επανάληψη | Μέγιστος αριθμός προσπαθειών επανάληψης. |
| (Ιδιότητες για προχωρημένους) Διάστημα επανάληψης (δευτ.) | Ο αριθμός των δευτερολέπτων μεταξύ κάθε προσπάθειας επανάληψης. |
| (Ιδιότητες για προχωρημένους) Ασφαλής έξοδος | Όταν είναι επιλεγμένο, η έξοδος από τη δραστηριότητα δεν καταγράφεται στην καταγραφή. |
| (Ιδιότητες για προχωρημένους) Ασφαλής είσοδος | Όταν είναι επιλεγμένο, τα δεδομένα εισόδου από τη δραστηριότητα δεν καταγράφονται στην καταγραφή. |
Σημείωμα
Υπάρχει ένα προεπιλεγμένο μαλακό όριο έως 80 δραστηριοτήτων ανά διοχέτευση, το οποίο περιλαμβάνει εσωτερικές δραστηριότητες για κοντέινερ.