You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In this walkthrough, you deploy a Dapr application to the cluster. The Dapr application will consume simulated MQTT data published to Azure IoT MQ, apply a windowing function and then publish the result back to IoT MQ. This represents how high volume data can be aggregated on the edge to reduce message frequency and size. The Dapr application is stateless, and uses the IoT MQ state store to cache past values needed for the window calculations.
18
+
In this walkthrough, you deploy a Dapr application to the cluster. The Dapr application consumes simulated MQTT data published to Azure IoT MQ, applies a windowing function, and then publishes the result back to IoT MQ. The published output represents how high volume data can be aggregated on the edge to reduce message frequency and size. The Dapr application is stateless, and uses the IoT MQ state store to cache past values needed for the window calculations.
19
19
20
20
The Dapr application performs the following steps:
21
21
22
22
1. Subscribes to the `sensor/data` topic for sensor data.
23
-
1. When receiving data on this topic, it's pushed to the Azure IoT MQ state store.
24
-
1. Every **10 seconds**, it fetches the data from the state store, and calculates the *min*, *max*, *mean*, *median* and *75th percentile* values on any sensor data timestamped in the last **30 seconds**.
23
+
1. When data is receiving on the topic, it's forwarded to the Azure IoT MQ state store.
24
+
1. Every **10 seconds**, it fetches the data from the state store and calculates the *min*, *max*, *mean*, *median*, and *75th percentile* values on any sensor data timestamped in the last **30 seconds**.
25
25
1. Data older than **30 seconds** is expired from the state store.
26
26
1. The result is published to the `sensor/window_data` topic in JSON format.
27
27
@@ -35,7 +35,7 @@ The Dapr application performs the following steps:
35
35
36
36
## Deploy the Dapr application
37
37
38
-
At this point, you can deploy the Dapr application. When you register the components, that doesn't deploy the associated binary that is packaged in a container. To deploy the binary along with your application, you can use a Deployment to group the containerized Dapr application and the two components together.
38
+
At this point, you can deploy the Dapr application. Registering the components doesn't deploy the associated binary that is packaged in a container. To deploy the binary along with your application, you can use a Deployment to group the containerized Dapr application and the two components together.
39
39
40
40
To start, create a yaml file that uses the following definitions:
41
41
@@ -238,7 +238,7 @@ To verify the MQTT bridge is working, deploy an MQTT client to the cluster.
238
238
kubectl exec --stdin --tty mqtt-client -n azure-iot-operations -- sh
239
239
```
240
240
241
-
1. Subscribe to the `sensor/window_data` topic to observe the publish output from the Dapr application:
241
+
1. Subscribe to the `sensor/window_data` topic to observe the published output from the Dapr application:
0 commit comments