Deserializer .NET personalizzati per Analisi di flusso di Azure in Visual Studio (anteprima)

Analisi di flusso di Azure offre supporto incorporato per tre formati di dati: JSON, CSV e Avro. Con i deserializzatori .NET personalizzati, è possibile leggere dati da altri formati, ad esempio buffer di protocollo, Bond e altri formati definiti dall'utente per i processi cloud ed Edge.

Questa esercitazione illustra come creare un deserializzatore .NET personalizzato per un processo cloud di Analisi di flusso di Azure con Visual Studio. Per informazioni su come creare deserializzatori .NET in Visual Studio Code, vedere Creare deserializzatori .NET per i processi di Analisi di flusso di Azure in Visual Studio Code.

In questa esercitazione viene illustrato come:

Prerequisiti

• Se non si ha una sottoscrizione di Azure, creare un account gratuito.

• Installare Visual Studio 2019 (consigliato) o Visual Studio 2017. Sono supportate le edizioni Enterprise (Ultimate/Premium), Professional e Community. L'edizione Express non è supportata.

• Installare gli strumenti di analisi di flusso per Visual Studio o eseguire l'aggiornamento all'ultima versione.

• Aprire Cloud Explorer in Visual Studio e accedere alla propria sottoscrizione di Azure.

• Creare un contenitore nell'account di Archiviazione di Azure. Il contenitore creato verrà usato per archiviare gli asset correlati al processo di analisi di flusso. Se è già disponibile un account di archiviazione con contenitori esistenti, è possibile usarli. In caso contrario, sarà necessario creare un nuovo contenitore.

Creare un deserializzatore personalizzato

1. Aprire Visual Studio e selezionare File > Nuovo > progetto. Cercare Analisi di flusso e selezionare Azure Stream Analytics Custom Deserializer Project (.NET) (Progetto deserializzatore personalizzato di Analisi di flusso di Azure - .NET). Assegnare un nome al progetto, ad esempio Protobuf Deserializer.

   

2. Da Esplora soluzioni fare clic con il pulsante destro del mouse sul progetto Protobuf Deserializer e scegliere Gestisci pacchetti NuGet dal menu. Installare quindi i pacchetti NuGet Microsoft.Azure.StreamAnalytics e Google.Protobuf.

3. Aggiungere la classe MessageBodyProto e la classe MessageBodyDeserializer al progetto.

4. Compilare il progetto Protobuf Deserializer.

Aggiungere un progetto di Analisi di flusso di Azure

1. In Esplora soluzioni fare clic con il pulsante destro del mouse sulla soluzione Protobuf Deserializer e scegliere Aggiungi > nuovo progetto. In Analisi di flusso di Azure scegliere Analisi di flusso >di Azure. Denominarla ProtobufCloudDeserializer e scegliere OK.

2. Fare clic con il pulsante destro del mouse su Riferimenti nel progetto di Analisi di flusso di Azure ProtobufCloudDeserializer. In Progetti aggiungere Protobuf Deserializer. Dovrebbe popolarsi automaticamente.

Configurare un processo di analisi di flusso

1. Fare doppio clic su JobConfig.json. Usare le configurazioni predefinite, tranne per le impostazioni seguenti:

   Impostazione	Valore consigliato
   Global Storage Settings Resource (Risorsa impostazioni di archiviazione globali)	Scegliere l'origine dati dall'account corrente
   Global Storage Settings Subscription (Sottoscrizione impostazioni di archiviazione globali)	< sottoscrizione >
   Global Storage Settings Storage Account (Account di archiviazione impostazioni di archiviazione globali)	< account di archiviazione >
   Custom Code Storage Settings Resource (Risorsa impostazioni di archiviazione codice personalizzato)	Scegliere l'origine dati dall'account corrente
   Custom Code Storage Settings Storage Account (Account di archiviazione impostazioni di archiviazione codice personalizzato)	< account di archiviazione >
   Custom Code Storage Settings Container (Contenitore impostazioni di archiviazione codice personalizzato)	< contenitore di archiviazione >

2. In Input fare doppio clic su Input.json. Usare le configurazioni predefinite, tranne per le impostazioni seguenti:

   Impostazione	Valore consigliato
   Source (Sorgente)	Archiviazione BLOB
   Risorsa	Scegliere l'origine dati dall'account corrente
   Sottoscrizione	< sottoscrizione >
   Account di archiviazione	< account di archiviazione >
   Contenitore	< contenitore di archiviazione >
   Formato di serializzazione eventi	Altro (Protobuf, XML, proprietario...)
   Risorsa	Caricare dal riferimento al progetto ASA o CodeBehind
   Nome dell'assembly CSharp	ProtobufDeserializer.dll
   Nome della classe	MessageBodyProto.MessageBodyDeserializer
   Tipo di compressione eventi	nessuno

3. Aggiungere la query seguente al file Script.asaql.

   SELECT * FROM Input
   

4. Scaricare il file di input protobuf di esempio. Nella cartella Input fare clic con il pulsante destro del mouse su Input.json e scegliere Aggiungi input locale. Fare doppio clic quindi su local_Input.json e configurare le impostazioni seguenti:

   Impostazione	Valore consigliato
   Alias di input	Input
   Tipo di origine	Flusso dati
   Formato di serializzazione eventi	Altro (Protobuf, XML, proprietario...)
   Nome dell'assembly CSharp	ProtobufDeserializer.dll
   Nome della classe	MessageBodyProto.MessageBodyDeserializer
   Percorso del file di input locale	< percorso del file per il file di input protobuf di esempio scaricato>

Eseguire il processo di analisi di flusso

1. Aprire script.asaql e selezionare Esegui localmente.

2. Osservare i risultati in Stream Analytics Local Run Results (Risultati esecuzione locale analisi di flusso).

Il deserializzatore personalizzato per il processo di analisi di flusso è stato implementato correttamente. In questa esercitazione è stato testato in locale il deserializzatore personalizzato. Per i dati effettivi, è necessario configurare correttamente l'input e l'output. Inviare quindi il processo ad Azure da Visual Studio per eseguirlo nel cloud usando il deserializzatore personalizzato appena implementato.

Eseguire il debug del deserializzatore

È possibile eseguire il debug del deserializzatore .NET in locale esattamente come si esegue il debug di codice .NET standard.

1. Fare clic con il pulsante destro del mouse sul nome del progetto ProtobufCloudDeserializer e impostarlo come progetto di avvio.

2. Aggiungere punti di interruzione nella funzione.

3. Premere F5 per avviare il debug. Il programma verrà interrotto in corrispondenza dei punti di interruzione nel modo previsto.

Pulire le risorse

Quando non sono più necessari, eliminare il gruppo di risorse, il processo di streaming e tutte le risorse correlate. Eliminando il processo si evita di pagare per le unità di streaming usate dal processo. Se si prevede di usare il processo in futuro, è possibile arrestarlo e riavviarlo in un secondo momento, quando è necessario. Se non si intende continuare a usare il processo, eliminare tutte le risorse create tramite questa esercitazione seguendo questa procedura:

1. Scegliere Gruppi di risorse dal menu a sinistra del portale di Azure e quindi selezionare il nome della risorsa creata.

2. Nella pagina del gruppo di risorse selezionare Elimina, digitare il nome della risorsa da eliminare nella casella di testo e quindi selezionare Elimina.

Passaggi successivi

In questa esercitazione è stato illustrato come implementare un deserializzatore .NET personalizzato per la serializzazione dell'input del buffer di protocollo. Per altre informazioni sulla creazione di deserializzatori personalizzati, continuare con l'articolo seguente: