Κοινοποίηση μέσω

Επεξεργασία συμβάντων με χρήση τελεστή SQL (έκδοση προεπισκόπησης)

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

Note

Τα ονόματα τεχνουργημάτων ροής συμβάντων που περιλαμβάνουν χαρακτήρα υπογράμμισης (_) ή τελεία (.) δεν είναι συμβατά με τελεστές SQL. Για την καλύτερη δυνατή εμπειρία, δημιουργήστε μια νέα ροή συμβάντων χωρίς να χρησιμοποιήσετε χαρακτήρες υπογράμμισης ή τελείες στο όνομα του τεχνουργήματος.

Prerequisites

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

Προσθήκη τελεστή SQL σε ροή συμβάντων

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

  1. Δημιουργήστε μια νέα ροή συμβάντων. Στη συνέχεια, προσθέστε έναν τελεστή SQL σε αυτόν χρησιμοποιώντας μία από τις ακόλουθες επιλογές:

    • Στην κορδέλα, επιλέξτε Μετασχηματισμός συμβάντων και, στη συνέχεια, επιλέξτε SQL.

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

    • Στον καμβά, επιλέξτε Μετασχηματισμός συμβάντων ή προσθήκη προορισμού και, στη συνέχεια, επιλέξτε Κώδικας SQL.

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

  2. Ένας νέος κόμβος SQL προστίθεται στη ροή συμβάντων σας. Επιλέξτε το εικονίδιο μολυβιού για να συνεχίσετε τη ρύθμιση του τελεστή SQL.

    Στιγμιότυπο οθόνης που εμφανίζει την επιλογή του εικονιδίου μολυβιού στον κόμβο τελεστή SQL.

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

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

    Στιγμιότυπο οθόνης που εμφανίζει το πλαίσιο για την εισαγωγή ενός ονόματος λειτουργίας και το κουμπί για την επεξεργασία ενός ερωτήματος στο παράθυρο Κώδικας SQL.

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

    Στιγμιότυπο οθόνης που εμφανίζει το πλήρες πρόγραμμα επεξεργασίας SQL.

  6. Επιλέξτε το κείμενο στην ενότητα Έξοδοι και, στη συνέχεια, εισαγάγετε ένα όνομα για τον κόμβο προορισμού. Ο τελεστής SQL υποστηρίζει όλους τους προορισμούς Real-Time Intelligence, συμπεριλαμβανομένης μιας βάσης συμβάντων, μιας λίμνης, ενός ενεργοποιητή ή μιας ροής.

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

  7. Καθορίστε ένα ψευδώνυμο ή ένα όνομα για τον προορισμό εξόδου όπου γράφονται τα δεδομένα που υποβάλλονται σε επεξεργασία μέσω του τελεστή SQL.

    Στιγμιότυπο οθόνης που εμφανίζει το όνομα μιας εξόδου.

  8. Προσθέστε ερώτημα SQL για τον απαιτούμενο μετασχηματισμό δεδομένων.

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

    Ακολουθεί η βασική δομή ερωτημάτων:

    SELECT 

    column1, column2, ... 

INTO 

    [output alias] 

FROM 

    [input alias]

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

    
    SELECT 
    System.Timestamp AS WindowEnd, 
    roomId, 
    AVG(temperature) AS AvgTemp 
INTO 
    output 
FROM 
    input 
GROUP BY 
    roomId, 
    TumblingWindow(minute, 1) 
HAVING 
    AVG(temperature) > 75

    Αυτό το παράδειγμα ερωτήματος δείχνει μια CASE δήλωση για την κατηγοριοποίηση της θερμοκρασίας:

    SELECT
    deviceId, 
    temperature, 
    CASE  
        WHEN temperature > 85 THEN 'High' 
        WHEN temperature BETWEEN 60 AND 85 THEN 'Normal' 
        ELSE 'Low' 
    END AS TempCategory 
INTO 
    CategorizedTempOutput 
FROM 
    SensorInput

  9. Στην κορδέλα, χρησιμοποιήστε την εντολή Δοκιμή ερωτήματος για να επικυρώσετε τη λογική μετασχηματισμού. Τα αποτελέσματα του ερωτήματος δοκιμής εμφανίζονται στην καρτέλα Αποτέλεσμα δοκιμής .

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

  10. Όταν ολοκληρώσετε τη δοκιμή, επιλέξτε Αποθήκευση στην κορδέλα για να επιστρέψετε στον καμβά ροής συμβάντων.

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

  11. Στο παράθυρο Κώδικας SQL , εάν το κουμπί Αποθήκευση είναι ενεργοποιημένο, επιλέξτε το για να αποθηκεύσετε τις ρυθμίσεις.

    Στιγμιότυπο οθόνης που εμφανίζει το παράθυρο Κώδικας SQL και το κουμπί Αποθήκευση.

  12. Ρυθμίστε τις παραμέτρους του προορισμού.

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

Limitations

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

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

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

  • Last updated on