Freigeben über

Verbinden mit Datenquellen aus dem Fabric User Data Functions-Element (Vorschau)

Fabric User Data Functions stellt mithilfe des Features zum Verwalten von Verbindungen im Fabric-Portal native Datenquellenverbindungen bereit. Mit diesem Feature können Sie eine Verbindung mit Ihren Fabric-Datenquellen herstellen, ohne Verbindungszeichenfolgen erstellen oder Zugriffsanmeldeinformationen verwalten zu müssen.

In diesem Artikel erfahren Sie, wie Sie:

  • Erstellen Sie eine neue Verbindung für das User Data Functions-Element.
  • Verwenden Sie die neue Verbindung in Ihrem Funktionscode.
  • Ändern oder löschen Sie Ihre Datenverbindung.

In Fabric User Data Functions unterstützte Datenquellenverbindungen

Die folgenden Datenquellen werden für Fabric User Data Functions derzeit unterstützt:

Erstellen Sie eine neue Datenverbindung für das User Data Functions-Element.

Alle von Ihnen hinzugefügten Datenverbindungen sind Ihrem User Data Functions-Element zugeordnet. Zudem kann im Code einer beliebigen Funktion auf diese Datenverbindungen verwiesen werden. Um diesem Leitfaden zu folgen, benötigen Sie ein vorhandenes Fabric User Data Functions-Element und eine vorhandene Fabric-Datenquelle.

1. Zugreifen auf das Feature zum Verwalten von Verbindungen über das Functions-Portal

Suchen im Menüband des Editors im Functions-Portal die Option Verbindungen verwalten, und wählen Sie diese aus.

Screenshot: Editor im Functions-Portal mit hervorgehobener Schaltfläche „Verbindungen verwalten“

Der geöffnete Bereich enthält alle von Ihnen erstellten Datenverbindungen. Wählen Sie Datenverbindung hinzufügen aus, um eine neue Verbindung zu erstellen.

Screenshot: Seitenbereich, auf dem die Registerkarte „Verbindungen“ ausgewählt ist und keine Verbindungen aufgelistet sind

2. Auswählen der Datenverbindung aus dem OneLake-Katalog

Wenn Sie Datenverbindung hinzufügenauswählen, wird der OneLake-Katalog mit einer Liste aller Datenquellen geöffnet, auf die Ihr Benutzerkonto Zugriff hat. Die Liste wird so gefiltert, dass lediglich unterstützte Datenquellen enthalten sind. Einige diese Datenquellen können sich jedoch in weiteren Arbeitsbereichen befinden.

Wählen Sie Ihre Datenquelle und anschließend Verbinden aus.

Screenshot: OneLake-Datenkatalog mit einer Liste von Datenquellen

Hinweis

Wenn Sie die gesuchte Datenquelle nicht finden können, stellen Sie sicher, dass Sie über die richtigen Berechtigungen zum Herstellen einer Verbindung mit dieser Datenquelle verfügen. Stellen Sie alternativ sicher, dass Sie eine der am Anfang dieses Artikels aufgelisteten, unterstützten Datenquellen verwenden.

Nach der Erstellung wird im Seitenbereich auf der Registerkarte Verbindungen die neue Verbindung mit der ausgewählten Datenquelle angezeigt. Wenn die Verbindung angezeigt wird, notieren Sie sich das für sie generierte Feld Alias. Sie benötigen diesen Alias, um von einer beliebigen Funktion in Ihrem User Data Functions-Element auf die Verbindung zu verweisen.

Screenshot: Seitenbereich „Verbindungen“ mit einer neu erstellten Datenquellenverbindung

3. Verwenden des Verbindungsalias in Ihrem Funktionscode

Im Portal-Editor müssen Sie dem Code den Alias der Verbindung hinzufügen, die Sie auf der Registerkarte Manage Connections erstellt haben. In diesem Fall verwenden wird ein Codebeispiel namens „Lesen von Daten aus einer Tabelle in einer SQL-Datenbank“ verwendet. Sie können dieses Beispiel suchen, indem Sie auf die Registerkarte „Bearbeiten“ und anschließend auf die Schaltfläche „Beispiel einfügen“ klicken und zu „SQL-Datenbank“ navigieren.

Screenshot: Datenkatalog für „Beispiel einfügen“ mit einer Liste von Datenquellen

Der folgende Beispielcode wurde eingefügt:

@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

Hinweis

Dieses Beispiel stellt zwar eine Verbindung mit einer SQL-Datenbank her, es müssen jedoch kein Schema und keine Daten in Ihrer Datenbank ausgeführt werden.

Um die von Ihnen erstellte Datenverbindung zu verwenden, ändern Sie die folgende Zeile in diesem Beispiel: @udf.connection(argName="sqlDB",alias="<alias for sql database>"). Ersetzen Sie in dieser Zeile den Wert der alias durch den Wert, den Sie über das Menü Manage Connections erhalten haben. Im folgenden Code wird dieses Beispiel mit dem Wert ContosoSalesDat veranschaulicht:

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

Nachdem Sie den Code geändert haben, veröffentlichen Sie Ihre Funktion mithilfe der Schaltfläche „Veröffentlichen“ auf der Symbolleiste. Dieser Vorgang kann einige Minuten dauern.

Screenshot: Schaltfläche „Veröffentlichen“

Nachdem die Veröffentlichung abgeschlossen ist, können Sie Ihre Funktion ausführen, indem Sie in der Liste des Functions-Explorers auf den Namen der Funktion zeigen und im Seitenpanel auf die Schaltfläche „Ausführen“ klicken. Im unteren Panel „Ausgabe“ wird das Ergebnis der Ausführung der Funktion angezeigt.

Screenshot: Seitenpanel, das zum Ausführen einer Funktion verwendet wird

Sie haben nun alles erfahren, was Sie zum Herstellen einer Verbindung mit einer Datenquelle aus Ihrem Fabric User Data Functions-Element benötigen.

Nächste Schritte