Επισκόπηση των ροών συμβάντων Microsoft Fabric

Μπορείτε να χρησιμοποιήσετε τη λειτουργία ροών συμβάντων στο Microsoft Fabric Real-Time Intelligence για να Fabric συμβάντα σε πραγματικό χρόνο, να τα μεταμορφώσετε και, στη συνέχεια, να τα στείλετε σε διάφορους προορισμούς χωρίς να γράψετε κώδικα. Μπορείτε να δημιουργήσετε μια ροή συμβάντων, να προσθέσετε προελεύσεις δεδομένων συμβάντων στη ροή, προαιρετικά να προσθέσετε μετασχηματισμούς για να μετασχηματίσετε τα δεδομένα συμβάντος και, στη συνέχεια, να στείλετε τα δεδομένα σε υποστηριζόμενους προορισμούς.

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

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

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

Source Περιγραφή
Azure Data Explorer (προεπισκόπηση) Εάν έχετε μια βάση δεδομένων Azure Data Explorer και έναν πίνακα, μπορείτε να προσλάβετε δεδομένα από τον πίνακα στο Microsoft Fabric χρησιμοποιώντας ροές συμβάντων.
Κέντρα συμβάντων Azure Εάν έχετε ένα κέντρο συμβάντων Azure, μπορείτε να προσλάβετε δεδομένα κέντρου συμβάντων στο Fabric χρησιμοποιώντας ροές συμβάντων.
Πλέγμα συμβάντων Azure Εάν έχετε έναν χώρο ονομάτων πλέγματος συμβάντων Azure, μπορείτε να προσλάβετε δεδομένα τηλεμετρίας ουράς μηνυμάτων (MQTT) ή μη MQTT στο Fabric χρησιμοποιώντας ροές συμβάντων.
Δίαυλος υπηρεσίας Azure Μπορείτε να προσλάβετε δεδομένα από μια ουρά διαύλου υπηρεσίας Azure ή τη συνδρομή ενός θέματος στο Fabric χρησιμοποιώντας ροές συμβάντων.
Κέντρο Azure IoT Εάν έχετε έναν διανομέα IoT Azure, μπορείτε να προσλάβετε δεδομένα IoT στο Fabric χρησιμοποιώντας ροές συμβάντων.
Συμβάντα ανίχνευσης ανωμαλιών (έκδοση προεπισκόπησης) Μπορείτε να προσλάβετε δεδομένα από έναν ανιχνευτή ανωμαλιών στο Fabric χρησιμοποιώντας ροές συμβάντων.
Προσαρμοσμένο τελικό σημείο (δηλαδή, προσαρμοσμένη εφαρμογή σε τυπική δυνατότητα) Η δυνατότητα προσαρμοσμένου τελικού σημείου επιτρέπει στις εφαρμογές σας ή στους πελάτες Kafka να συνδέονται σε ροές συμβάντων χρησιμοποιώντας μια συμβολοσειρά σύνδεσης. Αυτή η σύνδεση επιτρέπει την ομαλή απορρόφηση δεδομένων ροής σε ροές συμβάντων.
Azure IoT Operations Ρυθμίστε τις παραμέτρους του Azure IoT Operations για την αποστολή δεδομένων σε πραγματικό χρόνο απευθείας στο Fabric Real-Time Intelligence χρησιμοποιώντας ένα προσαρμοσμένο τελικό σημείο ροής συμβάντων. Αυτή η δυνατότητα υποστηρίζει έλεγχο ταυτότητας Microsoft Entra ID ή απλού ελέγχου ταυτότητας και επιπέδου ασφαλείας (SASL).
Δείγμα δεδομένων Μπορείτε να επιλέξετε Ποδήλατα, Κίτρινο ταξί, Χρηματιστήριο, Λεωφορεία, μετοχές εταιρειών του S&P 500 ή Αρχεία καταγραφής σημασιολογικών μοντέλων ως δείγμα προέλευσης δεδομένων για να ελέγξετε την πρόσληψη δεδομένων κατά τη ρύθμιση μιας ροής συμβάντων.
Καιρός σε πραγματικό χρόνο Μπορείτε να προσθέσετε μια πηγή καιρού σε πραγματικό χρόνο σε μια ροή συμβάντων για ροή δεδομένων καιρού σε πραγματικό χρόνο από διάφορες τοποθεσίες.
Καταγραφή δεδομένων αλλαγής βάσης δεδομένων SQL Azure (CDC) Μπορείτε να χρησιμοποιήσετε τη σύνδεση προέλευσης CDC βάσης δεδομένων SQL Azure για να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων SQL Azure. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα. Με το DeltaFlow (Προεπισκόπηση), μπορείτε να μετατρέψετε μη επεξεργασμένα συμβάντα CDC σε ροές έτοιμες για ανάλυση.
Oracle Database CDC (έκδοση προεπισκόπησης) Μπορείτε να χρησιμοποιήσετε τη σύνδεση προέλευσης CDC της βάσης δεδομένων Oracle για να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων της Oracle. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα.
Βάση δεδομένων PostgreSQL CDC Μπορείτε να χρησιμοποιήσετε τη σύνδεση προέλευσης PostgreSQL CDC για να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων PostgreSQL. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα. Με το DeltaFlow (Προεπισκόπηση), μπορείτε να μετατρέψετε μη επεξεργασμένα συμβάντα CDC σε ροές έτοιμες για ανάλυση.
HTTP (έκδοση προεπισκόπησης) Μπορείτε να χρησιμοποιήσετε τη σύνδεση HTTP για τη ροή δεδομένων από εξωτερικές πλατφόρμες σε μια ροή συμβάντων, χρησιμοποιώντας τυπικές αιτήσεις HTTP. Προσφέρει επίσης προκαθορισμένες δημόσιες ροές δεδομένων με κεφαλίδες και παραμέτρους αυτόματης συμπλήρωσης, ώστε να μπορείτε να ξεκινήσετε γρήγορα χωρίς περίπλοκη ρύθμιση.
MongoDB CDC (προεπισκόπηση) Η σύνδεση προέλευσης MongoDB CDC για ροές συμβάντων Fabric καταγράφει ένα αρχικό στιγμιότυπο δεδομένων από το MongoDB. Μπορείτε να καθορίσετε τις συλλογές που θα παρακολουθούνται και η ροή συμβάντων παρακολουθεί και καταγράφει τις αλλαγές σε πραγματικό χρόνο σε έγγραφα σε επιλεγμένες βάσεις δεδομένων και συλλογές.
Βάση δεδομένων MySQL CDC Μπορείτε να χρησιμοποιήσετε τη σύνδεση προέλευσης CDC βάσης δεδομένων MySQL για να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων Azure για βάση δεδομένων MySQL. Μπορείτε να καθορίσετε τους πίνακες για παρακολούθηση και η eventstream καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών στους πίνακες.
Azure Cosmos DB CDC Μπορείτε να χρησιμοποιήσετε τη σύνδεση προέλευσης CDC Azure Cosmos DB για ροές συμβάντων Fabric για να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων Azure Cosmos DB. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα.
SQL Server σε βάση δεδομένων εικονικής μηχανής (VM) (DB) CDC Μπορείτε να χρησιμοποιήσετε τη σύνδεση προέλευσης SQL Server on VM DB CDC για ροές συμβάντων Fabric για να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων SQL Server σε μια εικονική μηχανή. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών στα δεδομένα. Με το DeltaFlow (Προεπισκόπηση), μπορείτε να μετατρέψετε μη επεξεργασμένα συμβάντα CDC σε ροές έτοιμες για ανάλυση.
Azure SQL Managed Instance CDC Μπορείτε να χρησιμοποιήσετε τη σύνδεση προέλευσης CDC διαχειριζόμενης παρουσίας Azure SQL για ροές συμβάντων Fabric για να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων διαχειριζόμενης παρουσίας SQL. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα. Με το DeltaFlow (Προεπισκόπηση), μπορείτε να μετατρέψετε μη επεξεργασμένα συμβάντα CDC σε ροές έτοιμες για ανάλυση.
Ροή αλλαγών βάσης δεδομένων κατοπτρισμού (έκδοση προεπισκόπησης) Μπορείτε να χρησιμοποιήσετε τη σύνδεση προέλευσης κατοπτρικής βάσης δεδομένων (αλλαγή τροφοδοσίας) για ροές συμβάντων Fabric για να προσλάβετε συμβάντα αλλαγής σε πραγματικό χρόνο από μια βάση δεδομένων Fabric με κατοπτρισμό. Η σύνδεση καταγράφει εισαγωγές, ενημερώσεις και διαγραφές καθώς συμβαίνουν στη βάση δεδομένων κατοπτρισμού και τις μεταδίδει σε ροή συμβάντων για επεξεργασία και ανάλυση σε πραγματικό χρόνο.
Συμβάντα στοιχείων χώρου εργασίας Fabric Τα συμβάντα στοιχείων χώρου εργασίας Fabric είναι διακριτά συμβάντα Fabric που προκύπτουν όταν γίνονται αλλαγές στον χώρο εργασίας Fabric. Αυτές οι αλλαγές περιλαμβάνουν τη δημιουργία, ενημέρωση ή διαγραφή ενός στοιχείου Fabric. Με τις ροές συμβάντων Fabric, μπορείτε να καταγράψετε αυτά τα συμβάντα χώρου εργασίας Fabric, να τα μετασχηματίσετε και να τα δρομολογήσετε σε διάφορους προορισμούς στο Fabric για περαιτέρω ανάλυση.
συμβάντων OneLake Fabric Μπορείτε να χρησιμοποιήσετε συμβάντα OneLake για να εγγραφείτε σε αλλαγές σε αρχεία και φακέλους στο OneLake και, στη συνέχεια, να αντιδράσετε σε αυτές τις αλλαγές σε πραγματικό χρόνο. Με τις ροές συμβάντων Fabric, μπορείτε να καταγράψετε αυτά τα συμβάντα OneLake, να τα μετασχηματίσετε και να τα δρομολογήσετε σε διάφορους προορισμούς στο Fabric για περαιτέρω ανάλυση. Αυτή η απρόσκοπτη ενσωμάτωση των συμβάντων OneLake στις ροές συμβάντων Fabric σάς δίνει μεγαλύτερη ευελιξία για την παρακολούθηση και την ανάλυση δραστηριοτήτων στο OneLake.
Εκδηλώσεις εργασίας Fabric Μπορείτε να χρησιμοποιήσετε συμβάντα εργασίας για να εγγραφείτε σε αλλαγές που παράγονται όταν το Fabric εκτελεί μια εργασία. Για παράδειγμα, μπορείτε να αντιδράσετε σε αλλαγές κατά την ανανέωση ενός μοντέλου σημασιολογίας, την εκτέλεση μιας προγραμματισμένης διοχέτευσης ή την εκτέλεση ενός σημειωματάριου. Κάθε μία από αυτές τις δραστηριότητες μπορεί να δημιουργήσει μια αντίστοιχη εργασία, η οποία με τη σειρά της δημιουργεί ένα σύνολο αντίστοιχων συμβάντων εργασίας. Με τις ροές συμβάντων Fabric, μπορείτε να καταγράψετε αυτά τα συμβάντα εργασίας, να τα μετασχηματίσετε και να τα δρομολογήσετε σε διάφορους προορισμούς στο Fabric για περαιτέρω ανάλυση. Αυτή η απρόσκοπτη ενσωμάτωση συμβάντων εργασίας στις ροές συμβάντων Fabric σάς δίνει μεγαλύτερη ευελιξία για την παρακολούθηση και την ανάλυση δραστηριοτήτων στην εργασία σας.
Συμβάντα επισκόπησης εκχωρημένων πόρων Fabric (έκδοση προεπισκόπησης) Τα συμβάντα επισκόπησης εκχωρημένων πόρων Fabric παρέχουν πληροφορίες σε επίπεδο σύνοψης σχετικά με τους εκχωρημένους πόρους σας. Μπορείτε να χρησιμοποιήσετε αυτά τα συμβάντα για να δημιουργήσετε ειδοποιήσεις που σχετίζονται με την εύρυθμη λειτουργία των εκχωρημένων πόρων σας μέσω του Fabric Activator. Μπορείτε επίσης να αποθηκεύσετε αυτά τα συμβάντα σε μια αποθήκη συμβάντων για λεπτομερή ή ιστορική ανάλυση.
Συμβάντα χώρου αποθήκευσης αντικειμένων blob Azure Τα συμβάντα χώρου αποθήκευσης αντικειμένων Blob Azure ενεργοποιούνται όταν ένα πρόγραμμα-πελάτης δημιουργεί, αντικαθιστά ή διαγράφει ένα αντικείμενο blob. Μπορείτε να χρησιμοποιήσετε τη σύνδεση για να συνδέσετε συμβάντα χώρου αποθήκευσης αντικειμένων blob με συμβάντα Fabric σε έναν διανομέα σε πραγματικό χρόνο. Μπορείτε να μετατρέψετε αυτά τα συμβάντα σε συνεχείς ροές δεδομένων και να τα μετασχηματίσετε πριν από τη δρομολόγηση τους σε διάφορους προορισμούς στο Fabric.
Google Cloud Pub/Sub Το Google Pub/Sub είναι μια υπηρεσία ανταλλαγής μηνυμάτων που σας επιτρέπει να δημοσιεύετε και να εγγράφεστε σε ροές συμβάντων. Μπορείτε να προσθέσετε το Google Pub/Sub ως προέλευση στο eventstream σας για να καταγράφετε, να μετασχηματίζετε και να δρομολογείτε συμβάντα σε πραγματικό χρόνο σε διάφορους προορισμούς στο Fabric.
Ροές δεδομένων Amazon Kinesis Το Amazon Kinesis Data Streams είναι μια μαζικά επεκτάσιμη, εξαιρετικά ανθεκτική υπηρεσία απορρόφησης και επεξεργασίας δεδομένων που είναι βελτιστοποιημένη για ροή δεδομένων. Ενσωματώνοντας το Amazon Kinesis Data Streams ως προέλευση στη ροή συμβάντων σας, μπορείτε να επεξεργαστείτε απρόσκοπτα ροές δεδομένων σε πραγματικό χρόνο πριν τις δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric.
Confluent Cloud για Apache Kafka Το Confluent Cloud for Apache Kafka είναι μια πλατφόρμα ροής που προσφέρει ισχυρές λειτουργίες ροής και επεξεργασίας δεδομένων χρησιμοποιώντας το Apache Kafka. Ενσωματώνοντας το Confluent Cloud για Apache Kafka ως προέλευση στη ροή συμβάντων σας, μπορείτε να επεξεργαστείτε απρόσκοπτα ροές δεδομένων σε πραγματικό χρόνο πριν τις δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric.
Απάτσι Κάφκα Το Apache Kafka είναι μια κατανεμημένη πλατφόρμα ανοιχτού κώδικα για τη δημιουργία συστημάτων δεδομένων με δυνατότητα κλιμάκωσης σε πραγματικό χρόνο. Ενσωματώνοντας τον Apache Kafka ως προέλευση στη ροή συμβάντων σας, μπορείτε να μεταφέρετε απρόσκοπτα συμβάντα σε πραγματικό χρόνο από τον Apache Kafka και να τα επεξεργαστείτε πριν τα δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric.
Διαχειριζόμενη ροή Amazon για Apache Kafka (MSK) Το Amazon MSK Kafka είναι μια πλήρως διαχειριζόμενη υπηρεσία Kafka που απλοποιεί τη ρύθμιση, την κλιμάκωση και τη διαχείριση. Ενσωματώνοντας το Amazon MSK Kafka ως πηγή στη ροή συμβάντων σας, μπορείτε να μεταφέρετε απρόσκοπτα τα συμβάντα σε πραγματικό χρόνο από το MSK Kafka και να τα επεξεργαστείτε πριν τα δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric. 
MQTT (προεπισκόπηση) Μπορείτε να χρησιμοποιήσετε ροές συμβάντων Fabric για να συνδεθείτε σε έναν μεσίτη MQTT. Τα μηνύματα σε έναν μεσίτη MQTT μπορούν να προσληφθούν σε ροές συμβάντων Fabric και να δρομολογηθούν σε διάφορους προορισμούς εντός του Fabric. 
Cribl (προεπισκόπηση) Μπορείτε να συνδέσετε το Cribl σε μια ροή συμβάντων και να δρομολογήσετε δεδομένα σε διάφορους προορισμούς εντός του Fabric. 
Solace PubSub+ (προεπισκόπηση) Μπορείτε να χρησιμοποιήσετε ροές συμβάντων Fabric για να συνδεθείτε στο Solace PubSub+. Τα μηνύματα από το Solace PubSub+ μπορούν να προσληφθούν σε ροές συμβάντων Fabric και να δρομολογηθούν σε διάφορους προορισμούς εντός του Fabric. 

Επεξεργασία συμβάντων

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

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

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

Εκτός από τους μετασχηματισμούς χωρίς κώδικα, οι ροές συμβάντων υποστηρίζουν έναν τελεστή SQL (έκδοση προεπισκόπησης) για επεξεργασία ροής με προτεραιότητα στον κώδικα. Χρησιμοποιήστε τον τελεστή SQL για να ορίσετε προσαρμοσμένη λογική μετασχηματισμού χρησιμοποιώντας παραστάσεις SQL, συμπεριλαμβανομένων των παραθύρων, των συνδέσμων και των συναθροίσεων. Μπορείτε να επιλέξετε μεταξύ μετασχηματισμών χωρίς κώδικα και σύνταξης βάσει SQL σε μια ροή συμβάντων για να δημιουργήσετε σύνθετη λογική ροής.

Εάν ενεργοποιήσατε τις Βελτιωμένες δυνατότητες κατά τη δημιουργία μιας ροής συμβάντων, οι λειτουργίες μετασχηματισμού υποστηρίζονται για όλους τους προορισμούς. Η παραγόμενη ροή λειτουργεί ως ενδιάμεση γέφυρα για ορισμένους προορισμούς, όπως ένα προσαρμοσμένο τελικό σημείο ή ένα Fabric Activator). Εάν δεν ενεργοποιήσατε τις Βελτιωμένες δυνατότητες, οι λειτουργίες μετασχηματισμού είναι διαθέσιμες μόνο για τους προορισμούς lakehouse και eventhouse (επεξεργασία συμβάντων πριν από την πρόσληψη).

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

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

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

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

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

Διαχείριση σχήματος

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

  • Μητρώο σχήματος (έκδοση προεπισκόπησης): Καταχωρήστε και εκδώστε σχήματα κεντρικά, χρησιμοποιώντας το μητρώο σχήματος Fabric για να διαχειριστείτε την εξέλιξη του σχήματος στις ροές συμβάντων σας. Για περισσότερες πληροφορίες, ανατρέξτε στο θέμα Χρήση σχημάτων συμβάντων σε ροές συμβάντων.
  • Εξαγωγή συμπερασμάτων πολλαπλών σχημάτων (έκδοση προεπισκόπησης): Συμπεράνετε και εργαστείτε με πολλά σχήματα μέσα σε μία μόνο ροή συμβάντων. Σχεδιάστε διαφορετικές διαδρομές μετασχηματισμού επιλέγοντας το κατάλληλο συναγόμενο σχήμα για κάθε διαδρομή. Για περισσότερες πληροφορίες, ανατρέξτε στο θέμα Βελτίωση της επεξεργασίας συμβάντων με χρήση συμπερασμάτων πολλαπλών σχημάτων.
  • Αποσειριοποίηση βάσει μητρώου συρρέοντος σχήματος (προεπισκόπηση): Όταν προσλαμβάνετε δεδομένα από το Confluent Cloud για τον Apache Kafka, οι ροές συμβάντων μπορούν να χρησιμοποιήσουν το μητρώο συρρέοντος σχήματος για την αποσειριοποίηση μηνυμάτων που κωδικοποιούνται από σχήμα, βελτιώνοντας τη διαλειτουργικότητα με οικοσυστήματα ροής που βασίζονται σε Confluent.

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

DeltaFlow: Ροές CDC με δυνατότητα Analytics (Προεπισκόπηση)

Το DeltaFlow είναι μια δυνατότητα εντός των ροών συμβάντων Fabric που μετατρέπει τα ανεπεξέργαστα συμβάντα καταγραφής δεδομένων αλλαγής (CDC) από τις λειτουργικές βάσεις δεδομένων σας σε δεδομένα ροής έτοιμα για ανάλυση.

Βασικές δυνατότητες του DeltaFlow:

  • Σχήμα συμβάντος έτοιμο για ανάλυση: Τα συμβάντα CDC μετατρέπονται σε μορφή πίνακα που αντικατοπτρίζει τη δομή του πίνακα προέλευσης. Στη συνέχεια, μπορείτε να γράψετε απλά ερωτήματα αναλυτικών στοιχείων χρησιμοποιώντας εργαλεία όπως το Kusto Query Language (KQL) χωρίς πρώτα να αναλύσετε ένθετα ωφέλιμα φορτία Debezium JSON.
  • Αυτόματη καταχώρηση σχήματος: Το DeltaFlow ανακαλύπτει αυτόματα σχήματα πίνακα προέλευσης και τα καταχωρεί στο μητρώο σχήματος Fabric.
  • Αυτόματη διαχείριση πίνακα προορισμού: Όταν δρομολογείτε ροές με δυνατότητα DeltaFlow σε έναν υποστηριζόμενο προορισμό, όπως μια βάση δεδομένων eventhouse, οι πίνακες προορισμού δημιουργούνται αυτόματα και διαχειρίζονται ώστε να συμφωνούν με το σχήμα του πίνακα προέλευσης.
  • Χειρισμός εξέλιξης σχήματος: Όταν αλλάζουν οι πίνακες βάσης δεδομένων προέλευσης (για παράδειγμα, προστίθενται νέες στήλες ή δημιουργούνται νέοι πίνακες), το DeltaFlow εντοπίζει αυτόματα τις αλλαγές, ενημερώνει τα καταχωρημένα σχήματα και προσαρμόζει ανάλογα τους πίνακες προορισμού.

Το DeltaFlow (Προεπισκόπηση) είναι διαθέσιμο με τις ακόλουθες συνδέσεις προέλευσης CDC:

Για να χρησιμοποιήσετε το DeltaFlow, επιλέξτε Συμβάντα έτοιμα για ανάλυση και σχήμα αυτόματης ενημέρωσης κατά τη διάρκεια του βήματος χειρισμού σχήματος κατά τη ρύθμιση μιας σύνδεσης CDC ως προέλευσης Eventstream. Για να μάθετε πώς το DeltaFlow μετατρέπει τα μη επεξεργασμένα συμβάντα CDC σε έξοδο έτοιμη για ανάλυση, ανατρέξτε στο θέμα Μετασχηματισμός εξόδου DeltaFlow.

Σημείωμα

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

Ο Apache Kafka στις ροές συμβάντων Fabric

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

Η δυνατότητα ροών συμβάντων Fabric σχετίζεται με τα Κέντρα συμβάντων Azure, μια πλήρως διαχειριζόμενη υπηρεσία εγγενούς στο cloud. Όταν δημιουργείτε μια ροή συμβάντων, δημιουργείται αυτόματα ένας χώρος ονομάτων κέντρου συμβάντων για εσάς. Ένα κέντρο συμβάντων εκχωρείται στην προεπιλεγμένη ροή χωρίς να απαιτούνται διαμορφώσεις παροχής. Για να μάθετε περισσότερα σχετικά με τις δυνατότητες που είναι συμβατές με τον Κάφκα στα Κέντρα συμβάντων Azure, ανατρέξτε στο θέμα Τι είναι τα Κέντρα συμβάντων Azure για τον Apache Kafka;.

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

Επιχειρησιακές δυνατότητες και δυνατότητες ασφάλειας

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

  • Στοιχεία ελέγχου παύσης και συνέχισης: Οι ροές συμβάντων που προκύπτουν υποστηρίζουν στοιχεία ελέγχου παύσης και συνέχισης, ώστε να μπορείτε να διακόψετε προσωρινά την επεξεργασία χωρίς να επηρεάσετε άλλες εισόδους ή εξόδους στη ροή συμβάντων και, στη συνέχεια, να συνεχίσετε αργότερα. Για περισσότερες πληροφορίες, ανατρέξτε στο θέμα Παύση και συνέχιση ροών δεδομένων.
  • Ιδιωτική σύνδεση χώρου εργασίας (έκδοση προεπισκόπησης): Επιλεγμένες προελεύσεις και προορισμοί υποστηρίζουν την ιδιωτική σύνδεση χώρου εργασίας για πρόσβαση σε ιδιωτικό δίκτυο, η οποία σας βοηθά να ασφαλίσετε τις εισερχόμενες συνδέσεις στις ροές συμβάντων σας. Για περισσότερες πληροφορίες, ανατρέξτε στο θέμα Ασφαλείς εισερχόμενες συνδέσεις με ιδιωτικές συνδέσεις μισθωτή και χώρου εργασίας.

Περιορισμούς

Οι ροές συμβάντων Fabric έχουν τους ακόλουθους γενικούς περιορισμούς. Πριν εργαστείτε με ροές συμβάντων, εξετάστε αυτούς τους περιορισμούς για να βεβαιωθείτε ότι ευθυγραμμίζονται με τις απαιτήσεις σας.

Όριο Τιμή
Μέγιστο μέγεθος μηνύματος 1 ΜΒ
Μέγιστη περίοδος διατήρησης δεδομένων συμβάντος 90 ημέρες
Εγγυήσεις παράδοσης συμβάντων Τουλάχιστον μία φορά

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

  • Last updated on