Configurare gli endpoint del flusso di dati per Azure Esplora dati

Per inviare dati ad Azure Esplora dati in Operazioni IoT di Azure, è possibile configurare un endpoint del flusso di dati. Questa configurazione consente di specificare l'endpoint di destinazione, il metodo di autenticazione, la tabella e altre impostazioni.

Prerequisiti

• Istanza delle operazioni di Azure IoT
• Un cluster di Azure Esplora dati. Seguire i passaggi del cluster completo nella guida introduttiva: Creare un cluster e un database di Azure Esplora dati. L'opzione cluster gratuito non funziona per questo scenario.

Creare un database Esplora dati di Azure

1. Nella portale di Azure creare un database nel cluster completo di Azure Esplora dati.

2. Creare una tabella nel database per i dati. È possibile usare il portale di Azure e creare colonne manualmente oppure è possibile usare KQL nella scheda query. Ad esempio, per creare una tabella per i dati del termostato di esempio, eseguire il comando seguente:

   .create table thermostat (
       externalAssetId: string,
       assetName: string,
       CurrentTemperature: real,
       Pressure: real,
       MqttTopic: string,
       Timestamp: datetime
   )
   

3. Abilitare l'inserimento in streaming nella tabella e nel database. Nella scheda query eseguire il comando seguente sostituendo <DATABASE_NAME> con il nome del database:

   .alter database ['<DATABASE_NAME>'] policy streamingingestion enable
   

   In alternativa, abilitare l'inserimento in streaming nell'intero cluster. Vedere Abilitare l'inserimento in streaming in un cluster esistente.

Assegnare l'autorizzazione all'identità gestita

Per configurare un endpoint del flusso di dati per Azure Esplora dati, è consigliabile usare un'identità gestita assegnata dall'utente o assegnata dal sistema. Questo approccio è sicuro ed elimina la necessità di gestire manualmente le credenziali.

Dopo aver creato il database di Azure Esplora dati, è necessario assegnare un ruolo all'identità gestita di Operazioni IoT di Azure che concede l'autorizzazione per la scrittura nel database.

Se si usa l'identità gestita assegnata dal sistema, in portale di Azure passare all'istanza di Operazioni IoT di Azure e selezionare Panoramica. Copiare il nome dell'estensione elencata dopo l'estensione Azure IoT Operations Arc. Ad esempio, azure-iot-operations-xxxx7. L'identità gestita assegnata dal sistema è disponibile usando lo stesso nome dell'estensione Azure IoT Operations Arc.

1. Nel database di Azure Esplora dati (non cluster) in Panoramica selezionare Autorizzazioni>Aggiungi e quindi selezionare Ingestor come ruolo. In questo modo, l'identità gestita consente di scrivere nel database di Esplora dati di Azure. Per altre informazioni, vedere l'articolo relativo al controllo degli accessi in base al ruolo.
2. Cercare il nome dell'identità gestita assegnata dall'utente configurata per le connessioni cloud o l'identità gestita assegnata dal sistema. Ad esempio, azure-iot-operations-xxxx7.
3. Selezionare quindi Seleziona.

Creare un endpoint del flusso di dati per Azure Esplora dati

param aioInstanceName string = '<AIO_INSTANCE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'
param endpointName string = '<ENDPOINT_NAME>'
param hostName string = 'https://<CLUSTER>.<region>.kusto.windows.net'
param databaseName string = '<DATABASE_NAME>'

resource aioInstance 'Microsoft.IoTOperations/instances@2024-11-01' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource adxEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-11-01' = {
  parent: aioInstance
  name: endpointName
  extendedLocation: {
    name: customLocation.id
    type: 'CustomLocation'
  }
  properties: {
    endpointType: 'DataExplorer'
    dataExplorerSettings: {
      host: hostName
      database: databaseName
      authentication: {
        // See available authentication methods section for method types
        // method: <METHOD_TYPE>
      }
    }
  }
}

az deployment group create --resource-group <RESOURCE_GROUP> --template-file <FILE>.bicep

apiVersion: connectivity.iotoperations.azure.com/v1
kind: DataflowEndpoint
metadata:
  name: <ENDPOINT_NAME>
  namespace: azure-iot-operations
spec:
  endpointType: DataExplorer
  dataExplorerSettings:
    host: 'https://<CLUSTER>.<region>.kusto.windows.net'
    database: <DATABASE_NAME>
    authentication:
      # See available authentication methods section for method types
      # method: <METHOD_TYPE>

kubectl apply -f <FILE>.yaml

Metodi di autenticazione disponibili

Per gli endpoint di Azure Esplora dati sono disponibili i metodi di autenticazione seguenti.

Identità gestita assegnata dal sistema

Prima di configurare l'endpoint del flusso di dati, assegnare un ruolo all'identità gestita di Operazioni IoT di Azure che concede l'autorizzazione per la scrittura nel database di azure Esplora dati:

1. In portale di Azure passare all'istanza di Operazioni IoT di Azure e selezionare Panoramica.
2. Copiare il nome dell'estensione elencata dopo l'estensione Azure IoT Operations Arc. Ad esempio, azure-iot-operations-xxxx7.
3. Passare ad Azure Esplora dati database (non cluster), in Panoramica selezionare Autorizzazioni>Aggiungi e quindi selezionare un ruolo appropriato.
4. Cercare il nome dell'identità gestita assegnata dal sistema. Ad esempio, azure-iot-operations-xxxx7.
5. Selezionare Seleziona.

Configurare quindi l'endpoint del flusso di dati con le impostazioni di identità gestite assegnate dal sistema.

dataExplorerSettings: {
  authentication: {
    method: 'SystemAssignedManagedIdentity'
    systemAssignedManagedIdentitySettings: {}
  }
}

dataExplorerSettings:
  authentication:
    method: SystemAssignedManagedIdentity
    systemAssignedManagedIdentitySettings: {}

Se è necessario eseguire l'override del gruppo di destinatari dell'identità gestita assegnata dal sistema, è possibile specificare l'impostazione audience .

dataExplorerSettings: {
  authentication: {
    method: 'SystemAssignedManagedIdentity'
    systemAssignedManagedIdentitySettings: {
      audience: 'https://<AUDIENCE_URL>'    
    }
  }
}

dataExplorerSettings:
  authentication:
    method: SystemAssignedManagedIdentity
    systemAssignedManagedIdentitySettings:
      audience: https://<AUDIENCE_URL>

Identità gestita assegnata dall'utente

Per usare l'identità gestita assegnata dall'utente per l'autenticazione, è prima necessario distribuire le operazioni IoT di Azure con impostazioni sicure abilitate. È quindi necessario configurare un'identità gestita assegnata dall'utente per le connessioni cloud. Per altre informazioni, vedere Abilitare le impostazioni sicure nella distribuzione di Operazioni IoT di Azure.

Prima di configurare l'endpoint del flusso di dati, assegnare un ruolo all'identità gestita assegnata dall'utente che concede l'autorizzazione per la scrittura nel database di Azure Esplora dati:

1. In portale di Azure passare ad Azure Esplora dati database (non cluster), in Panoramica selezionare Autorizzazioni>Aggiungi e quindi selezionare un ruolo appropriato.
2. Cercare il nome dell'identità gestita assegnata dall'utente.
3. Selezionare Seleziona.

Configurare quindi l'endpoint del flusso di dati con le impostazioni di identità gestite assegnate dall'utente.

dataExplorerSettings: {
  authentication: {
    method: 'UserAssignedManagedIdentity'
    userAssignedManagedIdentitySettings: {
      clientId: '<ID>'
      tenantId: '<ID>'
      // Optional, defaults to 'https://api.kusto.windows.net/.default'
      // scope: 'https://<SCOPE_URL>'
    }
  }
}

dataExplorerSettings:
  authentication:
    method: UserAssignedManagedIdentity
    userAssignedManagedIdentitySettings:
      clientId: <ID>
      tenantId: <ID>
      # Optional, defaults to 'https://api.kusto.windows.net/.default'
      # scope: https://<SCOPE_URL>

In questo caso, l'ambito è facoltativo e l'impostazione predefinita è https://api.kusto.windows.net/.default. Se è necessario eseguire l'override dell'ambito predefinito, specificare l'impostazione scope tramite Bicep o Kubernetes.

Impostazioni avanzate

È possibile impostare impostazioni avanzate per l'endpoint Esplora dati di Azure, ad esempio la latenza di invio in batch e il numero di messaggi.

Usare le batching impostazioni per configurare il numero massimo di messaggi e la latenza massima prima che i messaggi vengano inviati alla destinazione. Questa impostazione è utile quando si vuole ottimizzare la larghezza di banda di rete e ridurre il numero di richieste alla destinazione.

Ad esempio, per configurare il numero massimo di messaggi su 1000 e la latenza massima a 100 secondi, usare le impostazioni seguenti:

dataExplorerSettings: {
  batching: {
    latencySeconds: 100
    maxMessages: 1000
  }
}

dataExplorerSettings:
  batching:
    latencySeconds: 100
    maxMessages: 1000

Passaggi successivi

Per altre informazioni sui flussi di dati, vedere Creare un flusso di dati.