Δρομολόγηση ροών δεδομένων με βάση το περιεχόμενο σε ροές συμβάντων Fabric
Αυτό το άρθρο περιγράφει τον τρόπο δρομολόγησης συμβάντων που βασίζονται σε περιεχόμενο στις ροές συμβάντων microsoft Fabric.
Τώρα, μπορείτε να χρησιμοποιήσετε το πρόγραμμα επεξεργασίας χωρίς κώδικα στον κύριο καμβά ροής συμβάντων Fabric για να δημιουργήσετε σύνθετη λογική επεξεργασίας ροής χωρίς τη σύνταξη κώδικα. Αυτή η δυνατότητα σάς επιτρέπει να προσαρμόζετε, να μετασχηματίζετε και να διαχειρίζεστε τις ροές δεδομένων σας πιο εύκολα. Αφού ορίσετε τις λειτουργίες επεξεργασίας ροής, μπορείτε να στείλετε ομαλά τις ροές δεδομένων σας σε διαφορετικούς προορισμούς, σύμφωνα με το συγκεκριμένο σχήμα και τα δεδομένα ροής.
Υποστηριζόμενες λειτουργίες
Ακολουθεί η λίστα των λειτουργιών που υποστηρίζονται για την επεξεργασία δεδομένων σε πραγματικό χρόνο:
Συγκεντρωτικά: Υποστηρίζουν συναρτήσεις SUM, AVG, MIN και MAX που εκτελούν υπολογισμούς σε μια στήλη τιμών, επιστρέφοντας ένα μοναδικό αποτέλεσμα.
Ανάπτυξη: Αναπτύξτε μια τιμή πίνακα και δημιουργήστε μια νέα γραμμή για κάθε τιμή σε έναν πίνακα.
Φίλτρο: Επιλέξτε ή φιλτράρετε συγκεκριμένες γραμμές από τη ροή δεδομένων βάσει μιας συνθήκης.
Ομαδοποίηση κατά: Συγκεντρώστε όλα τα δεδομένα συμβάντων μέσα σε ένα συγκεκριμένο χρονικό διάστημα, με την επιλογή να ομαδοποιήσετε μία ή περισσότερες στήλες.
Διαχείριση πεδίων: Προσθήκη, κατάργηση ή αλλαγή του τύπου δεδομένων ενός πεδίου ή στήλης των ροών δεδομένων σας.
Ένωση: Συνδέστε δύο ή περισσότερες ροές δεδομένων με κοινόχρηστα πεδία με το ίδιο όνομα και τύπο δεδομένων σε μία ροή δεδομένων. Τα πεδία που δεν συμφωνούν απορρίπτονται.
Σύνδεση: Συνδυάστε δεδομένα από δύο ροές βάσει μιας αντίστοιχης συνθήκης μεταξύ τους.
Υποστηριζόμενοι προορισμοί
Οι υποστηριζόμενοι προορισμοί είναι:
Lakehouse: Αυτός ο προορισμός σας δίνει τη δυνατότητα να μετασχηματίζετε τα συμβάντα σε πραγματικό χρόνο πριν την πρόσληψη στο lakehouse σας. Τα συμβάντα σε πραγματικό χρόνο μετατρέπονται σε μορφή Delta Lake και, στη συνέχεια, αποθηκεύονται στους καθορισμένους πίνακες lakehouse. Αυτός ο προορισμός βοηθά με τα σενάρια αποθήκευσης δεδομένων.
eventhouse: Αυτός ο προορισμός σάς επιτρέπει να προσλάβετε τα δεδομένα συμβάντων σε πραγματικό χρόνο στο Eventhouse, όπου μπορείτε να χρησιμοποιήσετε την ισχυρή Γλώσσα ερωτημάτων Kusto (KQL) για να υποβάλετε ερωτήματα και να αναλύσετε τα δεδομένα. Με τα δεδομένα στο Eventhouse, μπορείτε να αποκτήσετε βαθύτερες πληροφορίες σχετικά με τα δεδομένα συμβάντων σας και να δημιουργήσετε εμπλουτισμένες αναφορές και πίνακες εργαλείων.
Ενεργοποιητής Fabric: Αυτός ο προορισμός σάς επιτρέπει να συνδέσετε απευθείας τα δεδομένα συμβάντων σε πραγματικό χρόνο σε έναν Ενεργοποιητή Fabric. Ο ενεργοποιητής είναι ένας τύπος ευφυούς παράγοντα που περιέχει όλες τις πληροφορίες που απαιτούνται για τη σύνδεση δεδομένων, την παρακολούθηση συνθηκών και την πράξη. Όταν τα δεδομένα φτάσουν σε συγκεκριμένα όρια ή αντιστοιχίσουν άλλα μοτίβα, η συνάρτηση Activator λαμβάνει αυτόματα τα κατάλληλα μέτρα, όπως ειδοποίηση των χρηστών ή εκκίνηση ροών εργασιών του Power Automate.
Προσαρμοσμένο τελικό σημείο (πρώην προσαρμοσμένη εφαρμογή): Με αυτόν τον προορισμό, μπορείτε εύκολα να δρομολογήσετε τα συμβάντα σε πραγματικό χρόνο σε μια προσαρμοσμένη εφαρμογή. Αυτός ο προορισμός σάς επιτρέπει να συνδέσετε τις δικές σας εφαρμογές στο eventstream και να καταναλώσετε τα δεδομένα συμβάντων σε πραγματικό χρόνο. Είναι χρήσιμο όταν θέλετε να εξάγετε δεδομένα σε πραγματικό χρόνο σε ένα εξωτερικό σύστημα εκτός του Microsoft Fabric.
Stream: Αυτός ο προορισμός αντιπροσωπεύει την προεπιλεγμένη ανεπεξέργαστα ανεπεξέργαστα συμβάντα που μετασχηματίζονται από μια σειρά λειτουργιών που ονομάζονται επίσης παραγόμενη ροή. Αφού δημιουργηθεί, μπορείτε να δείτε τη ροή από το κέντρο "Πραγματικός χρόνος".
Το παρακάτω παράδειγμα δείχνει πώς τρεις διακριτοί προορισμοί eventstream fabric μπορούν να εξυπηρετήσουν ξεχωριστές συναρτήσεις για μια μοναδική προέλευση ροής δεδομένων. Ένα Eventhouse έχει καθοριστεί για την αποθήκευση ανεπεξέργαστων δεδομένων, ένα δεύτερο Eventhouse προορίζεται για τη διατήρηση φιλτραρισμένων ροών δεδομένων και το Lakehouse χρησιμοποιείται για την αποθήκευση συγκεντρωτικών τιμών.
Για να μετασχηματίζετε και να δρομολογείτε τη ροή δεδομένων σας με βάση το περιεχόμενο, ακολουθήστε τα βήματα στην ενότητα Επεξεργασία και δημοσίευση μιας ροής συμβάντων και ξεκινήστε τη σχεδίαση λογικής επεξεργασίας ροής για τη ροή δεδομένων σας.