Tutorial: Verwenden eines Notebooks mit Apache Spark zum Abfragen einer KQL-Datenbank

Notebooks sind sowohl lesbare Dokumente, die Beschreibungen und Ergebnisse der Datenanalyse enthalten, als auch ausführbare Dokumente, die zur Datenanalyse ausgeführt werden können. In diesem Artikel erfahren Sie, wie Sie ein Microsoft Fabric-Notebook verwenden, um mithilfe von Apache Spark Daten in einer KQL-Datenbank zu lesen und sie in diese zu schreiben. In diesem Tutorial werden vorab erstellte Datasets und Notebooks sowohl in der Real-Time Intelligence als auch in den Datentechnik-Umgebungen in Microsoft Fabric verwendet. Weitere Informationen zu Notebooks finden Sie unter Verwenden von Microsoft Fabric-Notebooks.

Sie lernen speziell Folgendes:

• Erstellen einer KQL-Datenbank
• Importieren eines Notebooks
• Schreiben von Daten in eine KQL-Datenbank mithilfe von Apache Spark
• Abfragen von Daten aus einer KQL-Datenbank

Voraussetzungen

• Ein Arbeitsbereich mit einer Microsoft Fabric-fähigen Kapazität

1. Erstellen einer KQL-Datenbank

1. Wählen Sie Ihren Arbeitsbereich in der linken Navigationsleiste aus.

2. Führen Sie einen der folgenden Schritte aus, um mit dem Erstellen eines Ereignisstreams zu beginnen:

   • Wählen Sie Neues Element und anschließend Eventhouse aus. Geben Sie nycGreenTaxi in das Feld Eventhouse-Name ein, und wählen Sie dann Erstellen aus. Eine KQL-Datenbank wird mit demselben Namen generiert.
   • Wählen Sie in einem vorhandenen Eventhouse die Option Datenbanken aus. Wählen Sie unter KQL-Datenbanken das Symbol + aus, geben Sie nycGreenTaxi in das Feld KQL-Datenbankname ein, und wählen Sie dann Erstellen aus.

3. Kopieren Sie den Abfrage-URI aus der Karte der Datenbankdetails im Datenbankdashboard, und fügen Sie ihn irgendwo, z. B. in einen Editor, ein, um ihn in einem späteren Schritt zu verwenden.

   

2. Herunterladen des NYC GreenTaxi-Notebooks

Wir haben ein Beispielnotebook erstellt, das Sie durch alle erforderlichen Schritte zum Laden von Daten in Ihre Datenbank mit dem Spark-Connector führt.

1. Öffnen Sie das Fabric-Beispielrepository auf GitHub, um das NYC GreenTaxi KQL-Notebook herunterzuladen.

   

2. Speichern Sie das Notebook lokal auf Ihrem Gerät.

   Hinweis

   Das Notebook muss im Dateiformat .ipynb gespeichert werden.

3. Importieren des Notebooks

Der Rest dieses Workflows erfolgt im Abschnitt Datentechnik des Produkts und verwendet ein Spark-Notebook, um Daten in Ihre KQL-Datenbank zu laden und abzufragen.

1. Wählen Sie in Ihrem Arbeitsbereich Importieren>Notebook>Von diesem Computer>Hochladen und dann das Notebook „NYC GreenTaxi“ aus, das Sie zuvor heruntergeladen haben.

   

2. Öffnen Sie das Notebook nach Abschluss des Imports in Ihrem Arbeitsbereich.

4. Abrufen der Daten

Um Ihre Datenbank mithilfe des Spark-Connectors abzufragen, müssen Sie Lese- und Schreibzugriff auf den NYC GreenTaxi-Blobcontainer gewähren.

Wählen Sie die Wiedergabeschaltfläche aus, um die folgenden Zellen auszuführen, oder wählen Sie die Zelle aus, und drücken Sie UMSCHALT+EINGABETASTE. Wiederholen Sie diesen Schritt für jede Codezelle.

Hinweis

Warten Sie, bis das Häkchen angezeigt wird, bevor Sie die nächste Zelle ausführen.

1. Führen Sie die folgende Zelle aus, um den Zugriff auf den NYC GreenTaxi-Blobcontainer zu ermöglichen.

   

2. Fügen Sie in KustoURI den zuvor kopiertenAbfrage-URI anstelle des Platzhaltertexts ein.

3. Ändern Sie den Platzhalternamen der Datenbank in nycGreenTaxi.

4. Ändern Sie den Platzhalternamen der Tabelle in GreenTaxiData.

   

5. Führen Sie die Zelle aus.

6. Führen Sie die nächste Zelle aus, um Daten in Ihre Datenbank zu schreiben. Es kann einige Minuten dauern, bis der Vorgang abgeschlossen ist.

   

Ihre Datenbank enthält nun Daten, die in eine Tabelle mit dem Namen GreenTaxiData geladen wurden.

5. Ausführen des Notebooks

Führen Sie die verbleibenden beiden Zellen sequenziell aus, um Daten aus Ihrer Tabelle abzufragen. Die Ergebnisse zeigen die 20 besten und niedrigsten Taxitarife und Entfernungen, die nach Jahr aufgezeichnet wurden.

6. Bereinigen der Ressourcen

Bereinigen Sie die erstellten Elemente, indem Sie zu dem Arbeitsbereich navigieren, in dem sie erstellt wurden.

1. Zeigen Sie in Ihrem Arbeitsbereich auf das Notebook, das Sie löschen möchten, und wählen Sie Menü „Mehr“ [...] >Löschen aus.

   

2. Klicken Sie auf Löschen. Sie können Ihr Notebook nach dem Löschen nicht mehr wiederherstellen.

Zugehöriger Inhalt

• Abfragen von Daten in einem KQL-Abfrageset
• Visualisieren von Daten in einem Power BI-Bericht