Ανανέωση δραστηριότητας τελικού σημείου SQL

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

Χρησιμοποιήστε αυτήν τη δραστηριότητα για να κάνετε τα τελικά σημεία SQL να αντικατοπτρίζουν αμέσως τις πρόσφατες ενημερώσεις χωρίς να βασίζεστε σε μη αυτόματες ανανεώσεις ή ad-hoc διαδικασίες. Χρησιμοποιήστε αυτήν τη δραστηριότητα όταν η διοχέτευσή σας:

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

Προϋποθέσεις

Πριν χρησιμοποιήσετε αυτήν τη δραστηριότητα, βεβαιωθείτε ότι:

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

  1. Δημιουργήστε μια νέα διοχέτευση στον χώρο εργασίας σας.  

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

    Στιγμιότυπο οθόνης της δραστηριότητας Ανανέωση τελικού σημείου SQL στο τμήμα παραθύρου Δραστηριότητες.

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

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

    Συμβουλή

    Μπορείτε να ενορχηστρώσετε αυτήν τη δραστηριότητα μαζί με άλλες δραστηριότητες του Lakehouse Utility Suite, όπως η δραστηριότητα Lakehouse Maintenance, στην ίδια διοχέτευση, ώστε η συντήρηση και η ανανέωση να εκτελούνται διαδοχικά.

  4. Ανατρέξτε στην καθοδήγηση Γενικές ρυθμίσεις για να ρυθμίσετε τις παραμέτρους της καρτέλας Γενικές ρυθμίσεις.

Ανανέωση ρυθμίσεων δραστηριότητας τελικού σημείου SQL

  1. Επιλέξτε την καρτέλα Ρυθμίσεις για να διαμορφώσετε τη δραστηριότητα.  

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

  3. Καθορίστε τον Χώρο εργασίας που περιέχει το Lakehouse.

  4. Καθορίστε το τελικό σημείο SQL για το Lakehouse που θέλετε να ανανεώσετε. Η ανανέωση ενημερώνει τα μετα-δεδομένα τελικού σημείου Lakehouse SQL, ώστε να αντικατοπτρίζουν τα πρόσφατα δεδομένα και τις αλλαγές σχήματος.

    Στιγμιότυπο οθόνης των ρυθμίσεων δραστηριότητας Ανανέωση τελικού σημείου SQL.

Συμπεριφορά δραστηριότητας

Όταν ολοκληρωθεί η δραστηριότητα:

  • Εάν το αναδυόμενο παράθυρο Έξοδος εμφανίζει την κατάσταση επιτυχίας , η αίτηση συγχρονίζει με επιτυχία τα μη συγχρονισμένα δεδομένα.

    Στιγμιότυπο οθόνης μιας κατάστασης επιτυχίας στο αναδυόμενο παράθυρο εξόδου δραστηριότητας.

  • Μια κατάσταση NotRun στο αναδυόμενο παράθυρο Έξοδος σημαίνει ότι η ανανέωση του τελικού σημείου SQL δεν εκτελέστηκε. Αυτή η συνθήκη συνήθως σημαίνει ότι δεν προσθέσατε νέα δεδομένα από τον τελευταίο συγχρονισμό, επομένως δεν χρειάστηκε να τα εκτελέσετε.

    Στιγμιότυπο οθόνης μιας κατάστασης NotRun στο αναδυόμενο παράθυρο δραστηριότητας Έξοδος.

  • Εάν το αναδυόμενο παράθυρο Έξοδος εμφανίζει την κατάσταση αποτυχίας , κάτι πήγε στραβά.

Σημείωμα

Η εκτέλεση δραστηριότητας ορίζει αυτές τις καταστάσεις στο pop-up Έξοδος. Μην συγχέετε αυτές τις καταστάσεις με την ίδια την κατάσταση δραστηριότητας.

Συνήθη σενάρια

  • Ανανέωση του τελικού σημείου SQL μετά την εγγραφή μετασχηματισμένων δεδομένων από ένα Σημειωματάριο σε ένα Lakehouse.
  • Ενεργοποιήστε μια ανανέωση τελικού σημείου SQL μετά την ολοκλήρωση της δραστηριότητας συντήρησης Lakehouse (OPTIMIZE ή VACUUM).
  • Διασφάλιση ότι οι αναφορές και οι πίνακες εργαλείων υποβάλλουν ερωτήματα στην πιο πρόσφατη κατάσταση Lakehouse σε καλά καθορισμένα σημεία σε μια διοχέτευση.

Γιατί αποτυγχάνει η ανανέωση τελικού σημείου SQL όταν τα υποκείμενα δεδομένα είναι κλειδωμένα;

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

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

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

Συμπτώματα

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

Βασική αιτία

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

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

Λύσεις

Δύο πρακτικές προσεγγίσεις μπορούν να μετριάσουν αυτό το ζήτημα:

Χρήση μόνο μίας δραστηριότητας τελικού σημείου SQL ανανέωσης στο τέλος της επεξεργασίας

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

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

Εφαρμογή χρονοδιαγράμματος περιοδικής ανανέωσης

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

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

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

Αυτή η προσέγγιση είναι πρακτική και ισχυρή για πολλούς φόρτους εργασίας ανάλυσης.

Αποθήκευση και εκτέλεση ή προγραμματισμός της διοχέτευσης

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

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

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

Γνωστά προβλήματα