Csatlakozás Fabric-elemekhez a Fabric User adatfüggvényelemből

A Fabric felhasználói adatfunkciói a Fabric portál Kapcsolatok kezelése funkciójával biztosítják a támogatott fabric adatforrások és -elemek kapcsolatait. Ez a funkció lehetővé teszi, hogy kapcsolati sztringek létrehozása vagy hozzáférési hitelesítő adatok kezelése nélkül csatlakozzon a Fabric-adatforrásokhoz. Olyan elemek esetében, amelyek nem adatforrások, biztonságosan csatlakozhat ezekhez az elemekhez egy függvényen belül.

Ebből a cikkből megtudhatja, hogyan:

• Hozzon létre egy új kapcsolatot a felhasználói adatfüggvény-elemhez.
• Használd az új kapcsolatot a függvénykódban.
• Módosítsa vagy törölje az adatkapcsolatot.

Támogatott elemek a Fabric felhasználói adatfüggvényekben

A következő elemeket támogatják jelenleg a Fabric Felhasználói adatfüggvények:

• Háló SQL-adatbázisok olvasási/írási műveletekhez
• Szövet raktárak olvasási/írási műveletekhez
• Fabric Lakehouse-ok olvasási/írási műveletei a Lakehouse-fájlokhoz, és az SQL végpont írásvédett műveletei.
• Fabric tükrözésű adatbázisok csak olvasási műveletekhez
• Hálóváltozó-kódtár a konfigurációs beállítások változóként való definiálásához. További információ.

Új adatkapcsolat létrehozása a felhasználói adatfüggvény-elemhez

Az Ön által hozzáadott adatkapcsolatok a felhasználói adatfüggvények eleméhez vannak társítva, és bármelyik függvény kódjában hivatkozhat rájuk. Az útmutató követéséhez szüksége van egy meglévő Fabric Felhasználói adatfüggvény elemre és egy meglévő Fabric Adatforrásra.

1. A Kapcsolatok kezelése funkció elérése a Functions portálról

Fejlesztés módban keresse meg és válassza a Kapcsolatok kezelése lehetőséget a Functions portálszerkesztő menüszalagján.

A megnyíló panel a létrehozott adatkapcsolatokat tartalmazza. Új kapcsolat létrehozásához válassza Adatkapcsolat hozzáadása lehetőséget.

2. Válassza ki az adatkapcsolatot a OneLake katalógusból

Amikor Adatkapcsolat hozzáadásalehetőséget választja, megnyílik a OneLake-katalógus az összes olyan adatforrás listájával, amelyhez a felhasználói fiókjának hozzáférése van. A lista úgy van szűrve, hogy csak támogatott adatforrásokat tartalmazzon, amelyek némelyike más munkaterületeken is szerepelhet.

Válassza ki az adatforrást, majd válassza a Csatlakozáslehetőséget.

Megjegyzés

Ha nem találja a keresett adatforrást, győződjön meg arról, hogy rendelkezik a megfelelő engedélyekkel a csatlakozáshoz. Másik lehetőségként győződjön meg arról, hogy támogatott adatforrást használ a cikk elején felsoroltak szerint.

A létrehozás után a kiválasztott adatforráshoz tartozó új kapcsolat megjelenik a Kapcsolatok lap oldalpanelén. Amikor megjelenik a kapcsolat, jegyezze fel a Alias mező, amely a számára létrejött. Erre az aliasra szüksége van a felhasználói adatfüggvényelem bármely függvényének kapcsolatára való hivatkozáshoz.

3. A kapcsolati alias használata a függvénykódban

Miután visszatért a portálszerkesztőbe, hozzá kell adnia a Manage Connections lapon létrehozott kapcsolat aliasát a kódhoz. Ez az alias automatikusan létrejön annak a Hálóelemnek a neve alapján, amelyhez csatlakozik.

Ebben az esetben az "Adatok olvasása egy táblából az SQL Database-ben" nevű kódmintát fogjuk használni. Ezt a mintát a Szerkesztés lapra kattintva, majd a "Minta beszúrása" gombra kattintva, majd az "SQL Database"-be lépve találja meg.

Ez a beszúrt mintakód:

@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

Megjegyzés

Bár ez a minta egy SQL Database-adatbázishoz csatlakozik, nem kell sémát vagy adatokat futtatnia az adatbázisban.

A létrehozott adatkapcsolat használatához módosítsa a következő sort ebben a példában: @udf.connection(argName="sqlDB",alias="<alias for sql database>") a alias értékét cserélje le a Manage Connections menüből beszerzettre. Az alábbi kód ezt a példát mutatja be a ContosoSalesDatértékkel:

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

A kód módosítása után a Fejlesztés módban a Tesztelés funkcióval tesztelheti a módosításokat. Ha elkészült, közzéteheti a függvényt az eszköztár Közzététel gombjával. Ez a művelet eltarthat néhány percig.

A közzététel befejezése után futtathatja a függvényt úgy, hogy a nevére mutat a Functions Explorer listájában, és az oldalpanelen a "Futtatás" gombra kattint. Az alsó "Kimenet" panelen a függvény futtatásának eredménye látható.

És ennyire van csak szüksége ahhoz, hogy csatlakozzon egy adatforráshoz a Fabric Felhasználói Adatfüggvényeiből.

Változók lekérése Fabric-változótárakból

A Microsoft Fabric hálóváltozótára egy központosított adattár, amely a munkaterület különböző elemei között használható változók kezelésére szolgál. Lehetővé teszi a fejlesztők számára az elemkonfigurációk hatékony testreszabását és megosztását. A változókódtárak függvényekben való használatához kövesse az alábbi lépéseket:

1. Adjon hozzá kapcsolatot egy változótárhoz a Kapcsolatok kezelése funkcióval, és kérje le a változótárelem aliasát .
2. Adjon hozzá egy kapcsolati dekorátort a változótárelemhez. Például @udf.connection(argName="varLib", alias="<My Variable Library Alias>") cserélje le az aliast a változótárelem újonnan hozzáadott kapcsolatára.
3. A függvénydefinícióban adjon meg egy típussal rendelkező argumentumot fn.FabricVariablesClient. Ez az ügyfél olyan metódusokat biztosít, amelyekre szükség van a változók kódtárelemével való munkához.
4. Metódus használatával getVariables() lekérheti az összes változót a változótárból.
5. A változók értékeinek olvasásához használja vagy ["variable-name"], vagy .get("variable-name").

Példa Ebben a példában egy konfigurációs forgatókönyvet szimulálunk egy éles és egy fejlesztési környezet számára. Ez a függvény egy tárolási útvonalat állít be a kiválasztott környezettől függően a változótárból lekért érték használatával. A változótár tartalmaz egy változót, amelynek az a neve, ENV hogy a felhasználók beállíthatnak egy értéket dev vagy 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"

Kapcsolódó tartalom

• Fabric felhasználói adatfüggvény-elemet hozzon létre a Fabric környezetében, vagy használja a Visual Studio Code bővítményt
• Ismerje meg a felhasználói adatfüggvény-programozási modellt