Partager via

Se connecter à des sources de données à partir de votre élément de fonctions de données utilisateur Fabric (préversion)

Les fonctions de données utilisateur Fabric fournissent des connexions de source de données natives à l’aide de la fonctionnalité Gérer les connexions sur le portail Fabric. Cette fonctionnalité vous permet de vous connecter à vos sources de données Fabric sans avoir à créer de chaînes de connexion ni gérer des informations d’identification d’accès.

Dans cet article, vous allez apprendre à :

  • Créez une connexion pour votre élément de fonctions de données utilisateur.
  • Utilisez votre nouvelle connexion dans votre code de fonction.
  • Modifiez ou supprimez votre connexion de données.

Connexions de source de données prises en charge dans les fonctions de données utilisateur Fabric

Les sources de données suivantes sont actuellement prises en charge pour les fonctions de données utilisateur Fabric :

Créer une connexion de données pour votre élément de fonctions de données utilisateur

Toutes les connexions de données que vous ajoutez sont associées à votre élément de fonctions de données utilisateur et peuvent être référencées dans le code de l’une de vos fonctions. Pour suivre ce guide, vous avez besoin d’un élément de fonctions de données utilisateur Fabric existant et d’une source de données Fabric existante.

1. Accéder à la fonctionnalité Gérer les connexions à partir du portail Functions

Recherchez et sélectionnez Gérer les connexions dans le ruban de l’éditeur du portail Functions.

Capture d’écran de l’éditeur du portail Functions avec le bouton Gérer les connexions mis en surbrillance.

Le volet qui s’ouvre contient les connexions de données que vous avez créées. Sélectionnez Ajouter une connexion de données pour créer une connexion.

Capture d’écran du volet latéral avec l’onglet Connexions sélectionné. Aucune connexion n’est répertoriée.

2. Sélectionner votre connexion de données dans le catalogue OneLake

Lorsque vous sélectionnez Ajouter une connexion de données, le catalogue OneLake s’ouvre avec une liste de toutes les sources de données auxquelles votre compte d’utilisateur a accès. La liste est filtrée pour inclure uniquement les sources de données prises en charge, dont certaines peuvent se trouver dans d’autres espaces de travail.

Choisissez votre source de données, puis sélectionnez Se connecter.

Capture d’écran du catalogue de données OneLake avec une liste de sources de données.

Remarque

Si vous ne trouvez pas la source de données que vous recherchez, vérifiez que vous disposez des autorisations appropriées pour vous y connecter. Vous pouvez également vous assurer que vous utilisez une source de données prise en charge, comme indiqué au début de cet article.

Une fois créée, la nouvelle connexion à la source de données sélectionnée s’affiche dans le volet latéral de l’onglet Connexions. Lorsque vous voyez la connexion, notez le champ Alias qui a été généré pour celle-ci. Vous avez besoin de cet alias pour référencer la connexion à partir de n’importe quelle fonction dans votre élément de fonctions de données utilisateur.

Capture d’écran du volet latéral Connexions avec une nouvelle connexion de source de données créée.

3. Utiliser votre alias de connexion dans votre code de fonction

Une fois que vous êtes de retour dans l’éditeur du portail, vous devez ajouter l’alias de la connexion que vous avez créée dans l’onglet Manage Connections à votre code. Dans ce cas, nous allons utiliser un exemple de code appelé « Lire des données à partir d’une table dans SQL Database ». Vous trouverez cet exemple en cliquant sur l’onglet Modifier, puis en cliquant sur le bouton « Insérer un exemple » et en accédant à « SQL Database ».

Capture d’écran du catalogue de données Insérer un exemple avec une liste de sources de données.

Voici l’exemple de code qui a été inséré :

@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

Remarque

Bien que cet exemple se connecte à une base de données SQL, il n’a pas besoin d’un schéma ou de données dans votre base de données pour s’exécuter.

Pour utiliser la connexion de données que vous avez créée, modifiez la ligne suivante dans cet exemple : @udf.connection(argName="sqlDB",alias="<alias for sql database>") en remplaçant la valeur de alias par celle que vous avez obtenue à partir du menu Manage Connections. Le code suivant montre cet exemple avec la valeur ContosoSalesDat :

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

Après avoir modifié le code, publiez votre fonction à l’aide du bouton Publier dans la barre d’outils. Cette opération peut prendre quelques minutes.

Capture d’écran du bouton Publier.

Une fois la publication terminée, vous pouvez exécuter votre fonction en pointant sur son nom dans la liste de l’Explorateur de fonctions, puis en cliquant sur le bouton Exécuter dans le volet latéral. Le panneau inférieur « Sortie » affiche le résultat de l’exécution de la fonction.

Capture d’écran du panneau latéral utilisé pour exécuter une fonction.

Et c’est tout ce dont vous avez besoin pour vous connecter à une source de données à partir de vos fonctions de données utilisateur Fabric.

Étapes suivantes