Προσθήκη και διαχείριση προέλευσης συμβάντων σε μια ροή συμβάντος
Αφού δημιουργήσετε μια ροή συμβάντων, μπορείτε να τη συνδέσετε σε διάφορες προελεύσεις δεδομένων και προορισμούς.
Σημείωμα
Οι βελτιωμένες δυνατότητες ενεργοποιούνται από προεπιλογή όταν δημιουργείτε ροές συμβάντων τώρα. Εάν έχετε ροές συμβάντων που δημιουργήθηκαν χρησιμοποιώντας τυπικές δυνατότητες, αυτές οι ροές συμβάντων θα συνεχίσουν να λειτουργούν. Εξακολουθείτε να μπορείτε να τα επεξεργαστείτε και να τα χρησιμοποιήσετε ως συνήθως. Συνιστούμε να δημιουργήσετε ένα νέο eventstream για να αντικαταστήσετε τις τυπικές ροές συμβάντων, ώστε να μπορείτε να επωφεληθείτε από πρόσθετες δυνατότητες και οφέλη από τις βελτιωμένες ροές συμβάντων.
Αφού δημιουργήσετε μια ροή συμβάντων, μπορείτε να τη συνδέσετε σε διάφορες προελεύσεις δεδομένων και προορισμούς.
Το Eventstream δεν σας επιτρέπει μόνο τη ροή δεδομένων από προελεύσεις της Microsoft, αλλά υποστηρίζει επίσης την πρόσληψη δεδομένων από πλατφόρμες τρίτων κατασκευαστών, όπως το Google Cloud και το Amazon Kinesis, με νέες συνδέσεις ανταλλαγής μηνυμάτων. Αυτή η ανεπτυγμένη δυνατότητα προσφέρει απρόσκοπτη ενοποίηση των εξωτερικών ροών δεδομένων στο Fabric, παρέχοντας μεγαλύτερη ευελιξία και επιτρέποντάς σας να αποκτήσετε πληροφορίες σε πραγματικό χρόνο από πολλές προελεύσεις.
Σε αυτό το άρθρο, θα μάθετε σχετικά με τις προελεύσεις συμβάντων που μπορείτε να προσθέσετε σε μια ροή συμβάντων.
Προαπαιτούμενα στοιχεία
- Πρόσβαση σε έναν χώρο εργασίας στη λειτουργία άδειας χρήσης εκχωρημένων πόρων Fabric (ή) στη λειτουργία άδειας χρήσης δοκιμαστικής έκδοσης με δικαιώματα Συμβάλλοντα ή υψηλότερα δικαιώματα.
- Προαπαιτούμενα ειδικά για κάθε προέλευση που τεκμηριώνονται στα παρακάτω άρθρα προέλευσης.
Υποστηριζόμενες προελεύσεις
Οι ροές συμβάντων Fabric με βελτιωμένες δυνατότητες υποστηρίζουν τις παρακάτω προελεύσεις. Κάθε άρθρο παρέχει λεπτομέρειες και οδηγίες για την προσθήκη συγκεκριμένων προελεύσεων.
| Πηγές | Περιγραφή |
|---|---|
| Κέντρα συμβάντων Azure | Εάν έχετε ένα κέντρο συμβάντων Azure, μπορείτε να πραγματοποιήσετε πρόσληψη δεδομένων κέντρου συμβάντων στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream. |
| Κέντρο Azure IoT | Εάν έχετε έναν διανομέα Azure IoT, μπορείτε να πραγματοποιήσετε πρόσληψη δεδομένων IoT στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream. |
| Azure SQL Database Change Data Capture (CDC) | Η σύνδεση προέλευσης CDC βάσης δεδομένων SQL Azure σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων SQL Azure. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα. |
| PostgreSQL Database CDC | Η σύνδεση προέλευσης PostgreSQL Change Data Capture (CDC) σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων PostgreSQL. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα. |
| MySQL Database CDC | Η σύνδεση προέλευσης αλλαγής δεδομένων (CDC) της βάσης δεδομένων MySQL του Azure σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων Azure για τη βάση δεδομένων MySQL. Μπορείτε να καθορίσετε τους πίνακες για παρακολούθηση και η eventstream καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών στους πίνακες. |
| Azure Cosmos DB CDC | Η σύνδεση προέλευσης Azure Cosmos DB Change Data Capture (CDC) για τις ροές συμβάντων Microsoft Fabric σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων Azure Cosmos DB. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα. |
| SQL Server σε βάση δεδομένων εικονικής μηχανής (VM) (DB) CDC | Η σύνδεση προέλευσης SQL Server σε VM DB (CDC) για ροές συμβάντων Fabric σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων SQL Server σε εικονική μηχανή. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών στα δεδομένα. |
| Azure SQL Managed Instance CDC | Η σύνδεση προέλευσης διαχειριζόμενης παρουσίας CDC του Azure SQL για τις ροές συμβάντων Microsoft Fabric σάς επιτρέπει να καταγράψετε ένα στιγμιότυπο των τρεχόντων δεδομένων σε μια βάση δεδομένων διαχειριζόμενης παρουσίας SQL. Η σύνδεση, στη συνέχεια, παρακολουθεί και καταγράφει τυχόν μελλοντικές αλλαγές σε επίπεδο γραμμών σε αυτά τα δεδομένα. |
| 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 Kafka | Το Confluent Cloud Kafka είναι μια πλατφόρμα ροής που προσφέρει ισχυρές λειτουργίες ροής και επεξεργασίας δεδομένων χρησιμοποιώντας το Apache Kafka. Ενσωματώνοντας το Confluent Cloud Kafka ως προέλευση στο eventstream, μπορείτε να επεξεργαστείτε απρόσκοπτα ροές δεδομένων σε πραγματικό χρόνο πριν τις δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric. |
| Amazon MSK Kafka | Το Amazon MSK Kafka είναι μια πλήρως διαχειριζόμενη υπηρεσία Kafka που απλοποιεί τη ρύθμιση, την κλιμάκωση και τη διαχείριση. Ενσωματώνοντας το Amazon MSK Kafka ως προέλευση στη ροή συμβάντων σας, μπορείτε να μεταφέρετε απρόσκοπτα τα συμβάντα σε πραγματικό χρόνο από το MSK Kafka σας και να τα επεξεργαστείτε πριν τα δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric. |
| Δείγμα δεδομένων | Μπορείτε να επιλέξετε συμβάντα ποδηλάτων, κίτρινου ταξί ή χρηματιστηρίου ως δείγμα προέλευσης δεδομένων για να δοκιμάσετε την πρόσληψη δεδομένων κατά τη ρύθμιση μιας ροής συμβάντων. |
| Προσαρμοσμένο τελικό σημείο (δηλαδή, Προσαρμοσμένη εφαρμογή σε τυπική δυνατότητα) | Η δυνατότητα προσαρμοσμένου τελικού σημείου επιτρέπει στις εφαρμογές σας ή στα προγράμματα-πελάτες Kafka να συνδεθούν στο Eventstream χρησιμοποιώντας μια συμβολοσειρά σύνδεσης, επιτρέποντας την ομαλή πρόσληψη δεδομένων ροής στο Eventstream. |
| Δίαυλος υπηρεσίας Azure (προεπισκόπηση) | Μπορείτε να κάνετε πρόσληψη δεδομένων από μια ουρά διαύλου υπηρεσίας Azure ή μια συνδρομή θέματος στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream. |
| Apache Kafka (προεπισκόπηση) | Το Apache Kafka είναι μια κατανεμημένη πλατφόρμα ανοιχτού κώδικα για τη δημιουργία συστημάτων δεδομένων με δυνατότητα κλιμάκωσης σε πραγματικό χρόνο. Ενσωματώνοντας το Apache Kafka ως προέλευση στη ροή συμβάντων σας, μπορείτε να μεταφέρετε απρόσκοπτα συμβάντα σε πραγματικό χρόνο από το Apache Kafka σας και να τα επεξεργαστείτε πριν τα δρομολογήσετε σε πολλούς προορισμούς εντός του Fabric. |
| Συμβάντα χώρου αποθήκευσης αντικειμένων blob Azure (προεπισκόπηση) | Τα συμβάντα χώρου αποθήκευσης αντικειμένων Blob Azure ενεργοποιούνται όταν ένα πρόγραμμα-πελάτης δημιουργεί, αντικαθιστά ή διαγράφει ένα αντικείμενο blob. Η σύνδεση σάς επιτρέπει να συνδέσετε συμβάντα χώρου αποθήκευσης αντικειμένων Blob με συμβάντα Fabric στο Κέντρο πραγματικού χρόνου. Μπορείτε να μετατρέψετε αυτά τα συμβάντα σε συνεχείς ροές δεδομένων και να τα μετασχηματίσετε πριν από τη δρομολόγηση τους σε διάφορους προορισμούς στο Fabric. |
| Συμβάντα στοιχείου χώρου εργασίας Fabric (προεπισκόπηση) | Τα συμβάντα Fabric Workspace Item είναι διακριτά συμβάντα Fabric που προκύπτουν όταν γίνονται αλλαγές στον χώρο εργασίας Fabric σας. Αυτές οι αλλαγές περιλαμβάνουν τη δημιουργία, ενημέρωση ή διαγραφή ενός στοιχείου Fabric. Με τις ροές συμβάντων Fabric, μπορείτε να καταγράψετε αυτά τα συμβάντα χώρου εργασίας Fabric, να τα μετασχηματίσετε και να τα δρομολογήσετε σε διάφορους προορισμούς στο Fabric για περαιτέρω ανάλυση. |
| συμβάντα Fabric OneLake (προεπισκόπηση) | Τα συμβάντα OneLake σάς επιτρέπουν να εγγραφείτε σε αλλαγές σε αρχεία και φακέλους στο OneLake και, στη συνέχεια, να αντιδράτε σε αυτές τις αλλαγές σε πραγματικό χρόνο. Με τις ροές συμβάντων Fabric, μπορείτε να καταγράψετε αυτά τα συμβάντα OneLake, να τα μετασχηματίσετε και να τα δρομολογήσετε σε διάφορους προορισμούς στο Fabric για περαιτέρω ανάλυση. Αυτή η απρόσκοπτη ενοποίηση των συμβάντων OneLake στις ροές συμβάντων Fabric σάς παρέχει μεγαλύτερη ευελιξία για την παρακολούθηση και ανάλυση δραστηριοτήτων στο OneLake. |
| συμβάντα εργασίας Fabric (προεπισκόπηση) | Τα συμβάντα εργασίας σάς επιτρέπουν να εγγραφείτε σε αλλαγές που παράγονται όταν το Fabric εκτελεί μια εργασία. Για παράδειγμα, μπορείτε να αντιδράσετε σε αλλαγές κατά την ανανέωση ενός μοντέλου σημασιολογίας, την εκτέλεση μιας προγραμματισμένης διοχέτευσης ή την εκτέλεση ενός σημειωματάριου. Κάθε μία από αυτές τις δραστηριότητες μπορεί να δημιουργήσει μια αντίστοιχη εργασία, η οποία με τη σειρά της δημιουργεί ένα σύνολο αντίστοιχων συμβάντων εργασίας. Με τις ροές συμβάντων Fabric, μπορείτε να καταγράψετε αυτά τα συμβάντα Εργασίας, να τα μετασχηματίσετε και να τα δρομολογήσετε σε διάφορους προορισμούς στο Fabric για περαιτέρω ανάλυση. Αυτή η απρόσκοπτη ενοποίηση των συμβάντων εργασίας στις ροές συμβάντων Fabric σάς παρέχει μεγαλύτερη ευελιξία για την παρακολούθηση και ανάλυση δραστηριοτήτων στην εργασία σας. |
Σημείωμα
Ο μέγιστος αριθμός των προελεύσεων και προορισμών για ένα eventstream είναι 11.
Σχετικό περιεχόμενο
Προαπαιτούμενα στοιχεία
Πριν ξεκινήσετε, πρέπει να συμπληρώσετε τις ακόλουθες προϋποθέσεις:
- Πρόσβαση σε έναν χώρο εργασίας στη λειτουργία άδειας χρήσης εκχωρημένων πόρων Fabric (ή) στη λειτουργία άδειας χρήσης δοκιμαστικής έκδοσης με δικαιώματα Συμβάλλοντα ή υψηλότερα δικαιώματα.
- Για να προσθέσετε κέντρα συμβάντων Azure ή Κέντρο Azure IoT ως προέλευση eventstream, πρέπει να έχετε τα κατάλληλα δικαιώματα για να αποκτήσετε πρόσβαση στα κλειδιά πολιτικής. Πρέπει να είναι προσβάσιμες στο κοινό και όχι πίσω από ένα τείχος προστασίας ή να προστατεύονται σε ένα εικονικό δίκτυο.
Υποστηριζόμενες προελεύσεις
Οι ροές συμβάντων Fabric υποστηρίζουν τις παρακάτω προελεύσεις. Χρησιμοποιήστε συνδέσεις στον πίνακα για να περιηγηθείτε σε άρθρα που παρέχουν περισσότερες λεπτομέρειες σχετικά με την προσθήκη συγκεκριμένων προελεύσεων.
| Πηγές | Περιγραφή |
|---|---|
| Κέντρα συμβάντων Azure | Εάν έχετε ένα κέντρο συμβάντων Azure, μπορείτε να πραγματοποιήσετε πρόσληψη δεδομένων κέντρου συμβάντων στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream. |
| Κέντρο Azure IoT | Εάν έχετε έναν διανομέα Azure IoT, μπορείτε να πραγματοποιήσετε πρόσληψη δεδομένων IoT στο Microsoft Fabric χρησιμοποιώντας τη συνάρτηση Eventstream. |
| Δείγμα δεδομένων | Μπορείτε να επιλέξετε συμβάντα ποδηλάτων, κίτρινου ταξί ή χρηματιστηρίου ως δείγμα προέλευσης δεδομένων για να δοκιμάσετε την πρόσληψη δεδομένων κατά τη ρύθμιση μιας ροής συμβάντων. |
| Προσαρμοσμένη εφαρμογή | Η δυνατότητα προσαρμοσμένης εφαρμογής επιτρέπει στις εφαρμογές σας ή στα προγράμματα-πελάτες Kafka να συνδεθούν στο Eventstream χρησιμοποιώντας μια συμβολοσειρά σύνδεσης, επιτρέποντας την ομαλή πρόσληψη δεδομένων ροής στο Eventstream. |
Σημείωμα
Ο μέγιστος αριθμός των προελεύσεων και προορισμών για ένα eventstream είναι 11.
Διαχείριση προέλευσης
Επεξεργασία/κατάργηση: Μπορείτε να επιλέξετε μια προέλευση eventstream για επεξεργασία ή κατάργηση είτε μέσω του παραθύρου περιήγησης είτε μέσω του καμβά. Όταν επιλέγετε Επεξεργασία, ανοίγει το παράθυρο επεξεργασίας στα δεξιά του κύριου προγράμματος επεξεργασίας.
Κλειδί δημιουργίας για μια προσαρμοσμένη εφαρμογή: Εάν θέλετε να δημιουργήσετε ξανά ένα νέο κλειδί σύνδεσης για την εφαρμογή σας, επιλέξτε μία από τις προελεύσεις προσαρμοσμένης εφαρμογής σας στον καμβά και επιλέξτε Αναγέννηση για να λάβετε ένα νέο κλειδί σύνδεσης.
