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

Δρομολόγηση ροών δεδομένων που βασίζονται σε περιεχόμενο σε ροές συμβάντων Fabric (προεπισκόπηση)

  • Άρθρο

Αυτό το άρθρο περιγράφει τον τρόπο δρομολόγησης συμβάντων που βασίζονται σε περιεχόμενο στις ροές συμβάντων microsoft Fabric.

Τώρα, μπορείτε να χρησιμοποιήσετε το πρόγραμμα επεξεργασίας χωρίς κώδικα στον κύριο καμβά ροής συμβάντων Fabric για να δημιουργήσετε σύνθετη λογική επεξεργασίας ροής χωρίς τη σύνταξη κώδικα. Αυτή η δυνατότητα σάς επιτρέπει να προσαρμόζετε, να μετασχηματίζετε και να διαχειρίζεστε τις ροές δεδομένων σας πιο εύκολα. Αφού ορίσετε τις λειτουργίες επεξεργασίας ροής, μπορείτε να στείλετε ομαλά τις ροές δεδομένων σας σε διαφορετικούς προορισμούς, σύμφωνα με το συγκεκριμένο σχήμα και τα δεδομένα ροής.

Σημαντικό

Οι βελτιωμένες δυνατότητες των ροών συμβάντων Fabric είναι αυτήν τη στιγμή σε προεπισκόπηση.

Υποστηριζόμενες λειτουργίες

Ακολουθεί η λίστα των λειτουργιών που υποστηρίζονται για την επεξεργασία δεδομένων σε πραγματικό χρόνο:

  • Συγκεντρωτικά: Υποστηρίζουν συναρτήσεις SUM, AVG, MIN και MAX που εκτελούν υπολογισμούς σε μια στήλη τιμών, επιστρέφοντας ένα μοναδικό αποτέλεσμα.

  • Ανάπτυξη: Αναπτύξτε μια τιμή πίνακα και δημιουργήστε μια νέα γραμμή για κάθε τιμή σε έναν πίνακα.

  • Φίλτρο: Επιλέξτε ή φιλτράρετε συγκεκριμένες γραμμές από τη ροή δεδομένων βάσει μιας συνθήκης.

  • Ομαδοποίηση κατά: Συγκεντρώστε όλα τα δεδομένα συμβάντων μέσα σε ένα συγκεκριμένο χρονικό διάστημα, με την επιλογή να ομαδοποιήσετε μία ή περισσότερες στήλες.

  • Διαχείριση πεδίων: Προσθήκη, κατάργηση ή αλλαγή του τύπου δεδομένων ενός πεδίου ή στήλης των ροών δεδομένων σας.

  • Ένωση: Σύνδεση δύο ή περισσότερες ροές δεδομένων με κοινόχρηστα πεδία με το ίδιο όνομα και τύπο δεδομένων σε μία ροή δεδομένων. Τα πεδία που δεν συμφωνούν απορρίπτονται.

  • Σύνδεση: Συνδυάστε δεδομένα από δύο ροές βάσει μιας αντίστοιχης συνθήκης μεταξύ τους.

Υποστηριζόμενοι προορισμοί

Οι υποστηριζόμενοι προορισμοί είναι:

  • Lakehouse: Αυτός ο προορισμός σάς δίνει τη δυνατότητα να μετασχηματίζετε τα συμβάντα πραγματικού χρόνου πριν την κατάποση στο lakehouse σας. Τα συμβάντα σε πραγματικό χρόνο μετατρέπονται σε μορφή Delta Lake και, στη συνέχεια, αποθηκεύονται στους καθορισμένους πίνακες lakehouse. Αυτός ο προορισμός βοηθά με τα σενάρια αποθήκευσης δεδομένων.

  • Βάση δεδομένων KQL: Αυτός ο προορισμός σάς επιτρέπει να προσλάβετε τα δεδομένα συμβάντων σε πραγματικό χρόνο στη βάση δεδομένων KQL, όπου μπορείτε να χρησιμοποιήσετε την ισχυρή γλώσσα ερωτημάτων Kusto (KQL) για να υποβάλετε ερωτήματα και να αναλύσετε τα δεδομένα. Με τα δεδομένα στη βάση δεδομένων KQL, μπορείτε να αποκτήσετε βαθύτερες πληροφορίες σχετικά με τα δεδομένα συμβάντων σας και να δημιουργήσετε εμπλουτισμένες αναφορές και πίνακες εργαλείων.

  • Reflex: Αυτός ο προορισμός σάς επιτρέπει να συνδέσετε απευθείας τα δεδομένα συμβάντων σε πραγματικό χρόνο σε ένα Reflex. Το Reflex είναι ένας τύπος ευφυούς παράγοντα που περιέχει όλες τις πληροφορίες που απαιτούνται για τη σύνδεση σε δεδομένα, την παρακολούθηση συνθηκών και την πράξη. Όταν τα δεδομένα φτάσουν σε συγκεκριμένα όρια ή αντιστοιχίσουν άλλα μοτίβα, το Reflex λαμβάνει αυτόματα τα κατάλληλα μέτρα, όπως ειδοποίηση των χρηστών ή εκκίνηση ροών εργασιών του Power Automate.

  • Προσαρμοσμένο τελικό σημείο (πρώην προσαρμοσμένη εφαρμογή): Με αυτόν τον προορισμό, μπορείτε εύκολα να δρομολογήσετε τα συμβάντα σε πραγματικό χρόνο σε μια προσαρμοσμένη εφαρμογή. Αυτός ο προορισμός σάς επιτρέπει να συνδέσετε τις δικές σας εφαρμογές στο eventstream και να καταναλώσετε τα δεδομένα συμβάντων σε πραγματικό χρόνο. Είναι χρήσιμο όταν θέλετε να εξάγετε δεδομένα σε πραγματικό χρόνο σε ένα εξωτερικό σύστημα εκτός του Microsoft Fabric.

  • Stream: Αυτός ο προορισμός αντιπροσωπεύει την προεπιλεγμένη ανεπεξέργαστα ανεπεξέργαστα συμβάντα που μετασχηματίζονται από μια σειρά λειτουργιών που ονομάζονται επίσης παραγόμενη ροή. Αφού δημιουργηθεί, μπορείτε να δείτε τη ροή από το κέντρο "Πραγματικός χρόνος".

Το παρακάτω παράδειγμα δείχνει πώς τρεις διακριτοί προορισμοί eventstream fabric μπορούν να εξυπηρετήσουν ξεχωριστές συναρτήσεις για μια μοναδική προέλευση ροής δεδομένων. Μία βάση δεδομένων KQL έχει καθοριστεί για την αποθήκευση ανεπεξέργαστων δεδομένων, μια δεύτερη βάση δεδομένων KQL προορίζεται για τη διατήρηση φιλτραρισμένων ροών δεδομένων και το Lakehouse χρησιμοποιείται για την αποθήκευση συγκεντρωτικών τιμών.

Ένα στιγμιότυπο οθόνης της δρομολόγησης συμβάντων βάσει περιεχομένου.

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

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