Verbinding maken met gegevensbronnen vanuit het item gegevensfuncties van Fabric-gebruikers

U kunt uw fabricgebruikersgegevensfuncties rechtstreeks vanuit de Fabric-portal verbinden met ondersteunde Fabric-gegevensbronnen. Fabric verwerkt verificatie voor u, zodat uw functiecode voor gebruikersgegevens alleen hoeft te verwijzen naar een verbindingsalias in plaats van referenties of verbindingsgegevens op te slaan.

In dit artikel leert u het volgende:

• Maak een nieuwe verbinding voor het onderdeel gebruikersgegevensfuncties.
• Gebruik uw nieuwe verbinding in uw functiecode.
• Uw gegevensverbinding wijzigen of verwijderen.

Ondersteunde gegevensbronnen in Fabric-gebruikersgegevensfuncties

De volgende gegevensbronnen worden momenteel ondersteund voor Fabric-gebruikersgegevensfuncties:

• Fabric SQL-databases voor lees-/schrijfbewerkingen
• Fabricwarehouses voor lees-/schrijfbewerkingen
• Fabric Lakehouses voor lees-/schrijfbewerkingen voor Lakehouse-bestanden en voor alleen-lezenbewerkingen voor het SQL-eindpunt.
• Gespiegelde fabric-databases voor alleen-lezen bewerkingen

Vereiste voorwaarden

Voordat u verbinding kunt maken met gegevensbronnen, hebt u het volgende nodig:

• Een Fabric User Data Functions-item in uw werkruimte
• Schrijfmachtigingen voor het item User Data Functions voor het beheren van verbindingen
• Ten minste één van de ondersteunde gegevensbronnen (SQL Database, Warehouse, Lakehouse of gespiegelde database) in een toegankelijke werkruimte
• Leesmachtigingen (of hoger) voor de gegevensbron waarmee u verbinding wilt maken

Een verbinding toevoegen in de Fabric-portal

Als u toegang wilt krijgen tot gegevens uit uw functies, moet u een verbinding met uw gegevensbron maken. Deze verbinding verwerkt verificatie en autorisatie automatisch, dus u hoeft geen verbindingsreeksen of referenties in uw code te beheren. Zodra u een verbinding hebt gemaakt, wordt er een alias gegenereerd waarnaar u kunt verwijzen vanuit elke functie in het item met gebruikersgegevensfuncties.

Een verbinding toevoegen:

1. Zoek en open uw functie-item voor gebruikersgegevens in de Fabric-portal.

2. Selecteer Verbindingen beheren op het lint van de editor voor gebruikersgegevensfuncties.

   

3. Selecteer Gegevensverbinding toevoegen in het deelvenster dat wordt geopend.

   

4. Wanneer de OneLake-catalogus wordt geopend, bladert u door de lijst met gegevensbronnen.

   Opmerking

   De lijst wordt gefilterd om alleen ondersteunde gegevensbronnen op te nemen waartoe uw gebruikersaccount toegang heeft. Gegevensbronnen kunnen zich in andere werkruimten bevinden. Als u de gewenste gegevensbron niet kunt vinden, controleert u of u over de juiste machtigingen beschikt om er verbinding mee te maken.

5. Kies uw gegevensbron en selecteer vervolgens Verbinding maken.

   

6. Zodra de verbinding is gemaakt, wordt de nieuwe verbinding weergegeven in het zijvenster op het tabblad Verbindingen . Noteer de aliasnaam die hiervoor is gegenereerd. U hebt deze alias nodig om te verwijzen naar de verbinding vanuit functies in uw gebruikersgegevensfunctiesitem.

   

Uw verbinding gebruiken in uw functiecode

Nadat u een verbinding hebt gemaakt, kunt u ernaar verwijzen in uw functiecode met behulp van de alias van de verbinding. De alias wordt automatisch gegenereerd op basis van de naam van de gegevensbron die u hebt verbonden. U voegt deze alias toe aan de @udf.connection decorator in uw functie en de verbinding verwerkt verificatie wanneer uw functie wordt uitgevoerd.

Hoewel u verbindingscode kunt toevoegen aan elke functie die u helemaal zelf schrijft, biedt een voorbeeld een beginpunt met de reeds geschreven verbindingscode. U hoeft alleen de alias te wijzigen zodat deze overeenkomt met uw verbinding.

De verbinding in uw code gebruiken:

1. Als u nog niet in de editor bent, opent u het functie-item voor gebruikersgegevens en selecteert u de modus Ontwikkelen en selecteert u vervolgens het tabblad Bewerken .

2. Selecteer Voorbeeld invoegen op het lint.

3. Selecteer in de vervolgkeuzelijst SQL Database>Leesgegevens uit een tabel in SQL Database.

   

   In het voorbeeld wordt de volgende code ingevoegd waarmee gegevens uit een SQL-databasetabel worden gelezen:

   @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
   

   Opmerking

   Met deze voorbeeldquery worden testgegevens inline gegenereerd met behulp van de VALUES component, zodat u de verbinding kunt testen, zelfs als uw database nog geen tabellen bevat. Wanneer u klaar bent om query's uit te voeren op uw eigen gegevens, vervangt u de query door een query die verwijst naar uw werkelijke tabellen.

4. Vervang <alias for sql database> in de @udf.connection decorator door de alias van de verbinding die u in de vorige sectie hebt gemaakt.

   Als uw verbindingsalias bijvoorbeeld is ContosoSalesDat, ziet de decorator er als volgt uit:

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

5. Test uw functie om te controleren of de verbinding correct werkt.

Nadat u de functie hebt getest met de verbinding, kunt u deze publiceren en uitvoeren. Zie Uw functies voor gebruikersgegevens testen voor meer informatie.

Een verbinding wijzigen of verwijderen

U kunt bestaande verbindingen wijzigen of verwijderen vanuit het deelvenster Verbindingen beheren . Houd echter rekening met het effect op uw functies voordat u wijzigingen aanbrengt.

Een verbindingsalias wijzigen

De alias van een bestaande verbinding wijzigen:

1. Open in de Fabric-portal het functie-item voor gebruikersgegevens.

2. Selecteer Verbindingen beheren op het lint.

3. Zoek in het deelvenster Verbindingen beheren de verbinding die u wilt wijzigen en selecteer het pictogram Verbinding bewerken (potlood).

4. Voer de naam van de nieuwe alias in.

5. Selecteer Bijwerken om de wijzigingen op te slaan.

Een verbinding verwijderen

Een verbinding verwijderen:

1. Open in de Fabric-portal het functie-item voor gebruikersgegevens.

2. Selecteer Verbindingen beheren op het lint.

3. Zoek in het deelvenster Verbindingen beheren de verbinding die u wilt verwijderen en selecteer het pictogram Verbinding verwijderen (prullenbak).

4. Bevestig de verwijdering.

Verwante inhoud

• Een gegevensfuncties-item voor Fabric-gebruikers maken vanuit de Fabric-omgeving of de Visual Studio Code-extensie gebruiken
• Leer meer over het programmeermodel voor functies met gebruikersgegevens