Prendere nota della parte comune del nome del percorso, derivata dal nome dell’applicazione e dalla chiave di strumentazione.Make a note of the common part of the path name, which is derived from the application name and instrumentation key.

Gli eventi vengono scritti nei file BLOB in formato JSON.The events are written to blob files in JSON format.Ogni file può contenere uno o più eventi.Each file may contain one or more events.A questo punto sarà possibile leggere i dati degli eventi e filtrare i campi preferiti.So we'd like to read the event data and filter out the fields we want.È possibile eseguire una serie di operazioni sui dati, ma lo scopo di questo articolo è usare l'analisi di flusso per spostare i dati in un Power BI.There are all kinds of things we could do with the data, but our plan today is to use Stream Analytics to pipe the data to Power BI.

PageViews è il tipo di dati da analizzare.PageViews is the type of data you want to analyze.I tipi disponibili dipendono dal filtro impostato nell'esportazione continua.The available types depend on the filter you set in Continuous Export.Esaminare i dati esportati per vedere gli altri tipi disponibili e vedere il modello di dati di esportazione.Examine the exported data to see the other available types, and see the export data model.

Aggiungere un nuovo outputAdd new output

Fornire l’ account aziendale o dell’istituto di istruzione per autorizzare l'analisi di flusso per l’accesso alla risorsa di Power BI.Provide your work or school account to authorize Stream Analytics to access your Power BI resource.Creare quindi un nome per l'output e per il set di dati Power BI e la tabella di destinazione.Then invent a name for the output, and for the target Power BI dataset and table.

Impostare la querySet the query

Utilizzare la funzione Test per verificare di ottenere l'output corretto.Use the Test function to check that you get the right output.Assegnare i dati di esempio presenti nella pagina di input.Give it the sample data that you took from the inputs page.

Query per visualizzare i conteggi degli eventiQuery to display counts of events

Incollare questa query:Paste this query:

SELECT
flat.ArrayValue.name,
count(*)
INTO
[pbi-output]
FROM
[export-input] A
OUTER APPLY GetElements(A.[event]) as flat
GROUP BY TumblingWindow(minute, 1), flat.ArrayValue.name

export-input è l'alias assegnato all'input del flussoexport-input is the alias we gave to the stream input

Viene usato OUTER APPLY GetElements perché il nome dell'evento si trova in una matrice JSON annidata.We use OUTER APPLY GetElements because the event name is in a nested JSON array.L'istruzione SELECT seleziona quindi il nome dell'evento insieme al conteggio del numero di istanze che presentano tale nome nel periodo di tempo indicato.Then the Select picks the event name, together with a count of the number of instances with that name in the time period.La clausola GROUP BY raggruppa gli elementi in periodi di tempo di un minuto.The Group By clause groups the elements into time periods of one minute.

SELECT
A.context.data.eventtime,
avg(CASE WHEN flat.arrayvalue.myMetric.value IS NULL THEN 0 ELSE flat.arrayvalue.myMetric.value END) as myValue
INTO
[pbi-output]
FROM
[export-input] A
OUTER APPLY GetElements(A.context.custom.metrics) as flat
GROUP BY TumblingWindow(minute, 1), A.context.data.eventtime

Questa query entra nella telemetria delle metriche per ottenere l'ora dell'evento e il valore della metrica.This query drills into the metrics telemetry to get the event time and the metric value.I valori delle metriche sono all'interno di una matrice, pertanto si utilizza il modello OUTER APPLY GetElements per estrarre le righe.The metric values are inside an array, so we use the OUTER APPLY GetElements pattern to extract the rows."myMetric" è il nome della metrica in questo caso."myMetric" is the name of the metric in this case.

Query per includere i valori delle proprietà delle dimensioniQuery to include values of dimension properties