Megosztás a következőn keresztül:

Adatok bővítése egy Azure IoT-adatfeldolgozó előzetes verziójának folyamatában

  • Cikk

Fontos

Az Azure IoT Operations Előzetes verziója – az Azure Arc által engedélyezett verzió jelenleg előzetes verzióban érhető el. Ezt az előzetes verziójú szoftvert nem szabad éles környezetben használni.

A bétaverziójú, előzetes verziójú vagy másként még általánosan nem elérhető Azure-szolgáltatások jogi feltételeit lásd: Kiegészítő használati feltételek a Microsoft Azure előzetes verziójú termékeihez.

A bővítési szakasz egy választható köztes folyamatszakasz, amely lehetővé teszi, hogy a folyamat adatait környezeti és referenciaadatokkal bővítse a referenciaadattár-adathalmazokból . A bővítési szakasz segít kontextusba hozni a különböző adatforrásokból származó adatokat, hogy a folyamat adatai értelmezhetőbbek és végrehajthatóbbak legyenek.

A folyamat adatait összekapcsolhatja egy referenciaadatkészlet adataival közös címkék, azonosítók vagy időbélyegek használatával.

Előfeltételek

A bővítési folyamat fázisának konfigurálásához és használatához az Azure IoT Data Processor Preview egy üzembe helyezett példányára van szükség, amely tartalmazza az opcionális adatfeldolgozó összetevőt.

A szakasz konfigurálása

A bővítési fázis JSON-konfigurációja határozza meg a szakasz részleteit. A szakasz létrehozásához használhatja az űrlapalapú felhasználói felületet, vagy megadhatja a JSON-konfigurációt a Speciális lapon:

Mező Leírás Kötelező Beállítások Példa
Név Az Adatfeldolgozó felhasználói felületén megjelenítendő név. Igen - ERP Context
Leírás A bővítési szakasz felhasználóbarát leírása. Nem - Enrich with vendor dataset
Adathalmaz Válassza ki az adathalmazt a bővítés referenciaadataival. Igen - Vendor dataset
Kimeneti elérési út A hivatkozási adatok elhelyezésének elérési útja a kimenő üzenetben. Igen - .payload.erp
Bővítés tömbként Ha igaz, a bővített bejegyzés mindig tömb. Nem No/Yes Yes
Korlát Korlátozza a referenciaadatkészletből visszaadott számbejegyzéseket. Ez a beállítás szabályozza az üzenetben gazdagodó rekordok számát. Nem - 100
Feltételek > operátor Az adatdúsítás illesztési feltételének operátora . Nem Key match/Past nearest/Future nearest Key match
Feltételek > bemeneti elérési útja Az egyes feltételeknek megfelelő kulcs elérési útja . Nem - .payload.asset
Feltételek > tulajdonság Az adathalmaz konfigurációjában megadott illesztési feltétel művelet tulajdonságneve vagy időbélyege Nem Válasszon egy tulajdonságnevet vagy időbélyeget a legördülő listából. equipmentName

Feltétel operátorok

Csatlakozási feltétel Leírás
Key match Azonosítóalapú illesztés, amely összekapcsolja azokat az adatokat, amelyek esetében pontos egyezés van a gazdagítási szakaszban megadott kulcs vagy tulajdonság neve és a referenciaadattár között.
Past nearest Időbélyeg-alapú illesztés, amely összekapcsolja a referenciaadattárban a legközelebbi korábbi időbélyeggel rendelkező referenciaadatokat a bővítési szakaszban megadott üzenet-időbélyeggel.
Future nearest Időbélyeg-alapú illesztés, amely a referenciaadattár legközelebbi jövőbeli időbélyegével összekapcsolja a referenciaadattárban a bővítési szakaszban megadott üzenetidőbélyeggel való összefüggésben.

Megjegyzések:

  • Ha nem ad meg feltételt, az adathalmaz összes referenciaadata bővül.
  • Ha a bemeneti útvonal időbélyegre hivatkozik, az időbélyegek RFC3339 formátumban kell lenniük.
  • Key match megkülönbözteti a kis- és nagybetűk megkülönböztetése.
  • Minden bővítési fázis legfeljebb 10 feltételt tartalmazhat.
  • Minden egyes bővítési fázis csak egy időalapú illesztési feltétellel rendelkezhet: Past nearest vagy Future nearest.
  • Ha egy Key match azonosítóalapú illesztés össze van kapcsolva vagy Future nearest időbélyegalapú illesztési feltételekkel van kombinálvaPast nearest, akkor a rendszer először a Key match visszaadott bejegyzések szűrésére alkalmazza a rendszer, mielőtt Past nearest alkalmazna vagy Future nearest alkalmazna.
  • A visszaadott bejegyzésekre több Key match feltételt is alkalmazhat. A logikai AND művelet több Key match feltétel között történik.

Ha a folyamat podja váratlanul leáll, lehetséges, hogy a háttérbeli eseményadat-folyamattal való összekapcsolás érvénytelen vagy jövőbeli értékeket használ a referenciaadattár-adathalmazból. Ez a helyzet nem kívánt adatdúsításhoz vezethet. A probléma megoldásához és az ilyen adatok szűréséhez használja a feltételt Past nearest .

Ha a feltételt a Past nearest bővítési szakaszban használja, a rendszer csak a referenciaadatokból származó múltbeli értékeket veszi figyelembe a bővítéshez. Ez a megközelítés biztosítja, hogy az összekapcsolt adatok ne tartalmazzanak a referenciaadattár-adatkészlet jövőbeli értékeit. A Past nearest feltétel kiszűri a jövőbeli értékeket, így pontosabb és megbízhatóbb adatbővítést tesz lehetővé.

Mintakonfiguráció

A bővítési fázis konfigurációjában a következő tulajdonságokat kell meghatároznia:

Mező Példa
Név dúsítás
Leírás gazdagítás a berendezések adataival
Adathalmaz equipment
Kimeneti elérési út .payload
Bővítés tömbként Igen
Feltétel > operátor Key match
Feltétel > bemeneti elérési útja .payload.assetid
Feltétel > tulajdonság equipment name

Az illesztés olyan feltételt használ, amely megfelel a assetid bejövő üzenetben szereplő értéknek a equipment name referenciaadatkészlet mezőjével. Ez a konfiguráció kibővíti az üzenetet az adathalmaz releváns adataival. Amikor a bővítési szakasz alkalmazza az illesztési feltételt, hozzáadja a referenciaadatkészlet környezeti adatait az üzenethez, miközben az végigfolyik a folyamaton.

Példa

Ez a példa a referenciaadatkészletekre épül. A bővítési szakasz használatával bővíteni szeretné azokat az idősoradatokat, amelyeket egy folyamat referenciaadatokkal fogad egy gyártási létesítménytől. Ez a példa a következő JSON-ra hasonlító bejövő hasznos adatokat használ:

payload: {
      { 
        "assetid": "Oven", 
        "timestamp": "T05:15:00.000Z", 
        "temperature": 120, 
        "humidity": 99 
    }, 
      { 
        "assetid": "Oven", 
        "timestamp": "T05:16:00.000Z", 
        "temperature": 127, 
        "humidity": 98 
    }, 
      { 
        "AssetID": "Mixer", 
        "timestamp": "T05:17:00.000Z", 
        "temperature": 89, 
        "humidity": 95 
    }, 
      { 
        "AssetID": "Slicer", 
        "timestamp": "T05:19:00.000Z", 
        "temperature": 56, 
        "humidity": 30 
    } 
}

Az alábbi JSON egy példát mutat be egy bővített kimeneti üzenetre az előző konfiguráció alapján:

payload: {
      { 
        "assetid": "Oven", 
        "timestamp": "2023-05-25T05:15:00.000Z", 
        "temperature": 120, 
        "humidity": 99, 
        "location": "Seattle", 
        "installationDate": "2002-03-05T00:00:00Z",  
        "isSpare": false  
    }, 
      { 
        "assetid": "Oven", 
        "timestamp": "2023-05-25T05:16:00.000Z", 
        "temperature": 127, 
        "humidity": 98, 
        "location": "Seattle", 
        "installationDate": "2002-03-05T00:00:00Z",  
        "isSpare": false  
    }, 
      { 
        "assetid": "Mixer", 
        "timestamp": "2023-05-25T05:17:00.000Z", 
        "temperature": 89, 
        "humidity": 95, 
        "location": "Tacoma",  
        "installationDate": "2005-11-15T00:00:00Z",  
        "isSpare": false  
    }, 
      { 
        "assetid": "Slicer", 
        "Timestamp": "2023-05-25T05:19:00.000Z", 
        "Temperature": 56, 
        "humidity": 30, 
        "location": "Seattle",  
        "installationDate": "2021-04-25T00:00:00Z",  
        "isSpare": true  
    } 
}

Kapcsolódó tartalom