Inserire dati dal flusso di Presepe in Azure Esplora dati

Stream presepe è un motore di elaborazione che raccoglie, elabora e trasmette in modo sicuro i dati degli eventi del computer da qualsiasi origine. Consente di analizzare ed elaborare i dati per qualsiasi destinazione per l'analisi e la gestione in modo sicuro.

Questo articolo illustra come inserire dati con il flusso del presepe.

Per un elenco completo dei connettori dati, vedere Panoramica delle integrazioni dei dati.

Prerequisiti

• Un account di Stream di Presepe
• Un cluster e un database di Azure Esplora dati con i criteri di conservazione e cache predefiniti.
• Ambiente di query. Per altre informazioni, vedere Panoramica delle integrazioni di query.
• URI del cluster Kusto per il valore TargetURI nel cluster> di formatohttps://ingest-<.<region.kusto.windows.net>. Per altre informazioni, vedere Aggiungere una connessione cluster.

Creare un'entità servizio Microsoft Entra

L'entità servizio Microsoft Entra può essere creata tramite il Portale di Azure o a livello di programmazione, come nell'esempio seguente.

Questa entità servizio è l'identità usata dal connettore per scrivere dati nella tabella in Kusto. Si possono concedere le autorizzazioni a questa entità servizio per accedere alle risorse Kusto.

1. Accedere alla sottoscrizione di Azure usando l'interfaccia della riga di comando di Azure. Eseguire quindi l'autenticazione nel browser.

   az login
   

2. Scegliere la sottoscrizione per ospitare l'entità di sicurezza. Questo passaggio è necessario quando si hanno più sottoscrizioni.

   az account set --subscription YOUR_SUBSCRIPTION_GUID
   

3. Creare l'entità servizio. In questo esempio l'entità servizio viene chiamata my-service-principal.

   az ad sp create-for-rbac -n "my-service-principal" --role Contributor --scopes /subscriptions/{SubID}
   

4. Dai dati JSON restituiti copiare appId, password e tenant per un uso futuro.

   {
     "appId": "00001111-aaaa-2222-bbbb-3333cccc4444",
     "displayName": "my-service-principal",
     "name": "my-service-principal",
     "password": "00001111-aaaa-2222-bbbb-3333cccc4444",
     "tenant": "00001111-aaaa-2222-bbbb-3333cccc4444"
   }
   

L'applicazione Microsoft Entra e l'entità servizio sono state create.

Creare una tabella di destinazione

Creare una tabella di destinazione per i dati in ingresso, e un mapping di inserimento per mappare le colonne di dati inseriti alle colonne della tabella di destinazione.

1. Nell'editor di query eseguire il comando di creazione della tabella seguente, sostituendo il segnaposto NomeTabella con il nome della tabella di destinazione:

   .create table <TableName> (_raw: string, _time: long, cribl_pipe: dynamic)
   

2. Eseguire il comando di mapping di inserimento seguente, sostituendo i segnaposto TableName con il nome della tabella di destinazione e TableNameMapping con il nome del mapping di inserimento:

   .create table <TableName> ingestion csv mapping '<TableNameMapping>' 'CriblLogMapping' '[{"Name":"_raw","DataType":"string","Ordinal":"0","ConstValue":null},{"Name":"_time","DataType":"long","Ordinal":"1","ConstValue":null},{"Name":"cribl_pipe","DataType":"dynamic","Ordinal":"2","ConstValue":null}]'
   

3. Usare l'entità servizio da Creare un'entità servizio Microsoft Entra database ingestor per concedere l'autorizzazione per lavorare con il database. Per maggiori informazioni, vedere gli Esempi. Sostituire il segnaposto DatabaseName con il nome del database di destinazione e ApplicationID con il AppId valore salvato durante la creazione di un'entità servizio Microsoft Entra.

   .add database <DatabaseName> ingestors ('aadapp=<ApplicationID>') 'App Registration'
   

Creare la destinazione del flusso del presepe

La sezione seguente descrive come creare una destinazione del flusso presepe che scrive i dati nella tabella in Kusto. Per ogni tabella è necessario un connettore di destinazione di Stream a presepe separato.

Selezionare la destinazione

Per connettere Il flusso di presepe al tavolo:

1. Nel riquadro di spostamento superiore in Presepe selezionare Gestisci e quindi selezionare un gruppo di lavoro.

2. Selezionare Routing>QuickConnect (Stream)>Add Destination (Aggiungi destinazione).

3. Nella finestra Configura nuova destinazione Di connessione rapida scegliere Azure Esplora dati e quindi Aggiungi ora.

Configurare le impostazioni generali

Nella finestra Nuovo Esplora dati impostare le impostazioni seguenti in Impostazioni generali:

Al termine, selezionare Avanti.

Impostazioni di autenticazione

Selezionare Impostazioni di autenticazione nella barra laterale. Usare i valori salvati in Creare un'entità servizio Microsoft Entra insieme all'URI di base come indicato di seguito:

Quindi seleziona Avanti.

Coda persistente

Visualizza quando la modalità di inserimento è impostata su Streaming e il comportamento di Backpressure è impostato su Coda persistente.

Al termine, selezionare Avanti.

Impostazioni di elaborazione

Al termine, selezionare Avanti.

Impostazioni Parquet

Visualizza quando Parquet è selezionato per Formato dati.

La scelta di Parquet apre una scheda Impostazioni Parquet per selezionare lo schema Parquet.

Nuovi tentativi

Visualizza quando la modalità di inserimento è impostata su Streaming.

Al termine, selezionare Avanti.

Impostazioni avanzate

Selezionare Impostazioni avanzate nella barra laterale. Di seguito vengono descritte le impostazioni avanzate quando viene selezionato Batch:

Al termine, selezionare Salva.

Configurazione connessione

Nella finestra Configurazione connessione visualizzata selezionare Connessione Passthru e quindi Salva. Il connettore inizia a accodare i dati.

Confermare l'inserimento dei dati

1. Dopo l'arrivo dei dati nella tabella, verificare il trasferimento dei dati controllando il conteggio delle righe:

   <Tablename> 
   | count
   

2. Confermare gli inserimenti accodati negli ultimi cinque minuti:

   .show commands-and-queries 
   | where Database == "" and CommandType == "DataIngestPull" 
   | where LastUpdatedOn >= ago(5m)
   

3. Verificare che non siano presenti errori nel processo di inserimento:

   • Per l'invio in batch:

   .show ingestion failures
   

   • Per lo streaming:

   .show streamingingestion failures 
   | order by LastFailureOn desc
   

4. Verificare i dati nella tabella:

   <TableName>
   | take 10
   

Per esempi di query e indicazioni, vedere Scrivere query in KQL e Linguaggio di query Kusto documentazione.

Contenuto correlato

• Panoramica delle integrazioni dei dati
• Panoramica di Linguaggio di query Kusto (KQL)