Zdieľať cez

Pripojenie k položkám služby Fabric z položky funkcií údajov používateľa služby Fabric

Funkcie údajov používateľov prostriedkov infraštruktúry poskytujú pripojenia k podporovaným zdrojom údajov a položkám štruktúry pomocou funkcie Spravovať pripojenia na portáli 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 prípade aktivovaných položiek, ktoré nie sú zdrojom údajov, sa k týmto položkám môžete bezpečne pripojiť v rámci funkcie.

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é položky vo funkciách používateľských údajov služby Fabric

Nasledujúce položky sú momentálne podporované pre funkcie údajov používateľov štruktúry:

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

V režime vývoja vyhľadajte a vyberte položku Spravovať pripojenia na páse s nástrojmi editora portálu Functions.

Snímka obrazovky znázorňujúca editor portálu funkcií so zvýrazneným tlačidlom spravovania pripojení.

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.

Snímka obrazovky bočnej tably s vybratou kartou pripojenia a žiadnymi uvedenými pripojeniami.

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ť.

Snímka obrazovky katalógu údajov OneLake so zoznamom zdrojov údajov.

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.

Snímka obrazovky s bočnou tablou pripojenia a vytvoreným novým pripojením zdroja údajov.

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. Tento alias sa automaticky vytvorí na základe názvu položky Fabric, ku ktorej sa pripájate.

V tomto prípade použijeme ukážku kódu s názvom "Čítanie údajov z tabuľky v SQL Database". 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".

Snímka obrazovky znázorňujúca katalóg vloženia vzorových údajov so zoznamom zdrojov údajov.

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

Aj keď sa táto ukážka pripája k databáze SQL, na spustenie nepotrebuje schému ani údaje v databáze.

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 môžete zmeny otestovať pomocou funkcie Test v režime vývoja. Keď budete pripravení, môžete svoju funkciu publikovať pomocou tlačidla Publikovať na paneli s nástrojmi. Táto operácia môže trvať niekoľko minút.

snímka obrazovky tlačidla Publikovať.

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. Spodný panel "Výstup" zobrazuje výsledok spustenia funkcie.

Snímka obrazovky bočného panela použitého na spustenie funkcie.

A to je všetko, čo potrebujete na pripojenie k zdroju údajov z používateľských funkcií služby Fabric.

Získanie premenných z knižníc premenných štruktúry

Knižnica premenných štruktúry v službe Microsoft Fabric je centralizované odkladacie zariadenie na správu premenných, ktoré možno použiť v rôznych položkách v rámci pracovného priestoru. Umožňuje vývojárom efektívne prispôsobovať a zdieľať konfigurácie položiek. Ak chcete používať knižnice premenných vo svojich funkciách, postupujte takto:

  1. Pridajte pripojenie ku knižnici premenných pomocou možnosti Spravovať pripojenia a získajte alias pre položku knižnice premenných.
  2. Pridanie dekorátora spojenia pre položku knižnice premenných. Napríklad @udf.connection(argName="varLib", alias="<My Variable Library Alias>") a nahradiť alias novo pridaným pripojením pre položku knižnice premenných.
  3. Do definície funkcie zahrňte argument s typom fn.FabricVariablesClient. Tento klient poskytuje metódy, ktoré potrebujete na prácu s položkou knižnice premenných.
  4. Použite getVariables() metódu na získanie všetkých premenných z knižnice premenných.
  5. Ak chcete prečítať hodnoty premenných, použite buď ["variable-name"] alebo .get("variable-name").

Príklad V tomto príklade simulujeme konfiguračný scenár pre produkčné a vývojové prostredie. Táto funkcia nastaví cestu úložiska v závislosti od zvoleného prostredia pomocou hodnoty načítanej z knižnice premenných. Knižnica premenných obsahuje premennú s názvom ENV , kde môžu používatelia nastaviť hodnotu dev alebo 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"

Súvisiaci obsah

  • Last updated on