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

InfluxDB v2-forrásszakasz konfigurálása

  • 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 forrásszakasz egy Azure IoT-adatfeldolgozó (előzetes verzió) folyamat első és kötelező szakasza. A forrásszakasz beolvasja az adatokat az adatfeldolgozási folyamatba, és előkészíti őket a további feldolgozásra. Az InfluxDB forrásszakasz lehetővé teszi az adatok felhasználó által meghatározott időközönként történő olvasását egy InfluxDB v2-adatbázisból .

A forrásszakaszban a következőket kell meghatároznia:

  • Csatlakozás influxDB v2-hez tartozó részletek.
  • Az az időköz, amely alatt lekérdezhető az InfluxDB-adatbázis. A szakasz megvárja az eredményt, mielőtt visszaállítja az időköz-időzítőt.
  • Particionálási konfiguráció az ön konkrét adatfeldolgozási követelményei alapján.

Előfeltételek

  • Az adatfeldolgozó egy működő példánya van üzembe helyezve.
  • Az InfluxDB-adatbázis minden szükséges nyers adattal működőképes és elérhető.

Az Influx-adatbázis előkészítése

Az InfluxDB-adatbázishoz való csatlakozáshoz a következőkre van szükség:

Az InfluxDB-forrás konfigurálása

Az InfluxDB-forrás konfigurálása:

  • Adja meg az InfluxDB-adatbázis részleteit. Ez a konfiguráció tartalmazza a kiszolgáló nevét és az adatok lekérésére szolgáló lekérdezést.
  • Adja meg a hitelesítési módszert. Jelenleg csak hozzáférési jogkivonat-hitelesítést használhat.

Az alábbi táblázat az InfluxDB forráskonfigurációs paramétereit ismerteti:

A bemeneti konfiguráció alapséma a következőből áll:

Mező Típus Leírás Kötelező? Alapértelmezett Példa
Név Sztring A forrásszakasz ügyfél által látható neve. Kötelező N.a. erp-database
Leírás Sztring A forrásszakasz ügyfél által látható leírása. Választható N.a. Enterprise database
Adatbázis URL-címe Sztring Az InfluxDB-adatbázis URL-címe Igen https://contoso.com/some/url/path
Adatbázis-port Egész Az InfluxDB-adatbázisport Nem 443 443
Organization Sztring Az a szervezet, amely a lekérdezéshez a gyűjtőt tartalmazza Igen test-org test-org
Hitelesítés Hitelesítés típusa A kiszolgálóhoz való csatlakozás hitelesítési módszere. Csak a típust támogatja accessToken . Igen {"type": "accessToken"} {"type": "accessToken"}
Titkos Sztring Hivatkozás az Azure Key Vaultban tárolt jogkivonatra. Igen Igen AKV_ACCESS_TOKEN
Flux lekérdezés Sztring Az InfluxDB-lekérdezés Igen {"expression": 'from(bucket:"test-bucket")\|> range(start: -1h) \|> filter(fn: (r) => r._measurement == "stat")'}
Lekérdezési időköz Időtartam A következő API-hívás előtt várakozni kívánt idő sztringes ábrázolása. Igen 24h
Adatformátum Formátum A szakasz a lekérdezés által lekért egyes sorokra alkalmazza a formátumot. Csak a json formátum támogatott. A legfelső szintű path nem támogatott. Igen {"type": "json"}
Particionálás Particionálás Particionálási konfiguráció a forrásszakaszhoz. Kötelező N.a. Lásd: particionálás

Particionálás konfigurálása

A folyamat particionálása külön partíciókra osztja a bejövő adatokat. A particionálás lehetővé teszi az adatok párhuzamosságát a folyamatban, ami javíthatja az átviteli sebességet és csökkentheti a késést. A particionálási stratégiák hatással vannak az adatok feldolgozásának módjára a folyamat más szakaszaiban. Az utolsó ismert értékszakasz és összesítési fázis például minden logikai partíción működik.

Az adatok particionálásához adja meg a particionálási stratégiát és a használandó partíciók számát:

Mező Leírás Kötelező Alapértelmezett Példa
Partíciótípus A használandó particionálás típusa: Partíció ID vagy partíció Key Kötelező ID ID
Partíciókifejezés A bejövő üzenetben a partíció ID vagy partíció kiszámításához használandó jq kifejezésKey Kötelező 0 .payload.header
Partíciók száma Az adatfeldolgozó folyamat partícióinak száma. Kötelező 1 1

Az adatfeldolgozó metaadatokat ad hozzá a bejövő üzenethez. Az adatfeldolgozó üzenetstruktúrájának áttekintésével megtudhatja, hogyan adhatja meg helyesen a bejövő üzeneten futó particionálási kifejezést. Alapértelmezés szerint a particionálási kifejezés a partíciótípussal van beállítva0, hogy ID az összes bejövő adatot egyetlen partícióra küldje.

A javaslatokról és további tudnivalókról a Mi a particionálás? című témakörben olvashat.

Mintakonfiguráció

Az alábbi JSON-példa egy teljes InfluxDB-forrásszakasz-konfigurációt mutat be:

{
  "displayName": "InfluxDB v2 - ec8750",
  "type": "input/influxdbv2@v1",
  "query": {
    "expression": "from(bucket:\\\"test-bucket\\\") |> range(start: -1h) |> filter(fn: (r) => r._measurement == \\\"stat\\\")"
  },
  "url": "https://contoso.com/some/url/path",
  "interval": "5s",
  "port": 443,
  "organization": "test-org",
  "format": {
    "type": "json"
  },
  "partitionCount": 1,
  "partitionStrategy": {
    "type": "id",
    "expression": "0"
  },
  "authentication": {
    "type": "accessToken",
    "accessToken": "AKV_ACCESS_TOKEN"
  },
  "description": "Example InfluxDB source stage"
}

Kapcsolódó tartalom