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
Copy file name to clipboardExpand all lines: articles/iot-operations/connect-to-cloud/howto-create-dataflow.md
+62-10Lines changed: 62 additions & 10 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -6,7 +6,7 @@ ms.author: patricka
6
6
ms.service: azure-iot-operations
7
7
ms.subservice: azure-data-flows
8
8
ms.topic: how-to
9
-
ms.date: 11/01/2024
9
+
ms.date: 11/06/2024
10
10
ai-usage: ai-assisted
11
11
12
12
#CustomerIntent: As an operator, I want to understand how to create a dataflow to connect data sources.
@@ -515,10 +515,41 @@ You can load sample data into the DSS by using the [DSS set tool sample](https:/
515
515
516
516
In the operations experience, the *Enrich* stage is currently supported using the **Rename** and **New property** transforms.
517
517
518
-
1. In the operations experience, select a dataflow then **Add transform (optional)**.
519
-
1. Choose **Rename** or **New property** transforms then select **Add**.
518
+
#### Rename
520
519
521
-
:::image type="content" source="media/howto-create-dataflow/dataflow-enrich.png" alt-text="Screenshot using operations experience to rename a datapoint and add a new property.":::
520
+
You can rename a datapoint using the **Rename** transform. This operation is used to rename a datapoint in the source data to a new name. The new name can be used in the subsequent stages of the dataflow.
521
+
522
+
1. Under **Transform (optional)**, select **Rename** > **Add**.
523
+
524
+
:::image type="content" source="media/howto-create-dataflow/dataflow-rename.png" alt-text="Screenshot using operations experience to rename a datapoint.":::
| Datapoint | Select a datapoint from the dropdown or enter a $metadata header using the format `$metadata.<header>.` |
531
+
| New datapoint name | Enter the new name for the datapoint. |
532
+
| Description | Provide a description for the transformation. |
533
+
534
+
1. Select **Apply**.
535
+
536
+
#### New property
537
+
538
+
You can add a new property to the source data using the **New property** transform. This operation is used to add a new property to the source data. The new property can be used in the subsequent stages of the dataflow.
539
+
540
+
1. Under **Transform (optional)**, select **New property** > **Add**.
541
+
542
+
:::image type="content" source="media/howto-create-dataflow/dataflow-new-property.png" alt-text="Screenshot using operations experience to add a new property.":::
| Property key | Enter the key for the new property. |
549
+
| Property value | Enter the value for the new property. |
550
+
| Description | Provide a description for the new property. |
551
+
552
+
1. Select **Apply**.
522
553
523
554
# [Bicep](#tab/bicep)
524
555
@@ -576,14 +607,21 @@ To filter the data on a condition, you can use the `filter` stage. The condition
576
607
# [Portal](#tab/portal)
577
608
578
609
1. Under **Transform (optional)**, select **Filter** > **Add**.
579
-
1. Choose the datapoints to include in the dataset.
580
-
1. Add a filter condition and description.
581
610
582
611
:::image type="content" source="media/howto-create-dataflow/dataflow-filter.png" alt-text="Screenshot using operations experience to add a filter transform.":::
| Filter condition | The condition to filter the data based on a field in the source data. |
618
+
| Description | Provide a description for the filter condition. |
619
+
620
+
In the filter condition field, type `@` or select **Ctrl + Space** to select datapoints from a dropdown. You can also enter $metadata headers using the format `@$metadata.<header>`.
585
621
586
-
For example, you could use a filter condition like `temperature > 20` to filter data less than or equal to 20 based on the temperature field.
622
+
The condition can use the fields in the source data. For example, you could use a filter condition like `temperature > 20` to filter data less than or equal to 20 based on the temperature field.
623
+
624
+
1. Select **Apply**.
587
625
588
626
# [Bicep](#tab/bicep)
589
627
@@ -629,10 +667,24 @@ To map the data to another field with optional conversion, you can use the `map`
629
667
In the operations experience, mapping is currently supported using **Compute** transforms.
630
668
631
669
1. Under **Transform (optional)**, select **Compute** > **Add**.
632
-
1. Enter the required fields and expressions.
633
670
634
671
:::image type="content" source="media/howto-create-dataflow/dataflow-compute.png" alt-text="Screenshot using operations experience to add a compute transform.":::
| Select formula | Choose an existing formula from the dropdown or select **Custom** to enter a formula manually. |
678
+
| Output | Specify the output display name for the result. |
679
+
| Formula | Enter the formula to be applied to the source data. |
680
+
| Description | Provide a description for the transformation. |
681
+
| Last known value | Optionally, use the last known value if the current value isn't available. |
682
+
683
+
684
+
You can enter or edit a formula in the **Formula** field. The formula can use the fields in the source data. Type `@` or select **Ctrl + Space** to select datapoints from a dropdown. You can also enter $metadata headers using the format `@$metadata.<header>`.
685
+
686
+
The formula can use the fields in the source data. For example, you could use the `temperature` field in the source data to convert the temperature to Celsius and store it in the `temperatureCelsius` output field.
687
+
636
688
1. Select **Apply**.
637
689
638
690
# [Bicep](#tab/bicep)
@@ -883,7 +935,7 @@ destinationSettings:
883
935
884
936
## Example
885
937
886
-
The following example is a dataflow configuration that uses the MQTT endpoint for the source and destination. The source filters the data from the MQTT topic `azure-iot-operations/data/thermostat`. The transformation converts the temperature to Fahrenheit and filters the data where the temperature multiplied by the humiditiy is less than 100000. The destination sends the data to the MQTT topic `factory`.
938
+
The following example is a dataflow configuration that uses the MQTT endpoint for the source and destination. The source filters the data from the MQTT topic `azure-iot-operations/data/thermostat`. The transformation converts the temperature to Fahrenheit and filters the data where the temperature multiplied by the humidity is less than 100000. The destination sends the data to the MQTT topic `factory`.
0 commit comments