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

Adatok közzététele MQTT-közvetítőn az Azure IoT Adatfeldolgozó előzetes verziójával

  • 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.

Az MQ-célhelyen feldolgozott üzeneteket tehet közzé egy MQTT-közvetítőn, például egy Azure IoT MQ Preview-példányon a peremhálózaton. Az adatfeldolgozó MQTT-közvetítőhöz csatlakozik az MQTT v5.0 használatával. A cél az MQTT-közvetítőnek teszi közzé az üzeneteket, amint a szakasz megkapja őket. Az MQ-célhely nem támogatja a kötegelést.

Előfeltételek

A célfolyamat-szakasz konfigurálásához és használatához az Azure IoT Data Processor Preview üzembe helyezett példányára van szükség.

A célszakasz konfigurálása

Az MQ célszakasz 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ő Típus Leírás Kötelező Alapértelmezett Példa
Név Sztring Az Adatfeldolgozó felhasználói felületén megjelenítendő név. Igen - MQTT broker output
Leírás Sztring A szakasz felhasználóbarát leírása. Nem Write to topic default/topic1
Közvetítő Sztring A közvetítő címe. Igen - mqtt://mqttEndpoint.cluster.local:1111
Hitelesítés Sztring Az MQTT-közvetítőhöz való csatlakozás hitelesítési részletei. None/Username/Password/Service account token (SAT) Igen Service account token (SAT) Username/Password
Felhasználónév Sztring A használni kívánt felhasználónév, ha Authentication be van állítva a következőre Username/Password: . Nem - myusername
Jelszó Sztring A jelszó titkos referenciája , amelyet akkor kell használni, ha Authentication be van állítva Username/Password. Nem - mysecret
Téma Statikus/dinamikus A témakör definíciója. Sztring, ha a típus statikus, jq elérési út , ha a típus dinamikus. Igen - ".topic"
Adatformátum1 Sztring Az üzenetek szerializálásának formátuma . Igen - Raw
Felhasználói tulajdonságok Kulcs-érték párok listája Az egyes MQTT-üzenetekhez beállítandó egyéni felhasználói tulajdonságok listája. Tartalmazhat statikus információkat vagy adatokat az egyes üzenetekből. Nem []

| Újrapróbálkozás | Újrapróbálkozás | A használni kívánt újrapróbálkozési szabályzat. | Nem | default | fixed |

1Adatformátum: Az adatfeldolgozó beépített szerializálójával szerializálhatja az üzeneteket a következő formátumokba , mielőtt az üzeneteket közzétenné az MQTT-közvetítőn:

  • Raw
  • JSON
  • JSONStream
  • CSV
  • Protobuf
  • MessagePack
  • CBOR

Válassza ki Raw , ha nincs szüksége szerializálásra. A Raw a jelenlegi formátumában küldi el az adatokat az MQTT-közvetítőnek.

Mintakonfiguráció

Az alábbi JSON-példa egy teljes MQ célszakasz-konfigurációt mutat be, amely a teljes üzenetet az MQ-témakörbe pipelineOutput írja:

{
    "displayName": "MQ - 67e929",
    "type": "output/mqtt@v1",
    "viewOptions": {
        "position": {
            "x": 0,
            "y": 992
        }
    },
    "broker": "tls://aio-mq-dmqtt-frontend:8883",
    "qos": 1,
    "authentication": {
        "type": "serviceAccountToken"
    },
    "topic": {
        "type": "static",
        "value": "pipelineOutput"
    },
    "format": {
        "type": "json",
        "path": "."
    },
    "userProperties": [],
    "retry": {
        "type": "fixed",
        "interval": "20s",
        "maxRetries": 4
    }
}

A konfiguráció a következőket határozza meg:

  • A hitelesítés szolgáltatásfiók-jogkivonat használatával történik.
  • A témakör egy statikus sztring, az úgynevezett pipelineOutput.
  • A kimeneti formátum a következő JSON: .
  • A formátum elérési útja annak . biztosítása, hogy a teljes adatfeldolgozó üzenet meg legyen írva az MQ-ba. Ha csak a hasznos adatokat szeretné írni, módosítsa a ".payload" elérési útját.

Példa

Az alábbi példa egy minta bemeneti üzenetet mutat be az MQ célszakaszába:

{
  "payload": {
    "Batch": 102,
    "CurrentTemperature": 7109,
    "Customer": "Contoso",
    "Equipment": "Boiler",
    "IsSpare": true,
    "LastKnownTemperature": 7109,
    "Location": "Seattle",
    "Pressure": 7109,
    "Timestamp": "2023-08-10T00:54:58.6572007Z",
    "assetName": "oven"
  },
  "qos": 0,
  "systemProperties": {
    "partitionId": 0,
    "partitionKey": "quickstart",
    "timestamp": "2023-11-06T23:42:51.004Z"
  },
  "topic": "quickstart"
}

Kapcsolódó tartalom