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:
- Creare un deserializzatore personalizzato per il buffer di protocollo.
- Creare un processo di Analisi di flusso di Azure in Visual Studio.
- Configurare un processo di analisi di flusso per l'uso del deserializzatore personalizzato.
- Eseguire un processo di Analisi di flusso in locale per eseguire il test e il debug del deserializzatore personalizzato.
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
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.
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.
Aggiungere la classe MessageBodyProto e la classe MessageBodyDeserializer al progetto.
Compilare il progetto Protobuf Deserializer.
Aggiungere un progetto di Analisi di flusso di Azure
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.
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
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 > 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 Aggiungere la query seguente al file Script.asaql.
SELECT * FROM InputScaricare 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
Aprire script.asaql e selezionare Esegui localmente.
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.
Fare clic con il pulsante destro del mouse sul nome del progetto ProtobufCloudDeserializer e impostarlo come progetto di avvio.
Aggiungere punti di interruzione nella funzione.
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:
Scegliere Gruppi di risorse dal menu a sinistra del portale di Azure e quindi selezionare il nome della risorsa creata.
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: