Dataanslutning för IoT Hub

Azure IoT Hub är en hanterad tjänst som finns i molnet och som fungerar som en central meddelandehubb för dubbelriktad kommunikation mellan ditt IoT-program och de enheter som det hanterar. Azure Data Explorer erbjuder kontinuerlig inmatning från kundhanterade IoT Hubs med hjälp av dess Event Hub-kompatibla inbyggda slutpunkt för meddelanden från enhet till moln.

IoT-inmatningspipelinen går igenom flera steg. Först skapar du en IoT Hub och registrerar en enhet till den. Sedan skapar du en måltabell i Azure Data Explorer där data i ett visst format matas in med hjälp av de angivna inmatningsegenskaperna. Iot Hub-anslutningen måste känna till händelsedirigering för att ansluta till Azure Data Explorer-tabellen. Data bäddas in med valda egenskaper enligt mappningen av händelsesystemegenskaper. Den här processen kan hanteras via Azure Portal, programmatiskt med C# eller Python eller med Azure Resource Manager-mallen.

Allmän information om datainmatning i Azure Data Explorer finns i Översikt över Datainmatning i Azure Data Explorer.

Dataformat

• Data läss från Event Hub-slutpunkten i form av EventData-objekt .
• Se format som stöds.

  Anteckning

  IoT Hub stöder inte .raw format.

• Se komprimering som stöds.

Inmatningsegenskaper

Inmatningsegenskaper instruerar inmatningsprocessen var data ska dirigeras och hur de ska bearbetas. Du kan ange inmatningsegenskaper för händelserna med hjälp av EventData.Properties. Du kan ange följande egenskaper:

Händelseroutning

När du skapar en dataanslutning till klustret anger du routning för var inmatade data ska skickas. Standardroutningen är till måltabellen som anges i anslutningssträng som är associerad med måldatabasen. Standardroutningen för dina data kallas även statisk routning. Du kan ange en alternativ routning för dina data med hjälp av händelsedataegenskaperna.

Dirigera händelsedata till en alternativ databas

Routning av data till en alternativ databas är inaktiverad som standard. Om du vill skicka data till en annan databas måste du först ange anslutningen som en anslutning med flera databaser. Ett exempel på hur du gör detta i Azure Portal finns i Aktivera routning med flera databaser. Användaren, gruppen, tjänstens huvudnamn eller hanterade identitet som används för att tillåta databasroutning måste minst ha deltagarrollen och skriva behörigheter i klustret.

Ange egenskapen Databasinmatning för att ange en alternativ databas.

Aktivera routning för flera databaser

Innan du kan ange en alternativ måldatabas måste du först tillåta routning av data till flera databaser. Använd följande steg för att tillåta routning av data till alternativa databaser:

1. I Azure Portal bläddrar du till klustret.

2. Välj Databaser>Dataanslutningar.

3. Skapa eller redigera en dataanslutning och i fönstret Dataanslutning , under Inställningar för dataroutning, aktiverar du alternativet Tillåt routning av data till annan databas (dataanslutning med flera databaser).

   

Dirigera händelsedata till en alternativ tabell

Du kan också ange måltabellegenskaper för varje händelse med hjälp av händelseegenskaper. Anslutningen dirigerar dynamiskt data enligt vad som anges i EventData.Properties, vilket åsidosättar de statiska egenskaperna för den här händelsen. Ange egenskapen Tabellinmatning om du vill ange en alternativ tabell.

Mappning av händelsesystemegenskaper

Systemegenskaper är en samling som används för att lagra egenskaper som anges av IoT Hub-tjänsten, när händelsen tas emot. Azure-Data Explorer IoT Hub-anslutningen bäddar in de valda egenskaperna i datalandningen i tabellen.

Systemegenskaper

IoT Hub visar följande systemegenskaper för meddelanden från enhet till moln IoT Hub:

Om du har valt Egenskaper för händelsesystem i avsnittet Datakälla i tabellen måste du inkludera egenskaperna i tabellschemat och mappningen.

Exempel på schemamappning

Exempel på mappning av tabellscheman

Om dina data innehåller tre kolumner (Timespan, Metricoch ) och Valuede egenskaper som du inkluderar är iothub-connection-device-id och sequence-number, skapar eller ändrar du tabellschemat med hjälp av det här kommandot:

    .create-merge table TestTable (TimeStamp: datetime, Metric: string, Value: int, IotHubDeviceId:long, IotHubSequenceNumber:long)

Exempel på CSV-mappning

Kör följande kommandon för att lägga till data i början av posten. Observera ordningstalsvärden.

    .create table TestTable ingestion csv mapping "CsvMapping1"
    '['
    '   { "column" : "TimeStamp", "Properties":{"Ordinal":"2"}},'
    '   { "column" : "Metric", "Properties":{"Ordinal":"3"}},'
    '   { "column" : "Value", "Properties":{"Ordinal":"4"}},'
    '   { "column" : "IotHubDeviceId", "Properties":{"Ordinal":"0"}},'
    '   { "column" : "IotHubSequenceNumber", "Properties":{"Ordinal":"1"}}'
    ']'

JSON-mappningsexempel

Data läggs till med hjälp av mappningen av systemegenskaper. Kör dessa kommandon:

    .create table TestTable ingestion json mapping "JsonMapping1"
    '['
    '    { "column" : "TimeStamp", "Properties":{"Path":"$.timestamp"}},'
    '    { "column" : "Metric", "Properties":{"Path":"$.metric"}},'
    '    { "column" : "Value", "Properties":{"Path":"$.metric_value"}},'
    '    { "column" : "IotHubDeviceId", "Properties":{"Path":"$.iothub-connection-device-id"}},'
    '    { "column" : "IotHubSequenceNumber", "Properties":{"Path":"$.sequence-number"}}'
    ']'

Mappning av händelseanvändares egenskaper

Det finns inget stöd för att utöka nyttolasten för IoT Hub händelser med användaregenskaper. Överväg att bädda in användaregenskaper i händelsetexten överordnad.

IoT Hub anslutning

Skapa en IoT Hub

Om du inte redan har en, skapa en Iot Hub. Anslutning till IoT Hub kan hanteras via Azure Portal, programmatiskt med C# eller Python eller med Azure Resource Manager-mallen.

Skicka händelser

Se exempelprojektet som simulerar en enhet och genererar data.

Nästa steg