Skip to content

Commit ab568c3

Browse files
committed
Address review comments
1 parent 40c2960 commit ab568c3

File tree

5 files changed

+26
-26
lines changed

5 files changed

+26
-26
lines changed

articles/iot-operations/connect-to-cloud/howto-create-dataflow.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -660,8 +660,8 @@ Request disk persistence allows data flows to maintain state across restarts. Wh
660660

661661
The data flow graph makes this persistence request during subscription using an MQTTv5 user property. This feature only works when:
662662

663-
1. The data flow uses the MQTT broker or asset as source
664-
1. The MQTT broker has persistence enabled with dynamic persistence mode set to `Enabled` for the data type, like subscriber queues
663+
- The data flow uses the MQTT broker or asset as source
664+
- The MQTT broker has persistence enabled with dynamic persistence mode set to `Enabled` for the data type, like subscriber queues
665665

666666
This configuration allows MQTT clients like data flows to request disk persistence for their subscriptions using MQTTv5 user properties. For detailed MQTT broker persistence configuration, see [Configure MQTT broker persistence](../manage-mqtt-broker/howto-broker-persistence.md).
667667

articles/iot-operations/connect-to-cloud/howto-dataflow-graph-wasm.md

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -482,9 +482,9 @@ This example demonstrates a sophisticated data processing workflow that handles
482482

483483
The complex graph processes three data streams and combines them into enriched sensor analytics:
484484

485-
1. Temperature processing: Converts Fahrenheit to Celsius, filters invalid readings, and calculates statistics
486-
2. Humidity processing: Accumulates humidity measurements over time intervals
487-
3. Image processing: Performs object detection on camera snapshots and formats results
485+
- Temperature processing: Converts Fahrenheit to Celsius, filters invalid readings, and calculates statistics
486+
- Humidity processing: Accumulates humidity measurements over time intervals
487+
- Image processing: Performs object detection on camera snapshots and formats results
488488

489489
The graph uses specialized modules from the [operators directory](https://github.com/Azure-Samples/explore-iot-operations/tree/wasm/samples/wasm/operators):
490490

@@ -498,7 +498,7 @@ The graph uses specialized modules from the [operators directory](https://github
498498

499499
The following diagram shows the data flow through the various processing modules:
500500

501-
:::image type="content" source="media/howto-dataflow-graph-wasm/wasm-dataflow-graph-complex.svg" alt-text="Diagram showing a complex data flow graph example with multiple modules" border="false":::
501+
:::image type="content" source="media/howto-dataflow-graph-wasm/wasm-dataflow-graph-complex.svg" alt-text="Diagram showing a complex data flow graph example with multiple modules." border="false":::
502502

503503
<!--
504504
```mermaid
@@ -863,8 +863,8 @@ Request disk persistence allows data flow graphs to maintain state across restar
863863

864864
The data flow graph makes this persistence request during subscription using an MQTTv5 user property. This feature only works when:
865865

866-
1. The data flow uses the MQTT broker as a source (source node with MQTT endpoint)
867-
1. The MQTT broker has persistence enabled with dynamic persistence mode set to `Enabled` for the data type, like subscriber queues
866+
- The data flow uses the MQTT broker as a source (source node with MQTT endpoint)
867+
- The MQTT broker has persistence enabled with dynamic persistence mode set to `Enabled` for the data type, like subscriber queues
868868

869869
This configuration allows MQTT clients like data flow graphs to request disk persistence for their subscriptions using MQTTv5 user properties. For detailed MQTT broker persistence configuration, see [Configure MQTT broker persistence](../manage-mqtt-broker/howto-broker-persistence.md).
870870

articles/iot-operations/connect-to-cloud/howto-develop-wasm-modules.md

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
---
2-
title: Develop WebAssembly modules and graph definitions for data flow graphs (preview)
2+
title: Develop WebAssembly Modules and Graph Definitions for Data Flow Graphs (Preview)
33
description: Learn how to develop WebAssembly modules and graph definitions in Rust and Python for custom data processing in Azure IoT Operations data flow graphs.
44
author: PatAltimore
55
ms.author: patricka
@@ -70,7 +70,7 @@ The hybrid logical clock approach ensures several capabilities:
7070
- **Progress guarantees**: The system knows when processing is complete
7171
- **Distributed coordination**: Multiple nodes stay synchronized
7272

73-
## Understanding operators and modules
73+
## Understand operators and modules
7474

7575
Understanding the distinction between operators and modules is essential for WASM development:
7676

@@ -528,7 +528,7 @@ Use Docker builds for consistent builds across different environments and automa
528528

529529
---
530530

531-
## Implementing operators
531+
## Implement operators
532532

533533
# [Rust](#tab/rust)
534534

@@ -566,11 +566,11 @@ Graph definitions are central to WASM development as they define how your module
566566

567567
Graph definitions follow a formal [JSON schema](https://github.com/Azure-Samples/explore-iot-operations/blob/wasm/samples/wasm/ConfigGraph.json) that validates structure and ensures compatibility. The configuration includes:
568568

569-
1. Module requirements: API and host library version compatibility
570-
2. Module configurations: Runtime parameters for operator customization
571-
3. Operations: Processing nodes in your workflow
572-
4. Connections: Data flow routing between operations
573-
5. Schemas (optional): Data validation schemas
569+
- Module requirements: API and host library version compatibility
570+
- Module configurations: Runtime parameters for operator customization
571+
- Operations: Processing nodes in your workflow
572+
- Connections: Data flow routing between operations
573+
- Schemas (optional): Data validation schemas
574574

575575
### Basic graph structure
576576

@@ -615,16 +615,16 @@ For working examples, see:
615615

616616
The relationship between graph definitions and Azure IoT Operations data flow graphs works as follows:
617617

618-
1. **Graph definition artifact**: Your YAML file defines the internal processing logic with source/sink operations as abstract endpoints
619-
2. **WASM modules**: Referenced modules implement the actual processing operators
620-
3. **Registry storage**: Both graph definitions and WASM modules are uploaded to a container registry (such as Azure Container Registry) as OCI artifacts
621-
4. **Data flow graph resource**: The Azure Resource Manager or Kubernetes resource "wraps" the graph definition and connects it to real endpoints
622-
5. **Runtime deployment**: The data flow engine pulls the artifacts from the registry and deploys them
623-
6. **Endpoint mapping**: The abstract source/sink operations in your graph connect to actual MQTT topics, Azure Event Hubs, or other data sources
618+
- **Graph definition artifact**: Your YAML file defines the internal processing logic with source/sink operations as abstract endpoints
619+
- **WASM modules**: Referenced modules implement the actual processing operators
620+
- **Registry storage**: Both graph definitions and WASM modules are uploaded to a container registry (such as Azure Container Registry) as OCI artifacts
621+
- **Data flow graph resource**: The Azure Resource Manager or Kubernetes resource "wraps" the graph definition and connects it to real endpoints
622+
- **Runtime deployment**: The data flow engine pulls the artifacts from the registry and deploys them
623+
- **Endpoint mapping**: The abstract source/sink operations in your graph connect to actual MQTT topics, Azure Event Hubs, or other data sources
624624

625625
For example, this diagram illustrates the relationship between graph definitions, WASM modules, and data flow graphs:
626626

627-
:::image type="content" source="media/howto-develop-wasm-modules/wasm-dataflow-overall-architecture.svg" alt-text="Diagram showing the relationship between graph definitions, WASM modules, and data flow graphs" border="false":::
627+
:::image type="content" source="media/howto-develop-wasm-modules/wasm-dataflow-overall-architecture.svg" alt-text="Diagram showing the relationship between graph definitions, WASM modules, and data flow graphs." border="false":::
628628

629629
<!--
630630
```mermaid
@@ -699,7 +699,7 @@ moduleConfigurations:
699699
required: false
700700
```
701701

702-
### Consuming parameters in code
702+
### Consume parameters in code
703703

704704
Parameters are accessed through the `ModuleConfiguration` struct passed to your operator's `init` function:
705705

articles/iot-operations/connect-to-cloud/media/howto-dataflow-graph-wasm/wasm-dataflow-graph-complex.svg

Lines changed: 1 addition & 1 deletion
Loading

articles/iot-operations/connect-to-cloud/media/howto-develop-wasm-modules/wasm-dataflow-overall-architecture.svg

Lines changed: 1 addition & 1 deletion
Loading

0 commit comments

Comments
 (0)