Προσθήκη προσαρμοσμένου τελικού σημείου ή προσαρμοσμένης προέλευσης εφαρμογής σε μια ροή συμβάντος

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

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

Σημείωμα

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

Προαπαιτούμενα στοιχεία

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

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

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

1. Επιλέξτε Ρυθμίσεις (εικονίδιο γραναζιού) στην επάνω δεξιά γωνία.

2. Επιλέξτε Πύλη διαχείρισης στην ενότητα Διαχείριση και δεδομενικές πληροφορίες .

   

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

   • Στη σελίδα Ρυθμίσεις μισθωτή , στην ενότητα Ρυθμίσεις προγραμματιστή , αναπτύξτε την επιλογή Κύρια υπηρεσία μπορεί να χρησιμοποιήσει το API Fabric .
   • Εναλλαγή για ενεργοποιημένων.
   • Εφαρμόστε σε ολόκληρο τον οργανισμό.
   • Επιλέξτε Εφαρμογή.

   

4. Ενεργοποιήστε αυτήν την επιλογή για να αποκτήσετε πρόσβαση σε όλα τα άλλα API (ενεργοποιημένα από προεπιλογή για νέους μισθωτές):

   • Ακόμα στη σελίδα Ρυθμίσεις μισθωτή , αναπτύξτε την επιλογή Να επιτρέπεται στις κύριες υπηρεσίες η δημιουργία και χρήση προφίλ .
   • Εναλλαγή για ενεργοποιημένων.
   • Εφαρμόστε σε ολόκληρο τον οργανισμό.
   • Επιλέξτε Εφαρμογή.

Σημείωμα

Μια ροή συμβάντων μπορεί να υποστηρίξει έως και 11 συνδυασμένες προελεύσεις και προορισμούς μόνο όταν χρησιμοποιούνται οι ακόλουθοι τύποι:

• Προέλευση: Προσαρμοσμένο τελικό σημείο.
• Προορισμοί: Προσαρμοσμένο τελικό σημείο και Eventhouse με άμεση πρόσληψη.

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

Προσθήκη προσαρμοσμένων δεδομένων τελικού σημείου ως προέλευσης

1. Για να προσθέσετε μια προσαρμοσμένη προέλευση τελικού σημείου, στη σελίδα "Γρήγορα αποτελέσματα", επιλέξτε Χρήση προσαρμοσμένου τελικού σημείου. Εναλλακτικά, εάν έχετε ήδη ένα δημοσιευμένο συμβάνstream και θέλετε να προσθέσετε προσαρμοσμένα δεδομένα τελικού σημείου ως προέλευση, αλλάξτε σε λειτουργία επεξεργασίας. Στην κορδέλα, επιλέξτε Προσθήκη προέλευσης>Προσαρμοσμένο τελικό σημείο.

   

2. Στο παράθυρο διαλόγου Προσαρμοσμένο τελικό σημείο, πληκτρολογήστε ένα όνομα για την προσαρμοσμένη προέλευση στην περιοχή Όνομα προέλευσης και, στη συνέχεια, επιλέξτε Προσθήκη.

   

3. Αφού δημιουργήσετε την προέλευση προσαρμοσμένου τελικού σημείου, προστίθεται στη ροή συμβάντων σας στον καμβά σε λειτουργία επεξεργασίας. Για να υλοποιήσετε τα δεδομένα που προστέθηκαν πρόσφατα από την προέλευση προσαρμοσμένης εφαρμογής, επιλέξτε Δημοσίευση.

   

Σημείωμα

Μια ροή συμβάντων μπορεί να υποστηρίξει έως και 11 συνδυασμένες προελεύσεις και προορισμούς μόνο όταν χρησιμοποιούνται οι ακόλουθοι τύποι:

• Προέλευση: Προσαρμοσμένο τελικό σημείο.
• Προορισμοί: Προσαρμοσμένο τελικό σημείο και Eventhouse με άμεση πρόσληψη.

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

Λήψη λεπτομερειών τελικού σημείου στο τμήμα παραθύρου "Λεπτομέρειες"

Αφού δημιουργήσετε μια προσαρμοσμένη προέλευση τελικού σημείου, τα δεδομένα της είναι διαθέσιμα για απεικόνιση στη δυναμική προβολή.

Το τμήμα παραθύρου Λεπτομέρειες διαθέτει τρεις καρτέλες πρωτοκόλλου: Κέντρο συμβάντων, AMQP και Kafka. Κάθε καρτέλα πρωτοκόλλου έχει τρεις σελίδες: Βασικός έλεγχος ταυτότητας και έλεγχος ταυτότητας κλειδιού SAS. Αυτές οι σελίδες προσφέρουν λεπτομέρειες τελικού σημείου με το αντίστοιχο πρωτόκολλο για σύνδεση.

Η συνάρτηση Basic εμφανίζει το όνομα, τον τύπο και την κατάσταση του προσαρμοσμένου τελικού σημείου σας.

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

Κέντρο συμβάντων

Η σελίδα Έλεγχος ταυτότητας κλειδιού SAS στην καρτέλα Κέντρο συμβάντων περιέχει πληροφορίες που σχετίζονται με τη συμβολοσειρά σύνδεσης ενός κέντρου συμβάντων. Οι πληροφορίες περιλαμβάνουν το όνομα του κέντρου συμβάντων, το όνομα κλειδιού κοινόχρηστη πρόσβασης, το πρωτεύον κλειδί, το δευτερεύον κλειδί δευτερεύοντος σύνδεσης, κλειδί συμβολοσειράς σύνδεσης.

Η μορφή κέντρου συμβάντων είναι η προεπιλογή για τη συμβολοσειρά σύνδεσης και λειτουργεί με το SDK Διανομείς συμβάντων Azure. Αυτή η μορφή σάς επιτρέπει να συνδεθείτε στο eventstream μέσω του πρωτοκόλλου Κέντρα συμβάντων.

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

Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

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

Advanced Message Queuing Protocol (AMQP)

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

Όταν επιλέγετε Εμφάνιση δείγματος κουμπιού κώδικα , βλέπετε τον κώδικα Java έτοιμο για χρήση με πληροφορίες κλειδιού σύνδεσης σε μορφή AMQP.

Κάφκα

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

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

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

Σημείωμα

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

• Για έξοδο από το δείγμα προβολής κώδικα, επιλέξτε Απόκρυψη δείγματος κώδικα.

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

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

Προαπαιτούμενα στοιχεία

• Πρόσβαση σε έναν χώρο εργασίας στη λειτουργία άδειας χρήσης εκχωρημένων πόρων Fabric (ή) στη λειτουργία άδειας χρήσης δοκιμαστικής έκδοσης με δικαιώματα Συμβάλλοντα ή υψηλότερα δικαιώματα.
• Εάν δεν έχετε ένα eventstream, δημιουργήστε ένα eventstream.

Προσθήκη προσαρμοσμένης εφαρμογής ως προέλευσης

Εάν θέλετε να συνδέσετε τη δική σας εφαρμογή με ένα eventstream, μπορείτε να προσθέσετε μια προσαρμοσμένη προέλευση εφαρμογής. Στη συνέχεια, στείλτε δεδομένα στο eventstream από τη δική σας εφαρμογή με το τελικό σημείο σύνδεσης εκτεθειμένο στην προσαρμοσμένη εφαρμογή.

Για να προσθέσετε μια προσαρμοσμένη προέλευση εφαρμογής:

1. Επιλέξτε Νέα προέλευση στην κορδέλα ή το σύμβολο συν (+) στον κύριο καμβά του προγράμματος επεξεργασίας και, στη συνέχεια, επιλέξτε Προσαρμοσμένη εφαρμογή.

2. Στο τμήμα παραθύρου Προσαρμοσμένη εφαρμογή, πληκτρολογήστε ένα όνομα προέλευσης για την προσαρμοσμένη εφαρμογή και, στη συνέχεια, επιλέξτε Προσθήκη.

   

Λήψη λεπτομερειών τελικού σημείου στο τμήμα παραθύρου "Λεπτομέρειες" για την αποστολή συμβάντων

Αφού δημιουργήσετε με επιτυχία την προσαρμοσμένη εφαρμογή ως προέλευση, μπορείτε να δείτε τις πληροφορίες στο τμήμα παραθύρου Λεπτομέρειες .

Το τμήμα παραθύρου Λεπτομέρειες διαθέτει τρεις καρτέλες πρωτοκόλλου: Κέντρο συμβάντων, AMQP και Kafka. Κάθε καρτέλα πρωτοκόλλου περιέχει τρεις σελίδες: Βασικόςέλεγχος ταυτότητας κλειδιού SAS και Έλεγχος ταυτότητας αναγνωριστικού Entra. Αυτές οι σελίδες παρέχουν πληροφορίες τελικού σημείου ειδικά για το επιλεγμένο πρωτόκολλο.

• Η σελίδα Βασικός εμφανίζει το όνομα, τον τύπο και την κατάσταση του προσαρμοσμένου τελικού σημείου σας.

• Ο έλεγχος ταυτότητας κλειδιού SAS και ο έλεγχος ταυτότητας αναγνωριστικού Entra είναι δύο υποστηριζόμενες μέθοδοι ελέγχου ταυτότητας για τη σύνδεση στην εφαρμογή σας:
  • Ο έλεγχος ταυτότητας κλειδιού SAS παρέχει τις πληροφορίες που απαιτούνται για την παραγωγή και κατανάλωση δεδομένων Eventstream με χρήση κλειδιών υπογραφής κοινόχρηστής πρόσβασης (SAS).
  • Ο έλεγχος ταυτότητας αναγνωριστικού Entra επιτρέπει σε μια κύρια ασφάλεια (όπως χρήστη ή κύρια υπηρεσία) να χρησιμοποιεί δεδομένα Eventstream με χρήση ελέγχου ταυτότητας αναγνωριστικού Microsoft Entra.

Για τα βήματα χρήσης του ελέγχου ταυτότητας entra ID, ανατρέξτε στο θέμα Ενεργοποίηση ελέγχου ταυτότητας αναγνωριστικού entra για μια εφαρμογή στο Eventstream.
Η παρακάτω ενότητα περιγράφει τον τρόπο σύνδεσης σε έναν προσαρμοσμένο προορισμό τελικού σημείου με χρήση ελέγχου ταυτότητας κλειδιού SAS.

Κέντρο συμβάντων

Η σελίδα Κλειδιά στην καρτέλα Κέντρο συμβάντων περιέχει πληροφορίες που σχετίζονται με τη συμβολοσειρά σύνδεσης ενός κέντρου συμβάντων. Οι πληροφορίες περιλαμβάνουν το όνομα του κέντρου συμβάντων, το όνομα κλειδιού κοινόχρηστη πρόσβασης, το πρωτεύον κλειδί και το πρωτεύον κλειδί συμβολοσειράς σύνδεσης.

Η μορφή κέντρου συμβάντων είναι η προεπιλογή για τη συμβολοσειρά σύνδεσης και λειτουργεί με το SDK Διανομείς συμβάντων Azure. Αυτή η μορφή σάς επιτρέπει να συνδεθείτε στο eventstream μέσω του πρωτοκόλλου Κέντρα συμβάντων.

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

Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

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

Κάφκα

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

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

AMQP

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

Επιλέξτε Εμφάνιση δείγματος κουμπιού κώδικα στη σελίδα AMQP για να ετοιμαστείτε για χρήση κώδικα με πληροφορίες κλειδιού σύνδεσης σε μορφή AMQP.

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

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

Για να μάθετε πώς μπορείτε να προσθέσετε άλλες προελεύσεις σε μια ροή συμβάντων, ανατρέξτε στα παρακάτω άρθρα:

• Κέντρα συμβάντων Azure
• Κέντρο Azure IoT
• Δείγμα δεδομένων