Poznámka
Na prístup k tejto stránke sa vyžaduje oprávnenie. Môžete sa skúsiť prihlásiť alebo zmeniť adresáre.
Na prístup k tejto stránke sa vyžaduje oprávnenie. Môžete skúsiť zmeniť adresáre.
Funkcie údajov používateľa služby Fabric poskytujú pripojenia natívneho zdroja údajov pomocou funkcie Spravovať pripojenia na portáli služby Fabric. Táto funkcia umožňuje pripojiť sa k zdrojom údajov služby Fabric bez toho, aby ste museli vytvárať reťazce pripojenia alebo spravovať prístupové poverenia.
V tomto článku sa naučíte:
- Vytvorte nové pripojenie pre položku údajových funkcií používateľa.
- Nové pripojenie použite v kóde funkcie.
- Upravte alebo odstráňte svoje údajové pripojenie.
Podporované pripojenia zdroja údajov v údajových funkciách používateľa služby Fabric
Pre funkcie údajov používateľa služby Fabric sú v súčasnosti podporované tieto zdroje údajov:
- Databázy SQL služby Fabric na operácie čítania a zapisovaia
- Sklady tkaniny na operácie čítania a zápisu
- Fabric lakehouses pre operácie čítania a zapisovania pre súbory Lakehouse a pre operácie iba na čítanie pre koncový bod SQL.
- Zrkadlové databázy tkaniny na operácie iba na čítanie
Vytvorenie nového údajového pripojenia pre položku údajových funkcií používateľa
Všetky údajové pripojenia, ktoré pridáte, sú priradené k položke údajových funkcií používateľa a je možné na ne odkazovať v kóde ktorejkoľvek z vašich funkcií. Ak chcete postupovať podľa tejto príručky, potrebujete existujúcu položku údajových funkcií používateľa služby Fabric a existujúci zdroj údajov služby Fabric.
1. Prístup k funkcii Spravovať pripojenia z portálu funkcie
Vyhľadajte a vyberte Spravovať pripojenia na páse s nástrojmi editora portálu funkcie.
Otvorí sa tabla obsahujúca všetky údajové pripojenia, ktoré ste vytvorili. Nové pripojenie vytvoríte výberom položky Pridanie dátového pripojenia.
2. Vyberte údajové pripojenie z katalógu OneLake.
Keď vyberiete možnosť Pridať údajové pripojenie, otvorí sa katalóg OneLake so zoznamom všetkých zdrojov údajov, ku ktorému má vaše používateľské konto prístup. Zoznam sa filtruje tak, aby obsahoval iba podporované zdroje údajov, z ktorých niektoré sa môžu nachádzať v iných pracovných priestoroch.
Vyberte zdroj údajov a potom vyberte položky Pripojiť.
Nota
Ak nemôžete nájsť zdroj údajov, ktorý hľadáte, uistite sa, že máte správne povolenia na pripojenie. Prípadne sa uistite, že používate podporovaný zdroj údajov, ktorý je uvedený na začiatku tohto článku.
Po vytvorení sa nové pripojenie k vybratému zdroju údajov zobrazí na bočnej table na karte Pripojenia. Keď sa zobrazí pripojenie, poznamenajte si pole Alias, ktoré preň bolo vygenerované. Tento alias potrebujete na odkazovanie na pripojenie z ľubovoľnej funkcie v položke údajových funkcií používateľa.
3. Použitie aliasu pripojenia v kóde funkcie
Keď sa vrátite do editora portálu, musíte do svojho kódu pridať alias pripojenia, ktoré ste vytvorili na karte Manage Connections. V tomto prípade použijeme ukážku kódu s názvom "Čítať údaje z tabuľky v databáze SQL". Túto ukážku nájdete tak, že kliknete na kartu Upraviť, potom kliknete na tlačidlo "Vložiť ukážku" a prejdete na "Databázu SQL".
Toto je vzorový kód, ktorý bol vložený:
@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
Nota
Hoci sa táto ukážka pripája k databáze SQL, na spustenie databázy nepotrebuje schému ani údaje.
Ak chcete použiť údajové pripojenie, ktoré ste vytvorili, upravte nasledujúci riadok v tejto ukážke: @udf.connection(argName="sqlDB",alias="<alias for sql database>") nahradením hodnoty alias hodnotou, ktorú ste získali z ponuky Manage Connections. Nasledujúci kód ukazuje tento príklad s hodnotou ContosoSalesDat:
@udf.connection(argName="sqlDB",alias="ContosoSalesDat")
@udf.function()
def read_from_sql_db(sqlDB: fn.FabricSqlConnection)-> list:
[...]
Po úprave kódu publikujte funkciu pomocou tlačidla Publikovať na paneli s nástrojmi. Táto operácia môže trvať niekoľko minút.
Po dokončení publikovania môžete funkciu spustiť tak, že ukážete na jej názov v zozname Prieskumník funkcií a kliknete na tlačidlo Spustiť na bočnom paneli. Na dolnom paneli "Output" (Výstup) sa zobrazí výsledok spustenia funkcie.
A to je všetko, čo potrebujete na pripojenie k zdroju údajov z používateľských funkcií služby Fabric.