Προσθήκη προσαρμοσμένου τελικού σημείου ή προσαρμοσμένης προέλευσης εφαρμογής σε μια ροή συμβάντος
Εάν θέλετε να συνδέσετε τη δική σας εφαρμογή με μια ροή συμβάντος, μπορείτε να προσθέσετε ένα προσαρμοσμένο τελικό σημείο ή μια προσαρμοσμένη εφαρμογή ως προέλευση. Στη συνέχεια, μπορείτε να στείλετε συμβάντα σε πραγματικό χρόνο στο eventstream από τη δική σας εφαρμογή με το τελικό σημείο σύνδεσης εκτεθειμένο στο προσαρμοσμένο τελικό σημείο ή την προσαρμοσμένη εφαρμογή. Επίσης, με το πρωτόκολλο Apache Kafka διαθέσιμο ως επιλογή για προσαρμοσμένα τελικά σημεία ή προσαρμοσμένες εφαρμογές, μπορείτε να στέλνετε συμβάντα σε πραγματικό χρόνο χρησιμοποιώντας το πρωτόκολλο Apache Kafka.
Αυτό το άρθρο σάς δείχνει πώς μπορείτε να προσθέσετε μια προέλευση προσαρμοσμένου τελικού σημείου ή μια προέλευση προσαρμοσμένης εφαρμογής σε μια ροή συμβάντων στις ροές συμβάντων Microsoft Fabric.
Σημείωμα
Εάν θέλετε να χρησιμοποιήσετε βελτιωμένες δυνατότητες που βρίσκονται σε προεπισκόπηση, επιλέξτε Βελτιωμένες δυνατότητες στο επάνω μέρος. Διαφορετικά, επιλέξτε Τυπικές δυνατότητες. Για πληροφορίες σχετικά με τις βελτιωμένες δυνατότητες που βρίσκονται σε προεπισκόπηση, ανατρέξτε στο θέμα Εισαγωγή στις ροές συμβάντων Fabric.
Προαπαιτούμενα στοιχεία
Πριν ξεκινήσετε, πρέπει να αποκτήσετε πρόσβαση στον χώρο εργασίας Fabric Premium με δικαιώματα Συμβάλλοντα ή υψηλότερα δικαιώματα.
Σημείωμα
Ο μέγιστος αριθμός των προελεύσεων και προορισμών για ένα eventstream είναι 11.
Προσθήκη προσαρμοσμένων δεδομένων τελικού σημείου ως προέλευσης
Δημιουργία νέας ροής συμβάντων:
Στην Αρχική σελίδα, επιλέξτε Eventstream.
Στο παράθυρο διαλόγου Νέα ροή συμβάντων, πληκτρολογήστε ένα όνομα, βεβαιωθείτε ότι είναι ενεργοποιημένη η επιλογή Βελτιωμένες δυνατότητες (προεπισκόπηση) και, στη συνέχεια, επιλέξτε Δημιουργία.
Για να προσθέσετε μια προσαρμοσμένη προέλευση τελικού σημείου, στη σελίδα "Γρήγορα αποτελέσματα", επιλέξτε Χρήση προσαρμοσμένου τελικού σημείου.
Εναλλακτικά, εάν έχετε ήδη ένα δημοσιευμένο συμβάνstream και θέλετε να προσθέσετε προσαρμοσμένα δεδομένα τελικού σημείου ως προέλευση, αλλάξτε σε λειτουργία επεξεργασίας. Στην κορδέλα, επιλέξτε Προσθήκη προέλευσης>Προσαρμοσμένο τελικό σημείο.
Στο παράθυρο διαλόγου Προσαρμοσμένο τελικό σημείο, πληκτρολογήστε ένα όνομα για την προσαρμοσμένη προέλευση στην περιοχή Όνομα προέλευσης και, στη συνέχεια, επιλέξτε Προσθήκη.
Αφού δημιουργήσετε την προέλευση προσαρμοσμένου τελικού σημείου, προστίθεται στη ροή συμβάντων σας στον καμβά σε λειτουργία επεξεργασίας. Για να υλοποιήσετε τα δεδομένα που προστέθηκαν πρόσφατα από την προέλευση προσαρμοσμένης εφαρμογής, επιλέξτε Δημοσίευση.
Λήψη λεπτομερειών τελικού σημείου στο τμήμα παραθύρου "Λεπτομέρειες" για την αποστολή συμβάντων
Αφού δημιουργήσετε μια προσαρμοσμένη προέλευση τελικού σημείου, τα δεδομένα της είναι διαθέσιμα για απεικόνιση στη δυναμική προβολή.
Το τμήμα παραθύρου Λεπτομέρειες διαθέτει τρεις καρτέλες πρωτοκόλλου: Κέντρο συμβάντων, AMQP και Kafka. Κάθε καρτέλα πρωτοκόλλου έχει τρεις σελίδες: Βασικά στοιχεία, Κλειδιά και Δείγμα κώδικα. Αυτές οι σελίδες προσφέρουν λεπτομέρειες τελικού σημείου με το αντίστοιχο πρωτόκολλο για σύνδεση.
Η συνάρτηση Basic εμφανίζει το όνομα, τον τύπο και την κατάσταση του προσαρμοσμένου τελικού σημείου σας.
Τα κλειδιά παρέχουν πληροφορίες σχετικά με τα κλειδιά σύνδεσης. Το δείγμα κώδικα παρέχει το δείγμα κώδικα, με τα αντίστοιχα κλειδιά ενσωματωμένα, που μπορείτε να χρησιμοποιήσετε για ροή των συμβάντων στη ροή συμβάντων στη ροή συμβάντων σας. Οι πληροφορίες σε αυτές τις σελίδες διαφέρουν ανάλογα με το πρωτόκολλο.
Κέντρο συμβάντων
Η σελίδα Κλειδιά στην καρτέλα Κέντρο συμβάντων περιέχει πληροφορίες που σχετίζονται με τη συμβολοσειρά σύνδεσης ενός κέντρου συμβάντων. Οι πληροφορίες περιλαμβάνουν το όνομα του κέντρου συμβάντων, το όνομα κλειδιού κοινόχρηστη πρόσβασης, το πρωτεύον κλειδί και το πρωτεύον κλειδί συμβολοσειράς σύνδεσης.
Η μορφή κέντρου συμβάντων είναι η προεπιλογή για τη συμβολοσειρά σύνδεσης και λειτουργεί με το SDK Διανομείς συμβάντων Azure. Αυτή η μορφή σάς επιτρέπει να συνδεθείτε στο eventstream μέσω του πρωτοκόλλου Κέντρα συμβάντων.
Το παρακάτω παράδειγμα εμφανίζει την εμφάνιση της συμβολοσειράς σύνδεσης στη μορφή κέντρου συμβάντων:
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx
Το δείγμα σελίδας κώδικα στην καρτέλα Κέντρο συμβάντων προσφέρει έτοιμο προς χρήση κώδικα, ο οποίος περιλαμβάνει τις απαιτούμενες πληροφορίες σχετικά με τα κλειδιά σύνδεσης στο κέντρο συμβάντων. Απλώς αντιγράψτε το και επικολλήστε το στην εφαρμογή σας για χρήση.
Kafka
Η μορφή Kafka είναι συμβατή με το πρωτόκολλο Apache Kafka, το οποίο είναι μια δημοφιλής κατανεμημένη πλατφόρμα ροής που υποστηρίζει επεξεργασία δεδομένων υψηλής ταχύτητας και χαμηλού λανθάνοντος χρόνου. Μπορείτε να χρησιμοποιήσετε τα κλειδιά και το δείγμα πληροφοριών κώδικα για τη μορφή πρωτοκόλλου Kafka για να συνδεθείτε στη ροή συμβάντων σας και να μεταδίδετε μέσω ροής τα συμβάντα.
Το δείγμα σελίδας κώδικα στην καρτέλα Κάφκα παρέχει έτοιμο κώδικα, συμπεριλαμβανομένων των απαραίτητων κλειδιών σύνδεσης σε μορφή Κάφκα. Απλώς αντιγράψτε το για δική σας χρήση.
AMQP
Η μορφή AMQP είναι συμβατή με το πρωτόκολλο AMQP 1.0, το οποίο είναι ένα τυπικό πρωτόκολλο ανταλλαγής μηνυμάτων που υποστηρίζει διαλειτουργικότητα μεταξύ διαφόρων πλατφορμών και γλωσσών. Μπορείτε να χρησιμοποιήσετε αυτήν τη μορφή για να συνδεθείτε στο eventstream σας, χρησιμοποιώντας το πρωτόκολλο AMQP.
Το δείγμα σελίδας κώδικα στην καρτέλα AMQP παρέχει έτοιμο προς χρήση κώδικα με πληροφορίες κλειδιού σύνδεσης σε μορφή AMQP.
Μπορείτε να επιλέξετε τη μορφή πρωτοκόλλου που ταιριάζει στις ανάγκες και τις προτιμήσεις της εφαρμογής σας και, στη συνέχεια, να αντιγράψετε και να επικολλήσετε τη συμβολοσειρά σύνδεσης στην εφαρμογή σας. Μπορείτε επίσης να αναφερθείτε ή να αντιγράψετε το δείγμα κώδικα στη σελίδα δείγματος κώδικα , που εμφανίζει τον τρόπο αποστολής ή λήψης συμβάντων χρησιμοποιώντας διάφορα πρωτόκολλα.
Σχετικό περιεχόμενο
Για να μάθετε πώς μπορείτε να προσθέσετε άλλες προελεύσεις σε μια ροή συμβάντων, ανατρέξτε στα παρακάτω άρθρα:
- Ροές δεδομένων Amazon Kinesis
- Συμβάντα χώρου αποθήκευσης αντικειμένων blob Azure
- Azure Cosmos DB
- Κέντρα συμβάντων Azure
- Κέντρο Azure IoT
- Azure SQL Database Change Data Capture (CDC)
- Confluent Kafka
- Συμβάν χώρου εργασίας Fabric
- Google Cloud Pub/Sub
- MySQL Database CDC
- PostgreSQL Database CDC
- Δείγμα δεδομένων
Προαπαιτούμενα στοιχεία
Πριν ξεκινήσετε, πρέπει να αποκτήσετε πρόσβαση σε έναν premium χώρο εργασίας με δικαιώματα Συμβάλλοντα ή υψηλότερα δικαιώματα όπου βρίσκεται η ροή συμβάντος σας.
Σημείωμα
Ο μέγιστος αριθμός των προελεύσεων και προορισμών για ένα eventstream είναι 11.
Προσθήκη προσαρμοσμένης εφαρμογής ως προέλευσης
Εάν θέλετε να συνδέσετε τη δική σας εφαρμογή με ένα eventstream, μπορείτε να προσθέσετε μια προσαρμοσμένη προέλευση εφαρμογής. Στη συνέχεια, στείλτε δεδομένα στο eventstream από τη δική σας εφαρμογή με το τελικό σημείο σύνδεσης εκτεθειμένο στην προσαρμοσμένη εφαρμογή.
Για να προσθέσετε μια προσαρμοσμένη προέλευση εφαρμογής:
Επιλέξτε Νέα προέλευση στην κορδέλα ή το σύμβολο συν (+) στον κύριο καμβά του προγράμματος επεξεργασίας και, στη συνέχεια, επιλέξτε Προσαρμοσμένη εφαρμογή.
Στο τμήμα παραθύρου Προσαρμοσμένη εφαρμογή, πληκτρολογήστε ένα όνομα προέλευσης για την προσαρμοσμένη εφαρμογή και, στη συνέχεια, επιλέξτε Προσθήκη.
Λήψη λεπτομερειών τελικού σημείου στο τμήμα παραθύρου "Λεπτομέρειες" για την αποστολή συμβάντων
Αφού δημιουργήσετε με επιτυχία την προσαρμοσμένη εφαρμογή ως προέλευση, μπορείτε να δείτε τις πληροφορίες στο τμήμα παραθύρου Λεπτομέρειες .
Το τμήμα παραθύρου Λεπτομέρειες διαθέτει τρεις καρτέλες πρωτοκόλλου: Κέντρο συμβάντων, AMQP και Kafka. Κάθε καρτέλα πρωτοκόλλου έχει τρεις σελίδες: Βασικά στοιχεία, Κλειδιά και Δείγμα κώδικα. Αυτές οι σελίδες προσφέρουν λεπτομέρειες τελικού σημείου με το αντίστοιχο πρωτόκολλο για σύνδεση.
Η βασική εμφανίζει το όνομα, τον τύπο και την κατάσταση της προσαρμοσμένης εφαρμογής σας.
Τα κλειδιά παρέχουν πληροφορίες σχετικά με τα κλειδιά σύνδεσης. Το δείγμα κώδικα παρέχει το δείγμα κώδικα, με τα αντίστοιχα κλειδιά ενσωματωμένα, που μπορείτε να χρησιμοποιήσετε για ροή των συμβάντων στη ροή συμβάντων στη ροή συμβάντων σας. Οι πληροφορίες σε αυτές τις σελίδες διαφέρουν ανάλογα με το πρωτόκολλο.
Κέντρο συμβάντων
Η σελίδα Κλειδιά στην καρτέλα Κέντρο συμβάντων περιέχει πληροφορίες που σχετίζονται με τη συμβολοσειρά σύνδεσης ενός κέντρου συμβάντων. Οι πληροφορίες περιλαμβάνουν το όνομα του κέντρου συμβάντων, το όνομα κλειδιού κοινόχρηστη πρόσβασης, το πρωτεύον κλειδί και το πρωτεύον κλειδί συμβολοσειράς σύνδεσης.
Η μορφή κέντρου συμβάντων είναι η προεπιλογή για τη συμβολοσειρά σύνδεσης και λειτουργεί με το SDK Διανομείς συμβάντων Azure. Αυτή η μορφή σάς επιτρέπει να συνδεθείτε στο eventstream μέσω του πρωτοκόλλου Κέντρα συμβάντων.
Το παρακάτω παράδειγμα εμφανίζει την εμφάνιση της συμβολοσειράς σύνδεσης στη μορφή κέντρου συμβάντων:
Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx
Το δείγμα σελίδας κώδικα στην καρτέλα Κέντρο συμβάντων προσφέρει έτοιμο προς χρήση κώδικα, ο οποίος περιλαμβάνει τις απαιτούμενες πληροφορίες σχετικά με τα κλειδιά σύνδεσης στο κέντρο συμβάντων. Απλώς αντιγράψτε το και επικολλήστε το στην εφαρμογή σας για χρήση.
Kafka
Η μορφή Kafka είναι συμβατή με το πρωτόκολλο Apache Kafka, το οποίο είναι μια δημοφιλής κατανεμημένη πλατφόρμα ροής που υποστηρίζει επεξεργασία δεδομένων υψηλής ταχύτητας και χαμηλού λανθάνοντος χρόνου. Μπορείτε να χρησιμοποιήσετε τα κλειδιά και το δείγμα πληροφοριών κώδικα για τη μορφή πρωτοκόλλου Kafka για να συνδεθείτε στη ροή συμβάντων σας και να μεταδίδετε μέσω ροής τα συμβάντα.
Το δείγμα σελίδας κώδικα στην καρτέλα Κάφκα παρέχει έτοιμο κώδικα, συμπεριλαμβανομένων των απαραίτητων κλειδιών σύνδεσης σε μορφή Κάφκα. Απλώς αντιγράψτε το για δική σας χρήση.
AMQP
Η μορφή AMQP είναι συμβατή με το πρωτόκολλο AMQP 1.0, το οποίο είναι ένα τυπικό πρωτόκολλο ανταλλαγής μηνυμάτων που υποστηρίζει διαλειτουργικότητα μεταξύ διαφόρων πλατφορμών και γλωσσών. Μπορείτε να χρησιμοποιήσετε αυτήν τη μορφή για να συνδεθείτε στο eventstream σας, χρησιμοποιώντας το πρωτόκολλο AMQP.
Το δείγμα σελίδας κώδικα στην καρτέλα AMQP παρέχει έτοιμο προς χρήση κώδικα με πληροφορίες κλειδιού σύνδεσης σε μορφή AMQP.
Μπορείτε να επιλέξετε τη μορφή πρωτοκόλλου που ταιριάζει στις ανάγκες και τις προτιμήσεις της εφαρμογής σας και, στη συνέχεια, να αντιγράψετε και να επικολλήσετε τη συμβολοσειρά σύνδεσης στην εφαρμογή σας. Μπορείτε επίσης να αναφερθείτε ή να αντιγράψετε το δείγμα κώδικα στη σελίδα δείγματος κώδικα , που εμφανίζει τον τρόπο αποστολής ή λήψης συμβάντων χρησιμοποιώντας διάφορα πρωτόκολλα.
Σχετικό περιεχόμενο
Για να μάθετε πώς μπορείτε να προσθέσετε άλλες προελεύσεις σε μια ροή συμβάντων, ανατρέξτε στα παρακάτω άρθρα: