Skip to content

Commit 3fb75a4

Browse files
authored
Merge pull request #269777 from dominicbetts/aio-qs-dp-updates
AIO: Fix data processor pipeline quickstart
2 parents fc4b31a + bd33b45 commit 3fb75a4

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed
-2.6 KB
Loading

articles/iot-operations/get-started/quickstart-process-telemetry.md

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ ms.topic: quickstart
77
ms.subservice: data-processor
88
ms.custom:
99
- ignite-2023
10-
ms.date: 10/11/2023
10+
ms.date: 03/21/2024
1111

1212
#CustomerIntent: As an OT user, I want to process and enrich my OPC UA data so that I can derive insights from it when I analyze it in the cloud.
1313
---
@@ -202,8 +202,8 @@ Create a Data Processor pipeline to process and enrich your data before it sends
202202

203203
| Input path | Output path | Expiration time |
204204
| ----------------- | ----------------- | ------------------ |
205-
| `.payload.payload["temperature"]` | `.payload.payload.temperature_lkv` | `01h` |
206-
| `.payload.payload["Tag 10"]` | `.payload.payload.tag1_lkv` | `01h` |
205+
| `.payload.Payload["temperature"]` | `.payload.Payload.temperature_lkv` | `01h` |
206+
| `.payload.Payload["Tag 10"]` | `.payload.Payload.tag1_lkv` | `01h` |
207207

208208
This stage enriches the incoming messages with the latest `temperature` and `Tag 10` values if they're missing. The tracked latest values are retained for 1 hour. If the tracked properties appear in the message, the tracked latest value is updated to ensure that the values are always up to date.
209209

@@ -229,16 +229,16 @@ Create a Data Processor pipeline to process and enrich your data before it sends
229229

230230
```jq
231231
.payload = {
232-
assetName: .payload.dataSetWriterName,
233-
Timestamp: .payload.timestamp,
232+
assetName: .payload.DataSetWriterName,
233+
Timestamp: .payload.Timestamp,
234234
Customer: .payload.enrich?.customer,
235235
Batch: .payload.enrich?.batch,
236236
Equipment: .payload.enrich?.equipment,
237237
IsSpare: .payload.enrich?.isSpare,
238238
Location: .payload.enrich?.location,
239-
CurrentTemperature : .payload.payload."temperature"?.Value,
240-
LastKnownTemperature: .payload.payload."temperature_lkv"?.Value,
241-
Pressure: (if .payload.payload | has("Tag 10") then .payload.payload."Tag 10"?.Value else .payload.payload."tag1_lkv"?.Value end)
239+
CurrentTemperature : .payload.Payload."temperature"?.Value,
240+
LastKnownTemperature: .payload.Payload."temperature_lkv"?.Value,
241+
Pressure: (if .payload.Payload | has("Tag 10") then .payload.Payload."Tag 10"?.Value else .payload.Payload."tag1_lkv"?.Value end)
242242
}
243243
```
244244

0 commit comments

Comments
 (0)