Csatlakozás adatforrásokhoz a Fabric User adatfüggvényelemből (előzetes verzió)

A Háló felhasználói adatfüggvényei natív adatforrás-kapcsolatokat biztosítanak a Háló portál Kapcsolatok kezelése funkciójával. 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.

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 adatforrás-kapcsolatok a Fabric User adatfüggvényekben

Jelenleg a következő adatforrások támogatják a Fabric felhasználói adatfüggvényeit:

• 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

Ú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

A Functions portálszerkesztő menüszalagján keresse meg és válassza ki a Kapcsolatok kezelése lehetőséget.

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. 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 tegye közzé a függvényt az eszköztár Közzététel gombjával. 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.

Következő lépések

• 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