Ροές συμβάντων Microsoft Fabric - επισκόπηση

Η δυνατότητα ροών συμβάντων στην εμπειρία Ευφυΐας πραγματικού χρόνου Microsoft Fabric σάς επιτρέπει να μεταφέρετε συμβάντα σε πραγματικό χρόνο στο Fabric, να τα μετασχηματίζετε και, στη συνέχεια, να τα δρομολογείτε σε διάφορους προορισμούς χωρίς να γράφετε κώδικα (χωρίς κώδικα). Δημιουργείτε μια ροή συμβάντων, η οποία είναι μια παρουσία του στοιχείου Eventstream στο Fabric, προσθέτετε προελεύσεις δεδομένων συμβάντων στη ροή, προσθέτετε προαιρετικά μετασχηματισμούς για να μετασχηματίζετε τα δεδομένα συμβάντων και, στη συνέχεια, δρομολογείτε τα δεδομένα σε υποστηριζόμενους προορισμούς.

Εισαγωγή συμβάντων στο Fabric

Η δυνατότητα ροές συμβάντων σάς παρέχει διάφορες συνδέσεις προέλευσης για τη λήψη δεδομένων συμβάντων από τις διάφορες προελεύσεις. Υπάρχουν περισσότερες διαθέσιμες προελεύσεις όταν ενεργοποιείτε βελτιωμένες δυνατότητες κατά τη στιγμή της δημιουργίας μιας ροής συμβάντων.

Σημαντικό

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

Βελτιωμένες δυνατότητες (Προεπισκόπηση)

Πηγές	Περιγραφή
Κέντρα συμβάντων Azure	Εάν έχετε ένα κέντρο συμβάντων Azure, μπορείτε να πραγματοποιήσετε πρόσληψη δεδομένων κέντρου συμβάντων στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream.
Κέντρο Azure IoT	Εάν έχετε έναν διανομέα Azure IoT, μπορείτε να πραγματοποιήσετε πρόσληψη δεδομένων IoT στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream.
Azure Βάση δεδομένων SQL αλλαγή της καταγραφής δεδομένων (CDC)	Η σύνδεση προέλευσης Azure Βάση δεδομένων SQL CDC σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων SQL Azure. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα.
Postgre Βάση δεδομένων SQL CDC	Η σύνδεση προέλευσης Postgre Βάση δεδομένων SQL Αλλαγή δεδομένων (CDC) σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων PostgreSQL. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα.
My Βάση δεδομένων SQL CDC	Η σύνδεση προέλευσης Azure My Βάση δεδομένων SQL Change Data Capture (CDC) σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων Azure για τη βάση δεδομένων MySQL. Μπορείτε να καθορίσετε τους πίνακες για παρακολούθηση και η eventstream καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών στους πίνακες.
Azure Cosmos DB CDC	Η σύνδεση προέλευσης Azure Cosmos DB Change Data Capture (CDC) για τις ροές συμβάντων Microsoft Fabric σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων Azure Cosmos DB. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα.
Google Cloud Pub/Sub	Το Google Pub/Sub είναι μια υπηρεσία ανταλλαγής μηνυμάτων που σας επιτρέπει να δημοσιεύετε και να εγγράφεστε σε ροές συμβάντων. Μπορείτε να προσθέσετε το Google Pub/Sub ως προέλευση στο eventstream σας για να καταγράφετε, να μετασχηματίζετε και να δρομολογείτε συμβάντα σε πραγματικό χρόνο σε διάφορους προορισμούς στο Fabric.
Ροές δεδομένων Amazon Kinesis	Το Amazon Kinesis Data Ροές είναι μια εξαιρετικά κλιμακούμενη, ιδιαίτερα ανθεκτική πρόσληψη δεδομένων και υπηρεσία επεξεργασίας βελτιστοποιημένη για δεδομένα ροής. Ενσωματώνοντας το Amazon Kinesis Data Ροές ως προέλευση στο eventstream, μπορείτε να επεξεργαστείτε απρόσκοπτα ροές δεδομένων σε πραγματικό χρόνο πριν τις δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric.
Confluent Cloud Kafka	Το Confluent Cloud Kafka είναι μια πλατφόρμα ροής που προσφέρει ισχυρές λειτουργίες ροής και επεξεργασίας δεδομένων χρησιμοποιώντας το Apache Kafka. Ενσωματώνοντας το Confluent Cloud Kafka ως προέλευση στο eventstream, μπορείτε να επεξεργαστείτε απρόσκοπτα ροές δεδομένων σε πραγματικό χρόνο πριν τις δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric.
Συμβάντα Υπηρεσία αποθήκευσης αντικειμένων blob Azure	Τα συμβάντα Υπηρεσία αποθήκευσης αντικειμένων blob του Azure ενεργοποιούνται όταν ένα πρόγραμμα-πελάτης δημιουργεί, αντικαθιστά ή διαγράφει ένα αντικείμενο blob. Η σύνδεση σάς επιτρέπει να συνδέσετε συμβάντα Blob Υπηρεσία αποθήκευσης με συμβάντα Fabric στο κέντρο σε πραγματικό χρόνο. Μπορείτε να μετατρέψετε αυτά τα συμβάντα σε συνεχείς ροές δεδομένων και να τα μετασχηματίσετε πριν από τη δρομολόγηση τους σε διάφορους προορισμούς στο Fabric.
Συμβάντα στοιχείου χώρου εργασίας Fabric	Τα συμβάντα Fabric Workspace Item είναι διακριτά συμβάντα Fabric που προκύπτουν όταν γίνονται αλλαγές στον χώρο εργασίας Fabric σας. Αυτές οι αλλαγές περιλαμβάνουν τη δημιουργία, ενημέρωση ή διαγραφή ενός στοιχείου Fabric. Με τις ροές συμβάντων Fabric, μπορείτε να καταγράψετε αυτά τα συμβάντα χώρου εργασίας Fabric, να τα μετασχηματίσετε και να τα δρομολογήσετε σε διάφορους προορισμούς στο Fabric για περαιτέρω ανάλυση.
Δείγμα δεδομένων	Μπορείτε να επιλέξετε συμβάντα ποδηλάτων, κίτρινου ταξί ή χρηματιστηρίου ως δείγμα προέλευσης δεδομένων για να δοκιμάσετε την πρόσληψη δεδομένων κατά τη ρύθμιση μιας ροής συμβάντων.
Προσαρμοσμένο τελικό σημείο (πρώην προσαρμοσμένη εφαρμογή)	Η δυνατότητα προσαρμοσμένου τελικού σημείου επιτρέπει στις εφαρμογές σας ή στα προγράμματα-πελάτες Kafka να συνδεθούν στο Eventstream χρησιμοποιώντας ένα συμβολοσειρά σύνδεσης, επιτρέποντας την ομαλή πρόσληψη δεδομένων ροής στο Eventstream.

Τυπικές δυνατότητες

Πηγές	Περιγραφή
Κέντρα συμβάντων Azure	Εάν έχετε ένα κέντρο συμβάντων Azure, μπορείτε να πραγματοποιήσετε πρόσληψη δεδομένων κέντρου συμβάντων στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream.
Κέντρο Azure IoT	Εάν έχετε έναν διανομέα Azure IoT, μπορείτε να πραγματοποιήσετε πρόσληψη δεδομένων IoT στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream.
Δείγμα δεδομένων	Μπορείτε να επιλέξετε συμβάντα ποδηλάτων, κίτρινου ταξί ή χρηματιστηρίου ως δείγμα προέλευσης δεδομένων για να δοκιμάσετε την πρόσληψη δεδομένων κατά τη ρύθμιση μιας ροής συμβάντων.
Προσαρμοσμένη εφαρμογή	Η δυνατότητα προσαρμοσμένης εφαρμογής επιτρέπει στις εφαρμογές σας ή στα προγράμματα-πελάτες Kafka να συνδεθούν στο Eventstream χρησιμοποιώντας ένα συμβολοσειρά σύνδεσης, επιτρέποντας την ομαλή πρόσληψη δεδομένων ροής στο Eventstream.

Επεξεργασία συμβάντων με χρήση εμπειρίας χωρίς κώδικα

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

Μετασχηματισμός	Περιγραφή
Φίλτρο	Χρησιμοποιήστε τον μετασχηματισμό φίλτρου για να φιλτράρετε συμβάντα με βάση την τιμή ενός πεδίου στην είσοδο. Ανάλογα με τον τύπο δεδομένων (αριθμός ή κείμενο), ο μετασχηματισμός διατηρεί τις τιμές που συμφωνούν με την επιλεγμένη συνθήκη, όπως is null ή is not null.
Διαχείριση πεδίων	Ο μετασχηματισμός Διαχείριση πεδίων σάς επιτρέπει να προσθέσετε, να καταργήσετε, να αλλάξετε τον τύπο δεδομένων ή να μετονομάσετε πεδία που εισέρχονται από μια είσοδο ή έναν άλλο μετασχηματισμό.
Συγκέντρωμα	Χρησιμοποιήστε τον μετασχηματισμό Συγκεντρωτικών αποτελεσμάτων για να υπολογίσετε μια συνάθροιση (Άθροισμα, Ελάχιστο, Μέγιστο ή Μέσος όρος) κάθε φορά που παρουσιάζεται ένα νέο συμβάν σε μια χρονική περίοδο. Αυτή η λειτουργία επιτρέπει επίσης τη μετονομασία αυτών των υπολογιζόμενων στηλών και το φιλτράρισμα ή ανάλυση της συνάθροισης με βάση άλλες διαστάσεις στα δεδομένα σας. Μπορείτε να έχετε μία ή περισσότερες συναθροίσεις στον ίδιο μετασχηματισμό.
Ομαδοποίηση κατά	Χρησιμοποιήστε τον μετασχηματισμό Ομαδοποίηση κατά για να υπολογίσετε συναθροίσεις σε όλα τα συμβάντα μέσα σε ένα συγκεκριμένο χρονικό διάστημα. Μπορείτε να ομαδοποιήσετε σύμφωνα με τις τιμές σε ένα ή περισσότερα πεδία. Είναι σαν ο μετασχηματισμός συγκέντρωσης να επιτρέπει τη μετονομασία στηλών, αλλά παρέχει περισσότερες επιλογές για συνάθροιση και περιλαμβάνει πιο σύνθετες επιλογές για τα χρονικά παράθυρα. Όπως συνάθροιση, μπορείτε να προσθέσετε περισσότερες από μία συναθροίσεις ανά μετασχηματισμό.
Ένωσης	Χρησιμοποιήστε τον μετασχηματισμό Ένωσης για να συνδέσετε δύο ή περισσότερους κόμβους και να προσθέσετε συμβάντα με κοινόχρηστα πεδία (με το ίδιο όνομα και τύπο δεδομένων) σε έναν πίνακα. Τα πεδία που δεν συμφωνούν απορρίπτονται και δεν περιλαμβάνονται στην έξοδο.
Ανάπτυξη	Χρησιμοποιήστε τον μετασχηματισμό Ανάπτυξη πίνακα για να δημιουργήσετε μια νέα γραμμή για κάθε τιμή σε έναν πίνακα.
Συμμετοχή	Χρησιμοποιήστε τον μετασχηματισμό Σύνδεση για να συνδυάσετε δεδομένα από δύο ροές με βάση μια αντίστοιχη συνθήκη μεταξύ τους.

Εάν ενεργοποιήσατε τις Βελτιωμένες δυνατότητες κατά τη δημιουργία ενός eventstream, οι λειτουργίες μετασχηματισμού υποστηρίζονται για όλους τους προορισμούς (με παραγόμενη ροή να λειτουργεί ως ενδιάμεση γέφυρα για ορισμένους προορισμούς, όπως το Προσαρμοσμένο τελικό σημείο, Reflex). Εάν δεν το κάνατε, οι λειτουργίες μετασχηματισμού είναι διαθέσιμες μόνο για τους προορισμούς Βάσης δεδομένων Lakehouse και KQL (επεξεργασία συμβάντων πριν από την πρόσληψη).

Δρομολόγηση συμβάντων σε προορισμούς

Η δυνατότητα Ροές συμβάντων Fabric υποστηρίζει την αποστολή δεδομένων στους παρακάτω υποστηριζόμενους προορισμούς.

Βελτιωμένες δυνατότητες (Προεπισκόπηση)

Προορισμός	Περιγραφή
Προσαρμοσμένο τελικό σημείο (πρώην προσαρμοσμένη εφαρμογή)	Με αυτόν τον προορισμό, μπορείτε εύκολα να δρομολογήσετε τα συμβάντα σε πραγματικό χρόνο σε ένα προσαρμοσμένο τελικό σημείο. Μπορείτε να συνδέσετε τις δικές σας εφαρμογές στο eventstream και να καταναλώσετε τα δεδομένα συμβάντων σε πραγματικό χρόνο. Αυτός ο προορισμός είναι χρήσιμος όταν θέλετε να μεταφέρετε δεδομένα σε πραγματικό χρόνο σε ένα εξωτερικό σύστημα εκτός του Microsoft Fabric.
Βάση δεδομένων KQL	Αυτός ο προορισμός σάς επιτρέπει να προσλάβετε τα δεδομένα συμβάντων σε πραγματικό χρόνο σε μια βάση δεδομένων KQL, όπου μπορείτε να χρησιμοποιήσετε την ισχυρή γλώσσα ερωτημάτων Kusto (KQL) για να υποβάλετε ερωτήματα και να αναλύσετε τα δεδομένα. Με τα δεδομένα στη βάση δεδομένων Kusto, μπορείτε να αποκτήσετε βαθύτερες πληροφορίες σχετικά με τα δεδομένα συμβάντων σας και να δημιουργήσετε εμπλουτισμένες αναφορές και πίνακες εργαλείων. Μπορείτε να επιλέξετε μεταξύ δύο λειτουργιών πρόσληψης: Απευθείας πρόσληψη δεδομένων και Επεξεργασία συμβάντων πριν από την πρόσληψη.
Lakehouse	Αυτός ο προορισμός σάς δίνει τη δυνατότητα να μετασχηματίζετε τα συμβάντα πραγματικού χρόνου πριν από την κατάποσή τους στο lakehouse σας. Τα συμβάντα σε πραγματικό χρόνο μετατρέπονται σε μορφή Delta Lake και, στη συνέχεια, αποθηκεύονται στους καθορισμένους πίνακες lakehouse. Αυτός ο προορισμός υποστηρίζει σενάρια αποθήκευσης δεδομένων.
Αντανακλαστικό	Αυτός ο προορισμός σάς επιτρέπει να συνδέσετε απευθείας τα δεδομένα συμβάντων σε πραγματικό χρόνο σε ένα Reflex. Το Reflex είναι ένας τύπος ευφυούς παράγοντα που περιέχει όλες τις πληροφορίες που απαιτούνται για τη σύνδεση σε δεδομένα, την παρακολούθηση συνθηκών και την πράξη. Όταν τα δεδομένα φτάσουν σε συγκεκριμένα όρια ή αντιστοιχίσουν άλλα μοτίβα, το Reflex λαμβάνει αυτόματα τα κατάλληλα μέτρα, όπως ειδοποίηση των χρηστών ή εκκίνηση ροών εργασιών του Power Automate.
Παραγόμενη ροή	Η παραγόμενη ροή είναι ένας εξειδικευμένος τύπος προορισμού που μπορείτε να δημιουργήσετε μετά την προσθήκη λειτουργιών ροής, όπως φιλτράρισμα ή διαχείριση πεδίων, σε μια ροή συμβάντων. Η παραγόμενη ροή αντιπροσωπεύει τη μετασχηματισμένη προεπιλεγμένη ροή μετά την επεξεργασία της ροής. Μπορείτε να δρομολογήσετε την παραγόμενη ροή σε πολλούς προορισμούς στο Fabric και να προβάλετε την παραγόμενη ροή στο κέντρο σε πραγματικό χρόνο.

Μπορείτε να επισυνάψετε πολλούς προορισμούς σε ένα eventstream για να λαμβάνετε ταυτόχρονα δεδομένα από τη ροή συμβάντων χωρίς να παρεμβάλλετε ο ένας στον άλλο.

Τυπικές δυνατότητες

Προορισμός	Περιγραφή
Προσαρμοσμένη εφαρμογή	Με αυτόν τον προορισμό, μπορείτε εύκολα να δρομολογήσετε τα συμβάντα σε πραγματικό χρόνο σε μια προσαρμοσμένη εφαρμογή. Σας επιτρέπει να συνδέσετε τις δικές σας εφαρμογές στο eventstream και να καταναλώσετε τα δεδομένα συμβάντων σε πραγματικό χρόνο. Είναι χρήσιμο όταν θέλετε να μεταφέρετε δεδομένα σε πραγματικό χρόνο σε ένα εξωτερικό σύστημα που βρίσκεται εκτός του Microsoft Fabric.
Βάση δεδομένων KQL	Αυτός ο προορισμός σάς επιτρέπει να προσλάβετε τα δεδομένα συμβάντων σε πραγματικό χρόνο σε μια βάση δεδομένων KQL, όπου μπορείτε να χρησιμοποιήσετε την ισχυρή γλώσσα ερωτημάτων Kusto (KQL) για να υποβάλετε ερωτήματα και να αναλύσετε τα δεδομένα. Με τα δεδομένα στη βάση δεδομένων Kusto, μπορείτε να αποκτήσετε βαθύτερες πληροφορίες σχετικά με τα δεδομένα συμβάντων σας και να δημιουργήσετε εμπλουτισμένες αναφορές και πίνακες εργαλείων. Μπορείτε να επιλέξετε μεταξύ δύο λειτουργιών πρόσληψης: Απευθείας πρόσληψη δεδομένων και Επεξεργασία συμβάντων πριν από την πρόσληψη.
Lakehouse	Αυτός ο προορισμός σάς δίνει τη δυνατότητα να μετασχηματίζετε τα συμβάντα σε πραγματικό χρόνο πριν από την πρόσληψη συμβάντων στο lakehouse σας. Τα συμβάντα σε πραγματικό χρόνο μετατρέπονται σε μορφή Delta Lake και, στη συνέχεια, αποθηκεύονται στους καθορισμένους πίνακες lakehouse. Σας βοηθά με το σενάριο αποθήκευσης δεδομένων. Για να μάθετε περισσότερα σχετικά με τον τρόπο χρήσης του επεξεργαστή συμβάντων για την επεξεργασία δεδομένων σε πραγματικό χρόνο, ανατρέξτε στο θέμα Επεξεργασία δεδομένων συμβάντων με το πρόγραμμα επεξεργασίας συμβάντων.
Αντανακλαστικό	Αυτός ο προορισμός σάς επιτρέπει να συνδέσετε απευθείας τα δεδομένα συμβάντων σε πραγματικό χρόνο σε ένα Reflex. Το Reflex είναι ένας τύπος ευφυούς παράγοντα που περιέχει όλες τις πληροφορίες που απαιτούνται για τη σύνδεση σε δεδομένα, την παρακολούθηση συνθηκών και την πράξη. Όταν τα δεδομένα φτάσουν σε συγκεκριμένα όρια ή αντιστοιχίσουν άλλα μοτίβα, το Reflex λαμβάνει αυτόματα τα κατάλληλα μέτρα, όπως ειδοποίηση των χρηστών ή εκκίνηση ροών εργασιών του Power Automate.

Μπορείτε να επισυνάψετε πολλούς προορισμούς σε ένα eventstream για να λαμβάνετε ταυτόχρονα δεδομένα από τη ροή συμβάντων χωρίς να παρεμβάλλετε ο ένας στον άλλο.

Σημείωμα

Συνιστούμε να χρησιμοποιήσετε τη δυνατότητα ροών συμβάντων Microsoft Fabric με τουλάχιστον 4 μονάδες εκχωρημένων πόρων (SKU: F4)

Βελτιωμένες δυνατότητες (προεπισκόπηση)

Υπάρχουν περισσότερες δυνατότητες, προελεύσεις και προορισμοί διαθέσιμοι όταν ενεργοποιείτε την επιλογή Βελτιωμένες δυνατότητες (προεπισκόπηση) κατά τη δημιουργία ενός eventstream. Χρησιμοποιήστε τις καρτέλες Βελτιωμένες δυνατότητες (προεπισκόπηση) και Τυπικές δυνατότητες για να μάθετε σχετικά με πρόσθετες προελεύσεις και προορισμούς που υποστηρίζονται με τις βελτιωμένες δυνατότητες.

Ακολουθούν μερικές άλλες αξιοσημείωτες δυνατότητες των Βελτιωμένων δυνατοτήτων (προεπισκόπηση):

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

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

• Δημιουργία και διαχείριση μιας ροής συμβάντων στο Microsoft Fabric