Delen via

Stream Analytics-taakdiagram (preview) in Azure Portal

  • Artikel

Het taakdiagram in Azure Portal kan u helpen bij het visualiseren van de querystappen van uw taak (logisch concept) of streamingknooppunt (fysiek concept) met de invoerbron, uitvoerbestemming en metrische gegevens. U kunt het taakdiagram gebruiken om de metrische gegevens voor elke stap of streamingknooppunt te onderzoeken en snel de bron van een probleem te identificeren wanneer u problemen oplost.

Er zijn twee soorten taakdiagrammen:

  • Fysiek diagram: hiermee worden de belangrijkste metrische gegevens van de Stream Analytics-taak gevisualiseerd met het concept van de fysieke berekening: dimensie streamingknooppunt. Een streamingknooppunt vertegenwoordigt een set rekenresources die worden gebruikt voor het verwerken van de invoergegevens van de taak. Zie de dimensie naam van het Azure Stream Analytics-knooppunt voor meer informatie over de dimensie streamingknooppunten.

    Binnen elk streamingknooppunt zijn er Stream Analytics-processors beschikbaar voor het verwerken van de streamgegevens. Elke processor vertegenwoordigt een of meer stappen in uw query. U kunt de processortopologie in elk streamingknooppunt visualiseren met behulp van het processordiagram in het fysieke taakdiagram.

  • Logisch diagram: hiermee worden de belangrijkste metrische gegevens van de Stream Analytics-taak gevisualiseerd met het logische concept: querystap op basis van de query's van de taak. Zie Foutopsporing met het logische taakdiagram (preview) in Azure Portal voor meer informatie.

In dit artikel worden de twee typen taakdiagrammen beschreven om u te helpen.

Belangrijk

Deze functie is momenteel beschikbaar als PREVIEW-versie. Raadpleeg de Aanvullende voorwaarden voor Microsoft Azure-previews voor juridische voorwaarden die van toepassing zijn op Azure-functies die in bèta of preview zijn of die anders nog niet algemeen beschikbaar zijn.

Het taakdiagram gebruiken

Zoek en selecteer een Stream Analytics-taak in Azure Portal. Selecteer vervolgens taakdiagram (preview) onder Ontwikkelhulpprogramma's:

Schermopname van de locatie van het taakdiagram in de portalstructuur.

In de linkerbovenhoek kunt u de twee typen taakdiagrammen wijzigen door te klikken op Logisch, Fysiek.

Schermopname van de taakdiagramwisselaar.

Diagram van fysieke taak

In de volgende schermopname ziet u een fysiek taakdiagram met een standaardperiode (afgelopen 30 minuten).

Schermopname van secties van het fysieke taakdiagram.

  1. Opdrachtbalksectie: het is het opdrachtgebied waar u het tijdsbereik van de metrische taakgegevens kunt configureren, heatmapvisualisatie kunt schakelen/configureren, een streamingknooppunt kunt doorzoeken en kunt schakelen tussen Diagram en Tabel.

    • Heatmap-instellingen: met de heatmap-instelling kunt u de knooppunten in een diagram sorteren op basis van uw gewenste metrische gegevens en sorteertype. De metrische gegevens kunnen CPU-/geheugengebruik, watermerkvertraging, invoergebeurtenis en backloginvoergebeurtenissen zijn.

    • Tijdsbereik: u kunt een ander tijdsbereik en een andere taakuitvoering kiezen om het diagram en de metrische gegevens weer te geven.

    • Taakuitvoering: taakuitvoering bevindt zich binnen het tijdsbereik. Wanneer een taak wordt gestart, opnieuw gestart of omhoog/omlaag geschaald (SU-wijzigingen), wordt er een nieuwe taakuitvoering gegenereerd. Eén taakuitvoeringstoewijzingen in een fysiek taakdiagram.

    • Diagram-/tabelweergavewisselaar: u kunt de weergave schakelen tussen diagram en tabel. De tabelweergave wordt weergegeven zoals hieronder:

      Schermopname van een fysiek taakdiagram met een tabeloverzicht.

  2. Diagram-/tabelsectie: dit is de plaats waar u de metrische gegevens kunt weergeven (geaggregeerd binnen het geselecteerde tijdsbereik) op streamingknooppuntniveau met diagramweergave of tabelweergave. Elk vak in deze sectie vertegenwoordigt een streamingknooppunt dat wordt gebruikt om de invoergegevens te verwerken. De metrische gegevens op elk knooppunt zijn:

    • Invoerevenementen (type aggregatie: SOM)
    • CPU-gebruik (aggregatietype: Gem)
    • SU (geheugen) % gebruik (aggregatietype: Max)
    • Partitie-id's (een lijst, geen aggregatie)
    • Watermerkvertraging (Aggregatietype: Max)
    • Teruggelogde invoergebeurtenissen (aggregatietype: SUM)

    Zie de naamdimensie van het Azure Stream Analytics-knooppunt voor meer informatie over de definitie van metrische gegevens.

  3. Grafieksectie: dit is de plaats waar u de historische metrische gegevens binnen het geselecteerde tijdsbereik kunt bekijken. De standaardmetrieken die worden weergegeven in de standaardgrafiek zijn SU (Geheugen) % gebruik en CPU % gebruik'. U kunt ook meer grafieken toevoegen door op Grafiek toevoegen te klikken.

De sectie Diagram/Tabel en grafieksectie kunnen interactief met elkaar zijn. U kunt meerdere knooppunten selecteren in de sectie Diagram/Tabel om de metrische gegevens in de grafieksectie te laten filteren op de geselecteerde knooppunten en omgekeerd.

Schermopname van de interactie van het knooppuntdiagram van het fysieke taakdiagram.

Zie Foutopsporing met het fysieke taakdiagram (preview) in Azure Portal voor meer informatie over het opsporen van fouten in een fysiek diagram.

Processordiagram in fysiek taakdiagram

Het processordiagram in het fysieke taakdiagram visualiseert de processortopologie in het specifieke streamingknooppunt. Als u het processordiagram wilt openen, moet u het fysieke taakdiagram openen, een streamingknooppunt zoeken dat u het processordiagram wilt controleren en vervolgens het processordiagram openen door op de naam van het streamingknooppunt te klikken.

Schermopname van het invoerpunt voor processordiagrammen.

Schermopname van de weergave processordiagram.

  1. Sectie informatiebalk: dit is de plaats waar u de basisinformatie voor dit processordiagram kunt bekijken, zoals het tijdsbereik, de bijbehorende naam van het streamingknooppunt.
  2. Diagramsectie: dit is de plaats waar het processordiagram wordt gevisualiseerd. Elk knooppuntvak in deze sectie vertegenwoordigt een processor die de streamgegevens voor bepaald doel verwerkt.

    • Processortype: het toont het type processor, staat voor bepaalde gegevensverwerkingsdoeleinden. Deze is beschikbaar in elk processorknooppunt.

      Processortype Beschrijving
      Invoer of uitvoer Deze processor wordt gebruikt voor het lezen van invoer- of het schrijven van uitvoergegevensstromen.
      ReferenceData Deze processor wordt gebruikt voor het ophalen van de referentiegegevens.
      Informatica Deze processor wordt gebruikt voor het verwerken van de stroomgegevens volgens de querylogica, bijvoorbeeld het samenvoegen, filteren, groeperen met venster, enzovoort. Zie de naslaginformatie over de queryfuncties voor gegevensberekeningen voor stromen voor meer informatie over de queryfuncties voor gegevensberekeningen in Azure Stream Analytics.
      MarshallerUpstream en MarshallerDownstream Wanneer er streamgegevensinteractie is tussen streamingknooppunten, zijn er twee marshallerprocessors: 1). MarshallerUpstream voor het verzenden van de gegevens in het stroomstreamstream-knooppunt en 2). MarshallerDownstream voor het ontvangen van de gegevens in het downstreamstream-knooppunt.
      Fusie Deze processor is het ontvangen van de gegevens van de stream van de kruisingspartitie, die zijn uitgevoerd vanuit verschillende upstream-streamingknooppunten. De aanbevolen procedure voor het optimaliseren van de taakprestaties is het bijwerken van query's om de fusieprocessor te verwijderen om de taak parallel te maken, omdat de fusieprocessor het knelpunt van de taak is. Met de functie taakdiagramsimulator in visual Studio Code ASA-extensie kunt u uw query lokaal simuleren wanneer u uw taakquery optimaliseert. Zie Query optimaliseren met behulp van taakdiagramsimulator (preview) voor meer informatie.

      Schermopname van marshaller- en fusiediagram.

    • Adaptertype: het toont het type invoer- of uitvoeradapter. Stream Analytics ondersteunt verschillende invoerbronnen en uitvoerbestemmingen. Elke invoerbron- of uitvoerbestemming heeft een toegewezen adaptertype. Deze is alleen beschikbaar in invoerprocessor en uitvoerprocessor. 'InputBlob' vertegenwoordigt bijvoorbeeld de ADLS Gen2-invoer waar de invoerprocessor de gegevens van ontvangt; 'OutputDocumentDb' vertegenwoordigt de Cosmos DB-uitvoer waarnaar de uitvoerprocessor de gegevens uitvoert.

      Zie het overzicht van Invoer- en uitvoer van Azure Stream Analytics en het overzicht van De uitvoer van Azure Stream Analytics voor meer informatie over de invoer- en uitvoertypen.

    • Partitie-id's: deze geeft aan welke partitie-id's de gegevens van deze processor worden verwerkt. Deze is alleen beschikbaar in invoerprocessor en uitvoerprocessor.

    • Serializer-type: het toont het type serialisatie. Stream Analytics ondersteunt verschillende serialisatietypen. Deze is alleen beschikbaar in invoerprocessor en uitvoerprocessor.

Diagram van logische taak

Het logische taakdiagram heeft een vergelijkbare indeling als het fysieke diagram, met drie secties, maar heeft verschillende metrische gegevens en configuratie-instellingen.

Schermopname van de secties van het logische taakdiagram.

  1. Sectie opdrachtbalk: in logisch diagram kunt u de cloudtaak uitvoeren (stoppen, verwijderen) en het tijdsbereik van de metrische taakgegevens configureren. De diagramweergave is alleen beschikbaar voor logische diagrammen.

  2. Diagramsectie: het knooppuntvak in deze selectie vertegenwoordigt de invoer-, uitvoer- en querystappen van de taak. U kunt de metrische gegevens in het knooppunt rechtstreeks of in de grafieksectie interactief bekijken door op een bepaald knooppunt in deze sectie te klikken. Zie de naamdimensie van het Azure Stream Analytics-knooppunt voor meer informatie over de definitie van metrische gegevens.

  3. Grafieksectie: de grafieksectie in een logisch diagram heeft twee tabbladen: Metrische gegevens en activiteitenlogboeken.

    • Metrische gegevens: de metrische gegevens van de taak worden hier weergegeven wanneer de bijbehorende metrische gegevens zijn geselecteerd in het rechterdeelvenster.
    • Activiteitenlogboeken: de bewerkingen die op taken worden uitgevoerd, worden hier weergegeven. Wanneer het diagnostische logboek van de taak is ingeschakeld, wordt dit hier ook weergegeven. Zie azure Stream Analytics-taaklogboeken voor meer informatie over de taaklogboeken.

    Wanneer een logisch taakdiagram wordt geladen, worden de metrische gegevens van deze taak: watermerkvertraging, invoergebeurtenissen, uitvoergebeurtenissen en backloginvoergebeurtenissen weergegeven in de grafieksectie voor de laatste 30 minuten.

De interactie tussen de sectie Diagram en de sectie Grafiek is ook beschikbaar in een logisch diagram. De metrische gegevens worden gefilterd op de eigenschappen van het knooppunt.

Schermopname van het overzicht van het fysieke taakdiagram.

Zie Foutopsporing met het logische taakdiagram (preview) in Azure Portal voor meer informatie over het opsporen van fouten in logische diagrammen.

Volgende stappen