Připojte se k Fabric komponentám z položky funkcí uživatelských dat

Funkce uživatelských dat fabricu poskytují připojení k podporovaným zdrojům dat a položkám pomocí funkce Spravovat připojení na portálu Fabric. Tato funkce umožňuje připojit se ke zdrojům dat Infrastruktury, aniž byste museli vytvářet připojovací řetězce nebo spravovat přihlašovací údaje pro přístup. U textilních položek, které nejsou zdrojem dat, se můžete bezpečně připojit k těmto položkám uvnitř funkce.

V tomto článku se naučíte:

• Vytvořte nové připojení pro položku funkcí uživatelských dat.
• Použijte nové připojení ve vašem kódu funkce.
• Upravte nebo odstraňte datové připojení.

Podporované položky v uživatelských datových funkcích Fabric

Funkce uživatelských dat Fabricu aktuálně podporují následující položky:

• Fabric SQL databáze pro operace čtení a zápisu
• Fabricové sklady pro operace čtení a zápisu
• Fabric Lakehouses pro operace čtení a zápisu pro soubory Lakehouse a pro operace jen pro čtení pro koncový bod SQL.
• Zrcadlené databáze fabric pro operace jen pro čtení
• Knihovna proměnných Fabric pro definování konfiguračních nastavení jako proměnných. Další informace.

Vytvoření nového datového připojení pro položku funkcí uživatelských dat

Všechna datová připojení, která přidáte, jsou přidružená k položce funkcí uživatelských dat a mohou být odkazována v kódu libovolné z vašich funkcí. Pokud chcete postupovat podle tohoto průvodce, potřebujete existující položku datových funkcí uživatelského Fabric a existující zdroj dat Fabric.

1. Přístup k funkci Správa připojení z portálu Functions

V režimu vývoje vyhledejte a vyberte Spravovat připojení na pásu karet editoru portálu funkcí.

Podokno, které se otevře, obsahuje všechna datová připojení, která jste vytvořili. Vyberte Přidat datové připojení pro vytvoření nového připojení.

2. Vyberte datové připojení z katalogu OneLake.

Když vyberete Přidat datové připojení, otevře se katalog OneLake se seznamem všech zdrojů dat, ke kterým má váš uživatelský účet přístup. Seznam je filtrovaný tak, aby zahrnoval pouze podporované zdroje dat, z nichž některé můžou být v jiných pracovních prostorech.

Zvolte zdroj dat, poté vyberte Připojit.

Poznámka:

Pokud nemůžete najít zdroj dat, který hledáte, ujistěte se, že máte správná oprávnění pro připojení k němu. Případně se ujistěte, že používáte podporovaný zdroj dat, jak je uvedeno na začátku tohoto článku.

Po vytvoření se nové připojení ke zdroji dat, který jste vybrali, zobrazí v bočním podokně na kartě Připojení. Po zobrazení připojení si poznamenejte pole Alias, které se pro něj vygenerovalo. Tento alias potřebujete k odkazování na připojení z libovolné funkce v položce funkcí uživatelských dat.

Snímek obrazovky postranního panelu připojení s nově vytvořeným připojením ke zdroji dat

3. Použijte alias připojení ve svém funkčním kódu

Jakmile se vrátíte do editoru portálu, musíte do kódu přidat alias připojení, které jste vytvořili na kartě Manage Connections. Tento alias se automaticky vytvoří na základě názvu položky Fabric, ke které se připojujete.

V tomto případě použijeme ukázku kódu s názvem Čtení dat z tabulky ve službě SQL Database. Tuto ukázku najdete kliknutím na kartu Upravit a následným kliknutím na tlačítko Vložit ukázku a přechodem do databáze SQL.

Toto je vzorový kód, který byl 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

Poznámka:

Tato ukázka se sice připojuje ke službě SQL Database, ale ke spuštění nepotřebuje schéma ani data v databázi.

Pokud chcete použít datové připojení, které jste vytvořili, upravte následující řádek v této ukázce: @udf.connection(argName="sqlDB",alias="<alias for sql database>") nahrazením hodnoty alias hodnotou, kterou jste získali z nabídky Manage Connections. Následující kód ukazuje tento příklad s hodnotou ContosoSalesDat:

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

Po úpravě kódu můžete změny otestovat pomocí funkce Testování v režimu Vývoje. Jakmile budete připraveni, můžete funkci publikovat pomocí tlačítka Publikovat na panelu nástrojů. Tato operace může trvat několik minut.

Po dokončení publikování můžete funkci spustit tak, že v seznamu Průzkumníka funkcí najedete myší na její název a na bočním panelu kliknete na tlačítko Spustit. Na dolním panelu Výstup se zobrazí výsledek spuštění funkce.

A to je vše, co potřebujete, abyste se připojili ke zdroji dat ze služby Fabric User Data Functions.

Získání proměnných z knihoven proměnných Fabric

Knihovna proměnných v Microsoft Fabric je centralizované úložiště pro správu proměnných, které lze použít v různých položkách v rámci pracovního prostoru. Umožňuje vývojářům efektivně přizpůsobovat a sdílet konfigurace položek. Pokud chcete ve svých funkcích používat knihovny proměnných, postupujte takto:

1. Přidejte připojení k knihovně proměnných pomocí Spravovat připojení a získejte alias pro položku knihovny proměnných.
2. Přidejte dekorátor připojení pro položku v knihovně proměnných. Můžete například @udf.connection(argName="varLib", alias="<My Variable Library Alias>") nahradit alias nově přidaného připojení pro položku knihovny proměnných.
3. Do definice funkce zahrňte argument s typem fn.FabricVariablesClient. Tento klient poskytuje metody, které potřebujete pro práci s položkou knihovny proměnných.
4. Pomocí metody získejte getVariables() všechny proměnné z knihovny proměnných.
5. Ke čtení hodnot proměnných se používají buď ["variable-name"] nebo .get("variable-name").

Příklad V tomto příkladu simulujeme scénář konfigurace pro produkční a vývojové prostředí. Tato funkce nastaví cestu k úložišti v závislosti na vybraném prostředí pomocí hodnoty načtené z knihovny proměnných. Knihovna proměnných obsahuje proměnnou s názvem ENV , ve které mohou uživatelé nastavit hodnotu dev nebo 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"

Související obsah

• Vytvořit položku funkcí uživatelských dat Fabric z Fabric nebo použít rozšíření pro Visual Studio Code
• Informace o programovacím modelu uživatelských datových funkcí