Yhteyden muodostaminen Fabric-kohteisiin Fabric User data functions -kohteesta

Kankaan käyttäjätietofunktiot tarjoavat yhteyksiä tuettuihin kankaan tietolähteisiin ja kohteisiin käyttämällä Fabric-portaalin Yhteyksien hallinta -toimintoa. Tämän ominaisuuden avulla voit muodostaa yhteyden Fabric-tietolähteisiin ilman yhteysmerkkijonojen luomista tai käyttöoikeuksien tunnistetietojen hallintaa. Jos kangas ei ole tietolähde, voit muodostaa turvallisen yhteyden kyseisiin kohteisiin funktiossa.

Tässä artikkelissa opit

Luo uusi yhteys käyttäjätietofunktiokohteelle.
Käytä uutta yhteyttäsi funktiokoodissasi.
Muokkaa tietoyhteyttäsi tai poista se.

Fabricin tuetut kohteet Käyttäjätietofunktiot

Kankaan käyttäjätietofunktiot tukevat tällä hetkellä seuraavia kohteita:

Sql-tietokantojen kangas luku- ja kirjoitustoimintoja varten
Fabric-varastot luku- ja kirjoitustoimintoja varten
Fabric Lakehouse -tallennustilat Lakehouse-tiedostojen luku- ja kirjoitustoimintoihin sekä SQL Endpointin vain luku -toimintoihin.
Fabric-peilatut tietokannat vain luku -toimintoja varten
Kangasmuuttujakirjasto konfigurointiasetusten määrittämiseksi muuttujiksi. Lisätietoja.

Luo uusi tietoyhteys käyttäjätietofunktiokohteeseen

Kaikki lisäämiäsi tietoyhteyksiä liittyvät käyttäjän tietofunktio -kohteeseen, ja niihin voidaan viitata minkä tahansa funktiosi koodissa. Jotta voit noudattaa tätä opasta, tarvitset olemassa olevan Fabric-käyttäjätietofunktiokohteen ja olemassa olevan Fabric-tietolähteen.

1. Yhteyksien hallintaominaisuuden käyttäminen Funktiot-portaalista

Etsi ja valitse kehitystilassa Yhteyksien hallinta Functions-portaalieditorin valintanauhasta.

Näyttöön avautuu ruutu, joka sisältää luomasi tietoyhteydet. Luo uusi yhteys valitsemalla Lisää tietoyhteys.

2. Valitse tietoyhteytesi OneLake-luettelosta

Kun valitset Lisää tietoyhteys, OneLake-luettelo avautuu ja sisältää luettelon kaikista tietolähteistä, joihin käyttäjätililläsi on käyttöoikeus. Luettelo on suodatettu sisältämään vain tuetut tietolähteet, joista osa saattaa olla muissa työtiloissa.

Valitse tietolähteesi ja valitse sitten Yhdistä.

Muistiinpano

Jos et löydä etsimääsi tietolähdettä, varmista, että sinulla on oikeat oikeudet yhteyden muodostamiseen siihen. Vaihtoehtoisesti voit varmistaa, että käytät tuettua tietolähdettä, joka on lueteltu tämän artikkelin alussa.

Kun uusi yhteys valitsemaasi tietolähteeseen on luotu, se näkyy sivuruudussa Yhteydet -välilehdessä. Kun näet yhteyden, kirjoita muistiin sille luotu Alias -kenttä. Tämän aliaksen on viitattava yhteyteen mistä tahansa käyttäjätietofunktiokohteen funktiosta.

3. Käytä yhteysaliastasi funktiokoodissasi

Kun olet palannut portaalieditoriin, sinun on lisättävä koodiin Manage Connections välilehdellä luomasi yhteyden alias. Tämä alias luodaan automaattisesti sen Fabric-kohteen nimen perusteella, johon olet muodostamassa yhteyttä.

Tässä tapauksessa käytämme koodiesimerkkiä nimeltä "Lue tietoja SQL Databasen taulukosta". Löydät tämän mallin napsauttamalla Muokkaa-välilehteä, napsauttamalla Lisää malli -painiketta ja siirtymällä kohtaan SQL-tietokanta.

Tämä on mallikoodi, joka lisättiin:

@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

Muistiinpano

Vaikka tämä malli muodostaa yhteyden SQL-tietokantaan, sen suorittaminen ei edellytä rakennetta tai tietoja tietokannassa.

Jos haluat käyttää luomaasi tietoyhteyttä, muokkaa seuraavaa riviä tässä mallissa: @udf.connection(argName="sqlDB",alias="<alias for sql database>") korvaamalla alias arvo Manage Connections valikosta hankkimallasi arvolla. Seuraava koodi näyttää esimerkin käyttäen arvoa ContosoSalesDat:

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

Kun olet muokannut koodia, voit testata muutoksia käyttämällä Testaa-ominaisuutta kehitystilassa. Kun olet valmis, voit julkaista funktion työkalurivin Julkaise-painikkeella. Tämä toiminto voi kestää muutamia minuutteja.

Kun julkaisu on valmis, voit suorittaa funktion viemällä sen nimen päälle Funktiot explorer -luettelossa ja napsauttamalla "Suorita"-painiketta sivupaneelissa. Alapaneeli "Output" näyttää toiminnon suorittamisen tuloksen.

Sen jälkeen sinun ei tarvitse kuin muodostaa yhteys Fabric-käyttäjätietofunktioista tietolähteeseen.

Muuttujien hakeminen Fabric-muuttujakirjastoista

Microsoft Fabricin Fabric-muuttujakirjasto on keskitetty säilö muuttujien hallintaan, joita voidaan käyttää työtilan eri kohteissa. Sen avulla kehittäjät voivat mukauttaa ja jakaa esinemäärityksiä tehokkaasti. Voit käyttää muuttujakirjastoja funktioissasi seuraavasti:

Lisää yhteys muuttujakirjastoon Yhteyksien hallinta -toiminnolla ja hanki muuttujakirjastokohteen alias .
Lisää muuttujakirjaston alkiolle yhteyden koristelija. Voit esimerkiksi @udf.connection(argName="varLib", alias="<My Variable Library Alias>") korvata aliaksen muuttujan kirjastokohteen juuri lisätylle yhteydelle.
Sisällytä funktion määritykseen argumentti, jonka tyyppi fn.FabricVariablesClienton . Tämä asiakasohjelma tarjoaa menetelmiä, joita tarvitset muuttujien kirjastokohteen käsittelyyn.
Käytä getVariables() metodia saadaksesi kaikki muuttujat muuttujakirjastosta.
Voit lukea muuttujien arvot käyttämällä joko ["variable-name"] tai ..get("variable-name")

Esimerkki Tässä esimerkissä simuloidaan tuotanto- ja kehitysympäristön määritysskenaariota. Tämä funktio asettaa tallennuspolun valitun ympäristön mukaan käyttämällä muuttujakirjastosta haettua arvoa. Muuttujakirjasto sisältää muuttujan nimeltä ENV , jossa käyttäjät voivat asettaa arvoksi dev tai 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"

Palaute

Oliko tästä sivusta apua?

Last updated on 2025-11-10