Schnellstart: Erstellen eines Azure Stream Analytics-Auftrags in Visual Studio Code

In dieser Schnellstartanleitung wird gezeigt, wie Sie mithilfe einer Azure Stream Analytics-Tools-Erweiterung für Visual Studio Code einen Azure Stream Analytics-Auftrag erstellen und ausführen. Der Beispielauftrag liest Streamingdaten von einem Azure IoT Hub-Gerät. Sie legen einen Auftrag fest, der bei Überschreitung von 27 Grad die Durchschnittstemperatur berechnet und die entsprechenden Ausgabeereignisse in eine neue Datei im Blobspeicher schreibt.

Hinweis

Visual Studio und Visual Studio Code Tools unterstützen keine Aufträge in den Regionen „China, Osten“, „China, Norden“, „Deutschland, Mitte“ oder „Deutschland, Nordosten“.

Voraussetzungen

Installieren der Azure Stream Analytics-Tools-Erweiterung

  1. Öffnen Sie Visual Studio Code.

  2. Suchen Sie in Erweiterungen im linken Bereich nach Stream Analytics, und wählen Sie in der Azure Stream Analytics-Tools-Erweiterung Installieren aus.

  3. Sobald die Erweiterung installiert ist, überprüfen Sie, ob Azure Stream Analytics-Tools unter Aktivierte Erweiterungen sichtbar ist.

    Azure Stream Analytics-Tools unter den aktivierten Erweiterungen in Visual Studio Code

Aktivieren der Azure Stream Analytics-Tools-Erweiterung

  1. Wählen Sie auf der Aktivitätsleiste von Visual Studio Code das Azure-Symbol aus. Wählen Sie auf der Seitenleiste unter Stream AnalyticsBei Azure anmelden aus.

    Anmelden bei Azure in Visual Studio Code

  2. Wenn Sie angemeldet sind, wird der Name Ihres Azure-Kontos auf der Statusleiste in der linken unteren Ecke des Visual Studio Code-Fensters angezeigt.

Hinweis

Die Azure Stream Analytics-Tools-Erweiterung führt die Anmeldung beim nächsten Mal automatisch durch, wenn Sie sich nicht abmelden. Wenn Ihr Konto über zweistufige Authentifizierung verfügt, empfehlen wir anstelle einer PIN die Verwendung der Telefonauthentifizierung. Wenn beim Auflisten von Ressourcen Probleme auftreten, lässt sich das meistens durch Abmelden und erneutes Anmelden beheben. Geben Sie zum Abmelden den Befehl Azure: Sign Out ein.

Vorbereiten der Eingabedaten

Vor dem Definieren des Stream Analytics-Auftrags sollten Sie die Daten vorbereiten, die später als Auftragseingabe konfiguriert werden. Führen Sie die folgenden Schritte aus, um die für den Auftrag erforderlichen Eingabedaten vorzubereiten:

  1. Melden Sie sich beim Azure-Portal an.

  2. Wählen Sie Ressource erstellenInternet der Dinge (IoT)IoT Hub aus.

  3. Geben Sie im Bereich IoT Hub die folgenden Informationen ein:

    Einstellung Empfohlener Wert Beschreibung
    Subscription <Ihr Abonnement> Wählen Sie das gewünschte Azure-Abonnement aus.
    Ressourcengruppe asaquickstart-resourcegroup Wählen Sie Neu erstellen aus, und geben Sie einen neuen Ressourcengruppennamen für Ihr Konto ein.
    Region <Die Region, die Ihren Benutzern am nächsten liegt> Wählen Sie einen geografischen Standort aus, an dem Sie Ihre IoT Hub-Instanz hosten können. Verwenden Sie den Standort, der Ihren Benutzern am nächsten ist.
    IoT Hub-Name MyASAIoTHub Wählen Sie einen Namen für Ihre IoT Hub-Instanz aus.

    Erstellen eines IoT-Hubs

  4. Klicken Sie auf Weiter: Set size and scale (Größe und Skalierung festlegen).

  5. Treffen Sie eine Auswahl für Preis- und Staffelungstarif. Legen Sie für diese Schnellstartanleitung den Tarif F1 – Free fest, wenn er für Ihr Abonnement noch verfügbar ist. Falls der Tarif „Free“ nicht verfügbar ist, sollten Sie den niedrigsten verfügbaren Tarif wählen. Weitere Informationen finden Sie unter Azure IoT Hub – Preise.

    Festlegen der Größe und Skalieren Ihrer IoT Hub-Instanz

  6. Klicken Sie auf Überprüfen + erstellen. Überprüfen Sie die Informationen zu IoT Hub, und wählen Sie Erstellen aus. Die Erstellung des IoT Hubs kann mehrere Minuten dauern. Sie können den Fortschritt im Bereich Benachrichtigungen überwachen.

  7. Wählen Sie in Ihrem IoT Hub-Navigationsmenü unter IoT-Geräte die Option Hinzufügen aus. Fügen Sie eine ID für Geräte-ID hinzu, und wählen Sie Speichern aus.

    Hinzufügen eines Geräts zu Ihrer IoT Hub-Instanz

  8. Öffnen Sie das Gerät nach der Erstellung in der Liste IoT-Geräte. Kopieren Sie die Zeichenfolge in Verbindungszeichenfolge (primärer Schlüssel) , und speichern Sie sie zur späteren Verwendung in einem Editor.

    Kopieren der Verbindungszeichenfolge für das IoT Hub-Gerät

Ausführen des IoT-Simulators

  1. Öffnen Sie den Raspberry Pi Azure IoT Online Simulator über eine neue Browserregisterkarte oder ein neues Fenster.

  2. Ersetzen Sie den Platzhalter in Zeile 15 durch die Verbindungszeichenfolge für das IoT Hub-Gerät, die Sie zuvor gespeichert haben.

  3. Klicken Sie auf Run (Ausführen). In der Ausgabe sollten nun die Sensordaten und -nachrichten angezeigt werden, die an Ihre IoT Hub-Instanz gesendet werden.

    Raspberry Pi-Azure IoT-Onlinesimulator mit Ausgabe

Erstellen eines Blobspeichers

  1. Wählen Sie in der linken oberen Ecke des Azure-Portals Ressource erstellenSpeicherSpeicherkonto aus.

  2. Geben Sie im Bereich Speicherkonto erstellen einen Speicherkontonamen, den Standort und die Ressourcengruppe ein. Wählen Sie den gleichen Speicherort und die gleiche Ressourcengruppe wie für die von Ihnen erstellte IoT Hub-Instanz aus. Wählen Sie dann zum Erstellen des Kontos Überprüfen + erstellen aus.

    Speicherkonto erstellen

  3. Wählen Sie nach der Erstellung des Speicherkontos im Bereich Übersicht die Kachel Blobs aus.

    Speicherkontoübersicht

  4. Wählen Sie auf der Seite Blob-Dienst die Option Container aus, und geben Sie einen Namen für Ihren Container (etwa container1) ein. Übernehmen Sie für Öffentliche Zugriffsebene die Option Privat (kein anonymer Zugriff) , und wählen Sie OK aus.

    Erstellen eines Blobcontainers

Erstellen eines Stream Analytics-Projekts

  1. Wählen Sie in Visual Studio Code STRG+UMSCHALT+P aus, um die Befehlspalette zu öffnen. Geben Sie dann ASA ein, und wählen Sie ASA: Neues Projekt erstellen aus.

    Erstellen eines neuen Projekts

  2. Geben Sie Ihren Projektnamen ein, z. B. myASAproj, und wählen Sie einen Ordner für Ihr Projekt aus.

    Erstellen eines Projektnamens

  3. Das neue Projekt wird Ihrem Arbeitsbereich hinzugefügt. Ein Stream Analytics-Projekt besteht aus drei Ordnern: Inputs, Outputs und Functions. Es verfügt außerdem über das Abfrageskript (*.asaql) , eine JobConfig.json-Datei, und eine asaproj.json-Konfigurationsdatei.

    Die asaproj.json-Konfigurationsdatei enthält die Eingaben, Ausgaben und Auftragskonfigurationsdatei-Informationen, die für die Übermittlung des Stream Analytics-Auftrags an Azure erforderlich sind.

    Stream Analytics-Projektdateien in Visual Studio Code

Hinweis

Beim Hinzufügen von Eingaben und Ausgaben aus der Befehlspalette werden die entsprechenden Pfade automatisch asaproj.json hinzugefügt. Wenn Sie Eingaben oder Ausgaben direkt auf einem Datenträger hinzufügen oder entfernen, müssen Sie sie manuell zu asaproj.json hinzufügen bzw. aus ihr entfernen. Sie können sich auch entscheiden, die Eingaben und Ausgaben an einem Ort zu versammeln und dann in verschiedenen Aufträgen auf sie verweisen, indem Sie in jeder asaproj.json-Datei die Pfade angeben.

Definieren der Transformationsabfrage

  1. Öffnen Sie myASAproj.asaql aus Ihrem Projektordner.

  2. Fügen Sie die folgende Abfrage hinzu:

    SELECT *
    INTO Output
    FROM Input
    WHERE Temperature > 27
    

Definieren einer Liveeingabe

  1. Klicken Sie im Stream Analytics-Projekt mit der rechten Maustaste auf den Ordner Inputs. Wählen Sie anschließend ASA: Eingabe hinzufügen im Kontextmenü aus.

    Hinzufügen von Eingaben aus dem Ordner „Inputs“

    Wählen Sie alternativ STRG+UMSCHALT+P aus, um die Befehlspalette zu öffnen, und geben Sie ASA: Eingabe hinzufügen ein.

    Hinzufügen einer Stream Analytics-Eingabe in Visual Studio Code

  2. Wählen Sie als Eingabetyp IoT Hub aus.

    Auswählen von „IoT Hub“ als Eingabeoption

  3. Wenn Sie die Eingabe über die Befehlspalette hinzugefügt haben, wählen Sie das Stream Analytics-Abfrageskript aus, von dem die Eingabe verwendet werden soll. Es sollte automatisch mit dem Dateipfad zu myASAproj.asaql aufgefüllt werden.

    Auswählen eines Stream Analytics-Skripts in Visual Studio Code

  4. Wählen Sie im Dropdownmenü die Option Aus Ihren Azure-Abonnements auswählen aus.

    Auswählen aus Abonnements

  5. Bearbeiten Sie die neu generierte IoTHub1.json-Datei mit den folgenden Werten. Behalten Sie die Standardwerte für Felder bei, die hier nicht aufgeführt sind.

    Einstellung Vorgeschlagener Wert Beschreibung
    Name Eingabe Geben Sie einen Namen zur Identifizierung der Eingabe des Auftrags ein.
    IotHubNamespace MyASAIoTHub Wählen Sie den Namen Ihrer IoT Hub-Instanz aus, oder geben Sie ihn ein. IoT Hub-Namen werden automatisch erkannt, wenn sie unter demselben Abonnement erstellt werden.
    SharedAccessPolicyName iothubowner

    Sie können das CodeLens-Feature verwenden, um sich bei der Eingabe einer Zeichenfolge, der Auswahl aus einer Dropdownliste oder direkten Änderungen von Text in der Datei unterstützen zu lassen. Der folgende Screenshot zeigt Select from your Subscriptions (Aus Ihren Abonnements auswählen) als Beispiel. Die Anmeldeinformationen werden automatisch aufgelistet und in der lokalen Anmeldeinformationsverwaltung gespeichert.

    Konfigurieren von Eingaben in Visual Studio Code

    Konfigurieren des Eingabewerts in Visual Studio Code

Anzeigen einer Eingabevorschau

Wählen Sie Datenvorschau in der obersten Zeile von IoTHub1.json aus. Es werden einige Eingabedaten aus der IoT Hub-Instanz abgerufen und im Vorschaufenster angezeigt. Dieser Vorgang kann etwas dauern.

Vorschau der Liveeingabe

Definieren einer Ausgabe

  1. Wählen Sie STRG+UMSCHALT+P aus, um die Befehlspalette zu öffnen. Geben Sie dann ASA: Ausgabe hinzufügen ein.

    Hinzufügen einer Stream Analytics-Ausgabe in Visual Studio Code

  2. Wählen Sie als Senkentyp Blob Storage aus.

  3. Wählen Sie das Stream Analytics-Abfrageskript aus, das diese Eingabe verwenden soll.

  4. Geben Sie als Namen der Ausgabedatei BlobStorage ein.

  5. Bearbeiten Sie BlobStorage mit den folgenden Werten. Behalten Sie die Standardwerte für Felder bei, die hier nicht aufgeführt sind. Das CodeLens-Feature unterstützt Sie beim Auswählen aus einer Dropdownliste oder beim Eingeben einer Zeichenfolge.

    Einstellung Vorgeschlagener Wert Beschreibung
    Name Output Geben Sie einen Namen ein, um die Ausgabe des Auftrags kenntlich zu machen.
    Speicherkonto asaquickstartstorage Wählen Sie den Namen Ihres Speicherkontos aus, oder geben Sie ihn ein. Speicherkontonamen werden automatisch erkannt, wenn sie im gleichen Abonnement erstellt werden.
    Container container1 Wählen Sie den vorhandenen Container aus, den Sie in Ihrem Speicherkonto erstellt haben.
    Pfadmuster output Geben Sie den Namen eines Dateipfads ein, der innerhalb des Containers erstellt werden soll.

    Konfigurieren von Ausgaben in Visual Studio Code

Kompilieren des Skripts

Die Skriptkompilierung überprüft die Syntax und generiert die Azure Resource Manager-Vorlagen für die automatische Bereitstellung.

Es gibt zwei Möglichkeiten, die Skriptkompilierung auszulösen:

  • Wählen Sie das Skript im Arbeitsbereich aus, und kompilieren Sie dann in der Befehlspalette.

    Verwenden der Visual Studio Code-Befehlspalette zum Kompilieren des Skripts

  • Klicken Sie mit der rechten Maustaste auf das Skript, und wählen Sie ASA: Compile Script ein.

    Klicken mit der rechten Maustaste auf das zu kompilierende Stream Analytics-Skript

Nach der Kompilierung finden Sie die zwei generierten Azure Resource Manager-Vorlagen im Ordner Deploy Ihres Projekts. Diese zwei Dateien werden für die automatische Bereitstellung verwendet.

Stream Analytics-Bereitstellungsvorlagen im Datei-Explorer

Übermitteln eines Stream Analytics-Auftrags an Azure

  1. Wählen Sie im Skript-Editor-Fenster des Abfrageskripts An Azure übermitteln aus.

    Auswählen Ihres Abonnementtexts im Skript-Editor

  2. Wählen Sie in der Popupliste Ihr Abonnement aus.

  3. Wählen Sie Auftrag auswählen aus. Wählen Sie dann Neuen Auftrag erstellen aus.

  4. Geben Sie den Auftragsnamen myASAjob ein. Befolgen Sie dann die Anweisungen, um die Ressourcengruppe und den Speicherort auszuwählen.

  5. Wählen Sie An Azure übermitteln aus. Sie finden die Protokolle im Ausgabefenster.

  6. Wenn der Auftrag erstellt wurde, wird er im Stream Analytics-Explorer angezeigt.

    Im Stream Analytics-Explorer aufgelisteter Auftrag

Starten des Stream Analytics-Auftrags und Überprüfen der Ausgabe

  1. Öffnen Sie den Stream Analytics-Explorer in Visual Studio Code, und suchen Sie Ihren Auftrag myASAJob.

  2. Klicken Sie mit der rechten Maustaste auf den Auftragsnamen. Wählen Sie dann im Kontextmenü Start aus.

    Starten des Stream Analytics-Auftrags in Visual Studio Code

  3. Wählen Sie im Popupfenster Jetzt aus, um den Auftrag zu starten.

  4. Beachten Sie, dass sich der Auftragsstatus in Wird ausgeführt geändert hat. Klicken Sie mit der rechten Maustaste auf den Namen des Auftrags, und wählen Sie Auftragsansicht im Portal öffnen aus, um die Eingabe- und Ausgabeereignismetriken anzuzeigen. Diese Aktion kann einige Minuten dauern.

  5. Um die Ergebnisse anzuzeigen, öffnen Sie den Blobspeicher in der Visual Studio Code-Erweiterung oder im Azure-Portal.

Bereinigen von Ressourcen

Löschen Sie die Ressourcengruppe, den Streamingauftrag und alle dazugehörigen Ressourcen, wenn Sie sie nicht mehr benötigen. Durch das Löschen des Auftrags verhindern Sie, dass die vom Auftrag verbrauchten Streamingeinheiten abgerechnet werden.

Wenn Sie den Auftrag in Zukunft verwenden möchten, können Sie ihn beenden und später neu starten. Wenn Sie diesen Auftrag nicht mehr verwenden möchten, löschen Sie alle Ressourcen, die im Rahmen dieser Schnellstartanleitung erstellt wurden, mit folgenden Schritten:

  1. Wählen Sie im Azure-Portal im Menü auf der linken Seite Ressourcengruppen und dann den Namen der erstellten Ressource aus.

  2. Wählen Sie auf der Ressourcengruppenseite die Option Löschen aus. Geben Sie den Namen der zu löschenden Ressourcengruppe in das Textfeld ein, und wählen Sie dann Löschen aus.

Nächste Schritte

In dieser Schnellstartanleitung haben Sie einen einfachen Stream Analytics-Auftrag mit Visual Studio Code bereitgestellt. Stream Analytics-Aufträge können auch mit Azure-Portal, PowerShell und Visual Studio bereitgestellt werden.

Informationen zu den Azure Stream Analytics-Tools für Visual Studio Code finden Sie in folgenden Artikeln: