Σύνδεση σε στοιχεία Fabric από το στοιχείο συναρτήσεων δεδομένων χρήστη Fabric

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

Σε αυτό το άρθρο, θα μάθετε πώς μπορείτε να κάνετε τα εξής:

• Δημιουργήστε μια νέα σύνδεση για το στοιχείο συναρτήσεων δεδομένων χρήστη.
• Χρησιμοποιήστε τη νέα σύνδεσή σας στον κωδικό συνάκησής σας.
• Τροποποιήστε ή διαγράψτε τη σύνδεση δεδομένων σας.

Υποστηριζόμενα στοιχεία στις συναρτήσεις δεδομένων χρήστη Fabric

Τα ακόλουθα στοιχεία υποστηρίζονται αυτήν τη στιγμή για συναρτήσεις δεδομένων χρήστη Fabric:

• Βάσεις δεδομένων SQL Fabric για λειτουργίες ανάγνωσης/εγγραφής
• Αποθήκες fabric για λειτουργίες ανάγνωσης /εγγραφής
• Οι λίμνες Fabric για λειτουργίες ανάγνωσης /εγγραφής για αρχεία Lakehouse και για λειτουργίες μόνο για ανάγνωση για το τελικό σημείο SQL.
• Βάσεις δεδομένων με κατοπτρισμούς fabric για λειτουργίες μόνο για ανάγνωση
• Fabric Variable για να ορίσετε τις ρυθμίσεις διαμόρφωσης ως μεταβλητές. Μάθετε περισσότερα..

Δημιουργία νέας σύνδεσης δεδομένων για το στοιχείο συναρτήσεων δεδομένων χρήστη

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

1. Αποκτήστε πρόσβαση στη δυνατότητα Διαχείριση συνδέσεων από την πύλη συναρτήσεων

Σε λειτουργία ανάπτυξης, βρείτε και επιλέξτε Διαχείριση συνδέσεων στην κορδέλα του προγράμματος επεξεργασίας πύλης συναρτήσεων.

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

2. Επιλέξτε τη σύνδεση δεδομένων σας από τον κατάλογο OneLake

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

Επιλέξτε την προέλευση δεδομένων σας και, στη συνέχεια, επιλέξτε Σύνδεση.

Σημείωση

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

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

3. Χρησιμοποιήστε το ψευδώνυμο σύνδεσής σας στον κωδικό συνάθησής σας

Όταν επιστρέψετε στο πρόγραμμα επεξεργασίας πύλης, πρέπει να προσθέσετε το ψευδώνυμο της σύνδεσης που δημιουργήσατε στην καρτέλα Manage Connections στον κώδικά σας. Αυτό το ψευδώνυμο δημιουργείται αυτόματα με βάση το όνομα του στοιχείου Fabric στο οποίο συνδέεστε.

Σε αυτήν την περίπτωση θα χρησιμοποιήσουμε ένα δείγμα κώδικα που ονομάζεται "Ανάγνωση δεδομένων από έναν πίνακα στη βάση δεδομένων SQL". Μπορείτε να βρείτε αυτό το δείγμα, κάνοντας κλικ στην καρτέλα Επεξεργασία και, στη συνέχεια, κάνοντας κλικ στο κουμπί "Εισαγωγή δείγματος" και μεταβαίνοντας στη "Βάση δεδομένων SQL".

Αυτό είναι το δείγμα κώδικα που έχει εισαχθεί:

@udf.connection(argName="sqlDB",alias="<alias for sql database>")
@udf.function()
def read_from_sql_db(sqlDB: fn.FabricSqlConnection)-> list:
    # Replace with the query you want to run
    query = "SELECT * FROM (VALUES ('John Smith', 31), ('Kayla Jones', 33)) AS Employee(EmpName, DepID);"

    # Establish a connection to the SQL database
    connection = sqlDB.connect()
    cursor = connection.cursor()

    query.capitalize()

    # Execute the query
    cursor.execute(query)

    # Fetch all results
    results = []
    for row in cursor.fetchall():
        results.append(row)

    # Close the connection
    cursor.close()
    connection.close()
        
    return results

Σημείωση

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

Για να χρησιμοποιήσετε τη σύνδεση δεδομένων που δημιουργήσατε, τροποποιήστε την ακόλουθη γραμμή σε αυτό το δείγμα: @udf.connection(argName="sqlDB",alias="<alias for sql database>") αντικαθιστώντας την τιμή του alias με αυτήν που λάβατε από το μενού Manage Connections. Ο παρακάτω κώδικας εμφανίζει αυτό το παράδειγμα με την τιμή ContosoSalesDat:

@udf.connection(argName="sqlDB",alias="ContosoSalesDat")
@udf.function()
def read_from_sql_db(sqlDB: fn.FabricSqlConnection)-> list:
    [...]

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

Μόλις ολοκληρωθεί η δημοσίευση, μπορείτε να εκτελέσετε τη λειτουργία σας τοποθετώντας τον δείκτη του ποντικιού στο όνομά της στη λίστα Functions Explorer και κάνοντας κλικ στο κουμπί "Εκτέλεση" στον πλαϊνό πίνακα. Ο κάτω πίνακας "Έξοδος" δείχνει το αποτέλεσμα της εκτέλεσης της συνάρτησης.

Αυτά είναι όλα όσα χρειάζεστε για να συνδεθείτε σε μια προέλευση δεδομένων από τις συναρτήσεις δεδομένων χρήστη Fabric σας.

Λήψη μεταβλητών από βιβλιοθήκες μεταβλητών Fabric

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

1. Προσθέστε μια σύνδεση σε μια βιβλιοθήκη μεταβλητών χρησιμοποιώντας τη Διαχείριση συνδέσεων και λάβετε το ψευδώνυμο για το στοιχείο βιβλιοθήκης μεταβλητών.
2. Προσθέστε έναν διακοσμητή σύνδεσης για το στοιχείο βιβλιοθήκης μεταβλητής. Για παράδειγμα, @udf.connection(argName="varLib", alias="<My Variable Library Alias>") και αντικαταστήστε το ψευδώνυμο στη σύνδεση που προστέθηκε πρόσφατα για το στοιχείο βιβλιοθήκης μεταβλητής.
3. Στον ορισμό της συνάρτησης, συμπεριλάβετε ένα όρισμα με τύπο fn.FabricVariablesClient. Αυτός ο πελάτης παρέχει μεθόδους που χρειάζεστε για να εργαστείτε με το στοιχείο βιβλιοθήκης μεταβλητών.
4. Χρησιμοποιήστε getVariables() τη μέθοδο για να λάβετε όλες τις μεταβλητές από τη βιβλιοθήκη μεταβλητών.
5. Για να διαβάσετε τις τιμές των μεταβλητών χρησιμοποιήστε, είτε ["variable-name"].get("variable-name")είτε .

Παράδειγμα Σε αυτό το παράδειγμα προσομοιώνουμε ένα σενάριο διαμόρφωσης για ένα περιβάλλον παραγωγής και ανάπτυξης. Αυτή η συνάρτηση ορίζει μια διαδρομή αποθήκευσης ανάλογα με το επιλεγμένο περιβάλλον χρησιμοποιώντας μια τιμή που ανακτάται από τη Βιβλιοθήκη μεταβλητών. Η βιβλιοθήκη μεταβλητών περιέχει μια μεταβλητή που ονομάζεται ENV όπου οι χρήστες μπορούν να ορίσουν μια τιμή dev ή prod.

@udf.connection(argName="varLib", alias="<My Variable Library Alias>")
@udf.function()
def get_storage_path(dataset: str, varLib: fn.FabricVariablesClient) -> str:
    """
    Description: Determine storage path for a dataset based on environment configuration from Variable Library.
    
    Args:
        dataset_name (str): Name of the dataset to store.
        varLib (fn.FabricVariablesClient): Fabric Variable Library connection.
    
    Returns:
        str: Full storage path for the dataset.
    """
    # Retrieve variables from Variable Library
    variables = varLib.getVariables()
    
    # Get environment and base paths
    env = variables.get("ENV")    
    dev_path = variables.get("DEV_FILE_PATH")
    prod_path = variables.get("PROD_FILE_PATH")
    
    # Apply environment-specific logic
    if env.lower() == "dev":
        return f"{dev_path}{dataset}/"
    elif env.lower() == "prod":
        return f"{prod_path}{dataset}/"
    else:
        return f"incorrect settings define for ENV variable"

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

• τη Δημιουργία ενός στοιχείου συναρτήσεων δεδομένων Χρήστη Fabric μέσα από το Fabric ή το χρησιμοποιήσετε την επέκταση Visual Studio Code
• Μάθετε σχετικά με το μοντέλο προγραμματισμού συναρτήσεων δεδομένων χρήστη