IoT-gegevens exporteren naar Blob Storage

Artikel
03/05/2024

In dit artikel wordt beschreven hoe u gegevensexport configureert om gegevens naar de Blob Storage-service te verzenden.

Gebruik deze functie om gefilterde en verrijkte IoT-gegevens continu te exporteren uit uw IoT Central-toepassing. Gegevensexport pusht wijzigingen in bijna realtime naar andere onderdelen van uw cloudoplossing voor inzichten, analyses en opslag op warm pad.

U kunt bijvoorbeeld:

Continu telemetrie exporteren, eigenschappenwijzigingen, apparaatconnectiviteit, apparaatlevenscyclus, levenscyclus van apparaatsjablonen en auditlogboekgegevens in JSON-indeling in bijna realtime.
Filter de gegevensstromen om gegevens te exporteren die overeenkomen met aangepaste voorwaarden.
Verrijk de gegevensstromen met aangepaste waarden en eigenschapswaarden van het apparaat.
Transformeer de gegevensstromen om hun vorm en inhoud te wijzigen.

Tip

Wanneer u gegevensexport inschakelt, krijgt u alleen de gegevens vanaf dat moment. Als u meer historische gegevens wilt behouden, schakelt u gegevensexport vroeg in. Als u gegevens handmatig wilt exporteren vanaf tijdstippen waarop gegevensexport is uitgeschakeld, raadpleegt u Hoe u de Rest API van IoT Central gebruikt om query's uit te voeren op apparaten.

Notitie

In sommige gevallen kan het tot 60 seconden duren voordat de berichten worden geëxporteerd. Deze tijd wordt gemeten vanaf wanneer IoT Central het bericht van de onderliggende IoT-hub ontvangt tot wanneer het bericht wordt bezorgd bij het doeleindpunt.

Vereisten

Als u functies voor gegevensexport wilt gebruiken, moet u beschikken over de machtiging Gegevensexport .

Zie De IoT Central REST API gebruiken om gegevensexports te beheren voor informatie over het beheren van gegevensexports met behulp van de Rest API van IoT Central.

Een Blob Storage-exportbestemming instellen

IoT Central exporteert gegevens één keer per minuut, waarbij elk bestand de batch met wijzigingen bevat sinds de vorige export. Geëxporteerde gegevens worden opgeslagen in JSON-indeling. De standaardpaden naar de geëxporteerde gegevens in uw opslagaccount zijn:

Telemetrie: {container}/{app-id}/{partition_id}/{JJJJ}/{MM}/{dd}/{hh}/{mm}/{bestandsnaam}
Eigenschapswijzigingen: {container}/{app-id}/{partition_id}/{JJJJ}/{MM}/{dd}/{hh}/{mm}/{bestandsnaam}

Als u door de geëxporteerde bestanden in Azure Portal wilt bladeren, gaat u naar het bestand en selecteert u Blob bewerken.

Verbindingsopties

Met Blob Storage-bestemmingen kunt u de verbinding configureren met een verbindingsreeks of een beheerde identiteit.

Tip

Als de Blob Storage-bestemming wordt beveiligd door een firewall, moet u een beheerde identiteit gebruiken om er verbinding mee te maken.

Beheerde identiteiten zijn veiliger omdat:

U slaat de referenties voor uw resource niet op in een verbindingsreeks in uw IoT Central-toepassing.
De referenties worden automatisch gekoppeld aan de levensduur van uw IoT Central-toepassing.
Beheerde identiteiten draaien hun beveiligingssleutels automatisch regelmatig.

IoT Central maakt momenteel gebruik van door het systeem toegewezen beheerde identiteiten.

Wanneer u een beheerde identiteit configureert, bevat de configuratie een bereik en een rol:

Het bereik definieert waar u de beheerde identiteit kunt gebruiken. U kunt bijvoorbeeld een Azure-resourcegroep gebruiken als bereik. In dit geval moeten zowel de IoT Central-toepassing als de bestemming zich in dezelfde resourcegroep bevinden.
De rol bepaalt welke machtigingen de IoT Central-toepassing wordt verleend in de doelservice. Voor een IoT Central-toepassing voor het verzenden van gegevens naar een Event Hub heeft de beheerde identiteit bijvoorbeeld de roltoewijzing Azure Event Hubs-gegevenszender nodig.

De volgende video bevat meer informatie over door het systeem toegewezen beheerde identiteiten:

Let op

Als u wilt exporteren naar blobopslag, gebruikt u de bijdrager voor het opslagaccount niet, zoals wordt weergegeven in de video. Gebruik in plaats daarvan de rol Inzender voor opslagblobgegevens.

In dit artikel wordt beschreven hoe u een beheerde identiteit maakt met behulp van de Azure CLI. U kunt azure Portal ook gebruiken om een beheerde identiteit te maken.

Als u geen bestaand Azure-opslagaccount hebt waarnaar u wilt exporteren, voert u het volgende script uit in de Azure Cloud Shell-bash-omgeving. Met het script maakt u een resourcegroep, een Azure Storage-account en een blobcontainer. Met het script wordt vervolgens de beheerde identiteit voor uw IoT Central-toepassing ingeschakeld en wordt de rol toegewezen die nodig is voor toegang tot uw opslagaccount:

# Replace the storage account name with your own unique value.
SA=yourstorageaccount$RANDOM

# Replace the IoT Central app name with the name of your
# IoT Central application.
CA=your-iot-central-app

CN=exportdata
RG=centralexportresources
LOCATION=eastus

az group create -n $RG --location $LOCATION
SAID=$(az storage account create --name $SA --resource-group $RG --location $LOCATION --sku Standard_LRS --query "id" --output tsv)
az storage container create --account-name $SA --resource-group $RG --name $CN

# This assumes your IoT Central application is in the 
# default `IOTC` resource group.
az iot central app identity assign --name $CA --resource-group IOTC --system-assigned
PI=$(az iot central app identity show --name $CA --resource-group IOTC --query "principalId" --output tsv)

az role assignment create --assignee $PI --role "Storage Blob Data Contributor" --scope $SAID

az role assignment list --assignee $PI --all -o table

echo "Endpoint URI: https://$SA.blob.core.windows.net/"
echo "Container: $CN"

Meer informatie over het maken van nieuwe Azure Blob Storage-accounts of Azure Data Lake Storage v2-opslagaccounts. Gegevensexport kan alleen gegevens schrijven naar opslagaccounts die blok-blobs ondersteunen. In de volgende tabel ziet u de bekende compatibele typen opslagaccounts:

Prestatielaag	Rekeningsoort
Standaard	Algemeen gebruik v2
Standaard	Algemeen gebruik v1
Standaard	Blob-opslag
Premium	Blok-blobopslag

Zie Gegevens exporteren naar een veilige bestemming in een virtueel Azure-netwerk om uw blobcontainer verder te beveiligen en alleen toegang toe te staan vanuit vertrouwde services met beheerde identiteiten.

De Blob Storage-bestemming maken in IoT Central op de pagina Gegevensexport :

Selecteer + Nieuwe bestemming.
Selecteer Azure Blob Storage als het doeltype.
Selecteer Door het systeem toegewezen beheerde identiteit als autorisatietype.
Voer de eindpunt-URI in voor uw opslagaccount en de naam van de hoofdlettergevoelige container. Een eindpunt-URI ziet er als volgt uit: https://contosowaste.blob.core.windows.net.
Selecteer Opslaan.

Als u geen gegevens ziet die binnenkomen in uw doelservice, raadpleegt u Problemen met gegevensexports vanuit uw Azure IoT Central-toepassing oplossen.

Als u geen bestaand Azure-opslagaccount hebt waarnaar u wilt exporteren, voert u het volgende script uit in de Azure Cloud Shell-bash-omgeving. Met het script maakt u een resourcegroep, een Azure Storage-account en een blobcontainer. Vervolgens wordt het verbindingsreeks afgedrukt dat moet worden gebruikt wanneer u de gegevensexport in IoT Central configureert:

# Replace the storage account name with your own unique value
SA=yourstorageaccount$RANDOM
CN=exportdata
RG=centralexportresources
LOCATION=eastus

az group create -n $RG --location $LOCATION
az storage account create --name $SA --resource-group $RG --location $LOCATION --sku Standard_LRS
az storage container create --account-name $SA --resource-group $RG --name $CN

CS=$(az storage account show-connection-string --resource-group $RG --name $SA --query "connectionString" --output tsv)

echo "Storage connection string: $CS"

Prestatielaag	Rekeningsoort
Standaard	Algemeen gebruik v2
Standaard	Algemeen gebruik v1
Standaard	Blob-opslag
Premium	Blok-blobopslag

De Blob Storage-bestemming maken in IoT Central op de pagina Gegevensexport :

Selecteer + Nieuwe bestemming.
Selecteer Azure Blob Storage als het doeltype.
Selecteer De verbindingsreeks als het autorisatietype.
Plak de verbindingsreeks voor uw Blob Storage-resource en voer indien nodig de naam van de hoofdlettergevoelige container in.
Selecteer Opslaan.

Een gegevensexport instellen

Nu u een bestemming hebt om uw gegevens naar te exporteren, stelt u de gegevensexport in uw IoT Central-toepassing in:

Meld u aan bij uw IoT Central-toepassing.
Selecteer Gegevensexport in het linkerdeelvenster.

Tip

Als u gegevensexport niet ziet in het linkerdeelvenster, hebt u geen machtigingen om gegevensexport in uw app te configureren. Neem contact op met een beheerder om gegevensexport in te stellen.
Selecteer + Nieuwe export.
Voer een weergavenaam in voor de nieuwe export en zorg ervoor dat de gegevensexport is ingeschakeld.

Kies het type gegevens dat u wilt exporteren. De volgende tabel bevat de ondersteunde typen gegevensexport:

Gegevenstype	Beschrijving	Gegevensopmaak
Telemetrie	Telemetrieberichten exporteren van apparaten in bijna realtime. Elk geëxporteerd bericht bevat de volledige inhoud van het oorspronkelijke apparaatbericht, genormaliseerd.	Telemetrieberichtindeling
Eigenschapswijzigingen	Exporteer wijzigingen in apparaat- en cloudeigenschappen in bijna realtime. Voor alleen-lezen apparaateigenschappen worden wijzigingen in de gerapporteerde waarden geëxporteerd. Voor eigenschappen voor lezen/schrijven worden zowel gerapporteerde als gewenste waarden geëxporteerd.	Berichtindeling wijzigen van eigenschap
Connectiviteit van apparaten	Verbonden en verbroken gebeurtenissen van het apparaat exporteren.	Berichtindeling voor apparaatconnectiviteit
Levenscyclus van apparaat	Exporteer apparaat geregistreerd, verwijderd, ingericht, ingeschakeld, uitgeschakeld, displayNameChanged en deviceTemplateChanged-gebeurtenissen.	Berichtindeling van apparaatlevenscyclus wordt gewijzigd
Levenscyclus van apparaatsjabloon	Gepubliceerde apparaatsjabloonwijzigingen exporteren, waaronder gemaakt, bijgewerkt en verwijderd.	De levenscyclus van apparaatsjablonen verandert de berichtindeling
Auditlogboeken	Logboeken van door de gebruiker geïnitieerde updates voor entiteiten in de toepassing. Zie Auditlogboeken gebruiken om activiteiten in uw IoT Central-toepassing bij te houden voor meer informatie	Berichtindeling auditlogboek

Voeg eventueel filters toe om de hoeveelheid geëxporteerde gegevens te verminderen. Er zijn verschillende typen filters beschikbaar voor elk type gegevensexport:

Type gegevens	Beschikbare filters
Telemetrie	Filteren op apparaatnaam, apparaat-id, apparaatsjabloon en of het apparaat is gesimuleerd Filterstroom om alleen telemetrie te bevatten die voldoet aan de filtervoorwaarden Filterstroom zodat deze alleen telemetrie van apparaten bevat met eigenschappen die overeenkomen met de filtervoorwaarden Filterstroom zodat deze alleen telemetrie bevat met berichteigenschappen die voldoen aan de filtervoorwaarde. Berichteigenschappen (ook wel toepassingseigenschappen genoemd) worden verzonden in een zak sleutel-waardeparen op elk telemetriebericht. Als u een berichteigenschapsfilter wilt maken, voert u de eigenschapssleutel van het bericht in die u zoekt en geeft u een voorwaarde op. Alleen telemetrieberichten met eigenschappen die overeenkomen met de opgegeven filtervoorwaarde worden geëxporteerd. Meer informatie over toepassingseigenschappen uit IoT Hub-documenten
Eigenschapswijzigingen	Filteren op apparaatnaam, apparaat-id, apparaatsjabloon en of het apparaat is gesimuleerd Filterstroom om alleen eigenschapswijzigingen te bevatten die voldoen aan de filtervoorwaarden
Connectiviteit van apparaten	Filteren op apparaatnaam, apparaat-id, apparaatsjabloon, organisaties en of het apparaat is gesimuleerd Filterstroom zodat deze alleen wijzigingen van apparaten bevat met eigenschappen die overeenkomen met de filtervoorwaarden
Levenscyclus van apparaat	Filteren op apparaatnaam, apparaat-id, apparaatsjabloon en of het apparaat is ingericht, ingeschakeld of gesimuleerd Filterstroom zodat deze alleen wijzigingen van apparaten bevat met eigenschappen die overeenkomen met de filtervoorwaarden
Levenscyclus van apparaatsjabloon	Filteren op apparaatsjabloon
Auditlogboeken	N.v.t.

Verrijk eventueel geëxporteerde berichten met extra metagegevens van sleutel-waardepaar. De volgende verrijkingen zijn beschikbaar voor de telemetrie, eigenschappenwijzigingen, apparaatconnectiviteit en gegevensexporttypen voor de levenscyclus van apparaten:
- Aangepaste tekenreeks: voegt een aangepaste statische tekenreeks toe aan elk bericht. Voer een willekeurige sleutel in en voer een tekenreekswaarde in.
- Eigenschap, die aan elk bericht wordt toegevoegd:
  - Metagegevens van apparaten, zoals apparaatnaam, apparaatsjabloonnaam, ingeschakeld, organisaties, ingericht en gesimuleerd.
  - De gerapporteerde eigenschap of cloudeigenschapswaarde van het huidige apparaat voor elk bericht. Als het geëxporteerde bericht afkomstig is van een apparaat dat niet de opgegeven eigenschap heeft, krijgt het geëxporteerde bericht de verrijking niet.

Configureer de exportbestemming:

Selecteer + Bestemming om een bestemming toe te voegen die u al hebt gemaakt of selecteer Een nieuwe maken.
Als u uw gegevens wilt transformeren voordat deze worden geëxporteerd, selecteert u + Transformeren. Zie Gegevens transformeren in uw IoT Central-toepassing voor export voor meer informatie.
Selecteer + Bestemming om maximaal vijf bestemmingen toe te voegen aan één export.
Wanneer u klaar bent met het instellen van de export, selecteert u Opslaan. Na een paar minuten worden uw gegevens weergegeven in uw bestemmingen.

Uw export bewaken

Op de pagina Gegevensexport in IoT Central kunt u de status van uw exports controleren. U kunt Ook Azure Monitor gebruiken om te zien hoeveel gegevens u exporteert en eventuele exportfouten. U hebt toegang tot metrische gegevens over export- en apparaatstatus in grafieken in Azure Portal met behulp van de REST API, query's in PowerShell of de Azure CLI. Op dit moment kunt u de volgende metrische gegevens voor gegevensexport bewaken in Azure Monitor:

Aantal berichten dat binnenkomt om te exporteren voordat filters worden toegepast.
Aantal berichten dat filters doorgeeft.
Het aantal berichten dat naar bestemmingen is geëxporteerd.
Aantal gevonden fouten.

Zie Toepassingsstatus bewaken voor meer informatie.

Bestandsindelingen

In de volgende secties worden de indelingen van de geëxporteerde gegevens beschreven:

Telemetrie-indeling

Elk geëxporteerd bericht bevat een genormaliseerde vorm van het volledige bericht dat het apparaat in de hoofdtekst van het bericht heeft verzonden. Het bericht heeft de JSON-indeling en is gecodeerd als UTF-8. Informatie in elk bericht bevat:

applicationId: De id van de IoT Central-toepassing.
messageSource: De bron voor het bericht - telemetry.
deviceId: De id van het apparaat dat het telemetriebericht heeft verzonden.
schema: de naam en versie van het nettoladingschema.
templateId: De id van de apparaatsjabloon die is toegewezen aan het apparaat.
enqueuedTime: Het tijdstip waarop IoT Central dit bericht heeft ontvangen.
enrichments: Alle verrijkingen die voor de export zijn ingesteld.
module: De IoT Edge-module die dit bericht heeft verzonden. Dit veld wordt alleen weergegeven als het bericht afkomstig is van een IoT Edge-module.
component: het onderdeel dat dit bericht heeft verzonden. Dit veld wordt alleen weergegeven als de mogelijkheden die in het bericht zijn verzonden, zijn gemodelleerd als onderdeel in de apparaatsjabloon
messageProperties: Andere eigenschappen die het apparaat met het bericht heeft verzonden. Deze eigenschappen worden soms toepassingseigenschappen genoemd. Meer informatie vindt u in IoT Hub-documenten.

Voor Blob Storage worden berichten één keer per minuut gebatcheerd en geëxporteerd.

In het volgende voorbeeld ziet u een geëxporteerd telemetriebericht:


{
    "applicationId": "00001111-aaaa-2222-bbbb-3333cccc4444",
    "messageSource": "telemetry",
    "deviceId": "1vzb5ghlsg1",
    "schema": "default@v1",
    "templateId": "urn:qugj6vbw5:___qbj_27r",
    "enqueuedTime": "2020-08-05T22:26:55.455Z",
    "telemetry": {
        "Activity": "running",
        "BloodPressure": {
            "Diastolic": 7,
            "Systolic": 71
        },
        "BodyTemperature": 98.73447010562934,
        "HeartRate": 88,
        "HeartRateVariability": 17,
        "RespiratoryRate": 13
    },
    "enrichments": {
      "userSpecifiedKey": "sampleValue"
    },
    "module": "VitalsModule",
    "component": "DeviceComponent",
    "messageProperties": {
      "messageProp": "value"
    }
}

Berichteigenschappen

Telemetrieberichten hebben eigenschappen voor metagegevens en de nettolading van telemetrie. In het vorige fragment ziet u voorbeelden van systeemberichten zoals deviceId en enqueuedTime. Zie Systeemeigenschappen van IoT Hub-berichten in de apparaat-naar-cloud voor meer informatie over de eigenschappen van systeemberichten.

U kunt eigenschappen toevoegen aan telemetrieberichten als u aangepaste metagegevens wilt toevoegen aan uw telemetrieberichten. U moet bijvoorbeeld een tijdstempel toevoegen wanneer het apparaat het bericht maakt.

In het volgende codefragment ziet u hoe u de iothub-creation-time-utc eigenschap aan het bericht toevoegt wanneer u het op het apparaat maakt:

Belangrijk

De notatie van deze tijdstempel moet UTC zijn zonder tijdzonegegevens. Is bijvoorbeeld 2021-04-21T11:30:16Z geldig, 2021-04-21T11:30:16-07:00 is ongeldig.

async function sendTelemetry(deviceClient, index) {
  console.log('Sending telemetry message %d...', index);
  const msg = new Message(
    JSON.stringify(
      deviceTemperatureSensor.updateSensor().getCurrentTemperatureObject()
    )
  );
  msg.properties.add("iothub-creation-time-utc", new Date().toISOString());
  msg.contentType = 'application/json';
  msg.contentEncoding = 'utf-8';
  await deviceClient.sendEvent(msg);
}

private static void sendTemperatureTelemetry() {
  String telemetryName = "temperature";
  String telemetryPayload = String.format("{\"%s\": %f}", telemetryName, temperature);

  Message message = new Message(telemetryPayload);
  message.setContentEncoding(StandardCharsets.UTF_8.name());
  message.setContentTypeFinal("application/json");
  message.setProperty("iothub-creation-time-utc", Instant.now().toString());

  deviceClient.sendEventAsync(message, new MessageIotHubEventCallback(), message);
  log.debug("My Telemetry: Sent - {\"{}\": {}°C} with message Id {}.", telemetryName, temperature, message.getMessageId());
  temperatureReadings.put(new Date(), temperature);
}

private async Task SendTemperatureTelemetryAsync()
{
  const string telemetryName = "temperature";

  string telemetryPayload = $"{{ \"{telemetryName}\": {_temperature} }}";
  using var message = new Message(Encoding.UTF8.GetBytes(telemetryPayload))
  {
      ContentEncoding = "utf-8",
      ContentType = "application/json",
  };
  message.Properties.Add("iothub-creation-time-utc", DateTime.UtcNow.ToString("yyyy-MM-ddTHH:mm:ssZ"));
  await _deviceClient.SendEventAsync(message);
  _logger.LogDebug($"Telemetry: Sent - {{ \"{telemetryName}\": {_temperature}°C }}.");
}

async def send_telemetry_from_thermostat(device_client, telemetry_msg):
    msg = Message(json.dumps(telemetry_msg))
    msg.custom_properties["iothub-creation-time-utc"] = datetime.now(timezone.utc).isoformat()
    msg.content_encoding = "utf-8"
    msg.content_type = "application/json"
    print("Sent message")
    await device_client.send_message(msg)

Opmaak van eigenschapswijzigingen

Elk bericht of elke record vertegenwoordigt wijzigingen in apparaat- en cloudeigenschappen. Informatie in het geëxporteerde bericht bevat:

applicationId: De id van de IoT Central-toepassing.
messageSource: De bron voor het bericht - properties.
messageType: Ofwel cloudPropertyChange, devicePropertyDesiredChangeof devicePropertyReportedChange.
deviceId: De id van het apparaat dat het telemetriebericht heeft verzonden.
schema: de naam en versie van het nettoladingschema.
enqueuedTime: Het tijdstip waarop IoT Central deze wijziging heeft gedetecteerd.
templateId: De id van de apparaatsjabloon die is toegewezen aan het apparaat.
properties: Een matrix met eigenschappen die zijn gewijzigd, inclusief de namen van de eigenschappen en waarden die zijn gewijzigd. De onderdeel- en modulegegevens worden opgenomen als de eigenschap is gemodelleerd binnen een onderdeel of een IoT Edge-module.
enrichments: Alle verrijkingen die voor de export zijn ingesteld.

Voor Blob Storage worden berichten één keer per minuut gebatcheerd en geëxporteerd.

In het volgende fragment ziet u een bericht voor het wijzigen van de eigenschap dat is geëxporteerd naar Blob Storage:

{
    "applicationId": "11112222-bbbb-3333-cccc-4444dddd5555",
    "messageSource": "properties",
    "deviceId": "Pepjmh1Hcc",
    "enqueuedTime": "2023-03-02T10:35:39.281Z",
    "enrichments": {},
    "messageType": "devicePropertyReportedChange",
    "schema": "default@v1",
    "templateId": "dtmi:azureiot:ddzig4ascxz",
    "properties": [
        {
            "component": "device_info",
            "name": "swVersion",
            "value": "12"
        },
        {
            "component": "device_info",
            "name": "osName",
            "value": "Android"
        },
        {
            "component": "device_info",
            "name": "processorArchitecture",
            "value": "arm64-v8a"
        },
        {
            "component": "device_info",
            "name": "processorManufacturer",
            "value": "unknown"
        }
    ]
}

Indeling van apparaatverbindingswijzigingen

Elk bericht of elke record vertegenwoordigt een connectiviteitsgebeurtenis van één apparaat. Informatie in het geëxporteerde bericht bevat:

applicationId: De id van de IoT Central-toepassing.
messageSource: De bron voor het bericht - deviceConnectivity.
messageType: Of connected disconnected.
deviceId: De id van het apparaat dat is gewijzigd.
schema: de naam en versie van het nettoladingschema.
templateId: De id van de apparaatsjabloon die is toegewezen aan het apparaat.
enqueuedTime: Het tijdstip waarop deze wijziging heeft plaatsgevonden in IoT Central.
enrichments: Alle verrijkingen die voor de export zijn ingesteld.

Voor Blob Storage worden berichten één keer per minuut gebatcheerd en geëxporteerd.

In het volgende voorbeeld ziet u een geëxporteerd verbindingsbericht voor apparaten dat is ontvangen in Azure Blob Storage.

{
  "applicationId": "00001111-aaaa-2222-bbbb-3333cccc4444",
  "messageSource": "deviceConnectivity",
  "messageType": "connected",
  "deviceId": "1vzb5ghlsg1",
  "schema": "default@v1",
  "templateId": "urn:qugj6vbw5:___qbj_27r",
  "enqueuedTime": "2021-04-05T22:26:55.455Z",
  "enrichments": {
    "userSpecifiedKey": "sampleValue"
  }
}

Indeling voor wijzigingen in de levenscyclus van apparaten

Elk bericht of elke record vertegenwoordigt één wijziging in één apparaat. Informatie in het geëxporteerde bericht bevat:

applicationId: De id van de IoT Central-toepassing.
messageSource: De bron voor het bericht - deviceLifecycle.
messageType: Het type wijziging dat is opgetreden. Een van: registered, , deleted, provisioned, enabled, , disabled, , en displayNameChangeddeviceTemplateChanged.
deviceId: De id van het apparaat dat is gewijzigd.
schema: de naam en versie van het nettoladingschema.
templateId: De id van de apparaatsjabloon die is toegewezen aan het apparaat.
enqueuedTime: Het tijdstip waarop deze wijziging heeft plaatsgevonden in IoT Central.
enrichments: Alle verrijkingen die voor de export zijn ingesteld.

Voor Blob Storage worden berichten één keer per minuut gebatcheerd en geëxporteerd.

In het volgende voorbeeld ziet u een geëxporteerd bericht over de levenscyclus van apparaten dat is ontvangen in Azure Blob Storage.

{
  "applicationId": "00001111-aaaa-2222-bbbb-3333cccc4444",
  "messageSource": "deviceLifecycle",
  "messageType": "registered",
  "deviceId": "1vzb5ghlsg1",
  "schema": "default@v1",
  "templateId": "urn:qugj6vbw5:___qbj_27r",
  "enqueuedTime": "2021-01-01T22:26:55.455Z",
  "enrichments": {
    "userSpecifiedKey": "sampleValue"
  }
}

Indeling voor levenscycluswijzigingen van apparaatsjablonen

Elk bericht of elke record vertegenwoordigt één wijziging in één gepubliceerde apparaatsjabloon. Informatie in het geëxporteerde bericht bevat:

applicationId: De id van de IoT Central-toepassing.
messageSource: De bron voor het bericht - deviceTemplateLifecycle.
messageType: Ofwel created, updatedof deleted.
schema: de naam en versie van het nettoladingschema.
templateId: De id van de apparaatsjabloon die is toegewezen aan het apparaat.
enqueuedTime: Het tijdstip waarop deze wijziging heeft plaatsgevonden in IoT Central.
enrichments: Alle verrijkingen die voor de export zijn ingesteld.

Voor Blob Storage worden berichten één keer per minuut gebatcheerd en geëxporteerd.

In het volgende voorbeeld ziet u een geëxporteerd bericht over de levenscyclus van apparaten dat is ontvangen in Azure Blob Storage.

{
  "applicationId": "00001111-aaaa-2222-bbbb-3333cccc4444",
  "messageSource": "deviceTemplateLifecycle",
  "messageType": "created",
  "schema": "default@v1",
  "templateId": "urn:qugj6vbw5:___qbj_27r",
  "enqueuedTime": "2021-01-01T22:26:55.455Z",
  "enrichments": {
    "userSpecifiedKey": "sampleValue"
  }
}

Indeling van auditlogboek

Elk auditlogboekbericht vertegenwoordigt een door de gebruiker geïnitieerde wijziging in een controleerbare entiteit in de IoT Central-toepassing. Informatie in het geëxporteerde bericht bevat:

actor: Informatie over de gebruiker die de entiteit heeft gewijzigd.
applicationId: De id van de IoT Central-toepassing.
messageSource: De bron voor het bericht - audit.
messageType: Het type wijziging dat is opgetreden. Een van: updated, created, deleted.
updated: Alleen aanwezig als messageType dat het is updated. Biedt meer informatie over de update.
resource: Details van de gewijzigde entiteit.
schema: de naam en versie van het nettoladingschema.
deviceId: De id van het apparaat dat is gewijzigd.
enqueuedTime: Het tijdstip waarop deze wijziging heeft plaatsgevonden in IoT Central.
enrichments: Alle verrijkingen die voor de export zijn ingesteld.

In het volgende voorbeeld ziet u een geëxporteerd auditlogboekbericht dat is ontvangen in Azure Blob Storage:

{
  "actor": {
    "id": "test-audit",
    "type": "apiToken"
    },
  "applicationId": "22223333-cccc-4444-dddd-5555eeee6666",
  "enqueuedTime": "2022-07-25T21:54:40.000Z",
  "enrichments": {},
  "messageSource": "audit",
  "messageType": "created",
  "resource": {
    "displayName": "Sensor 1",
    "id": "sensor",
    "type": "device"    
  },
  "schema": "default@v1"
}

Volgende stappen

Nu u weet hoe u kunt exporteren naar Blob Storage, is een voorgestelde volgende stap het leren exporteren naar Service Bus.

Share via

IoT-gegevens exporteren naar Blob Storage

Vereisten

Een Blob Storage-exportbestemming instellen

Verbindingsopties

Een Azure Blob Storage-bestemming maken

Een gegevensexport instellen

Uw export bewaken

Bestandsindelingen

Telemetrie-indeling

Berichteigenschappen

Opmaak van eigenschapswijzigingen

Indeling van apparaatverbindingswijzigingen

Indeling voor wijzigingen in de levenscyclus van apparaten

Indeling voor levenscycluswijzigingen van apparaatsjablonen

Indeling van auditlogboek

Volgende stappen

Feedback

Aanvullende resources