Docs Home
This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
Azure Native v3.3.0 published on Monday, Apr 28, 2025 by Pulumi
azure-native.iotoperations.Dataflow
Explore with Pulumi AI
This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
Azure Native v3.3.0 published on Monday, Apr 28, 2025 by Pulumi
Instance dataflowProfile dataflow resource
Uses Azure REST API version 2024-11-01.
Other available API versions: 2024-08-15-preview, 2024-09-15-preview, 2025-04-01. These can be accessed by generating a local SDK package using the CLI command pulumi package add azure-native iotoperations [ApiVersion]. See the version guide for details.
Example Usage
Dataflow_CreateOrUpdate
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var dataflow = new AzureNative.IoTOperations.Dataflow("dataflow", new()
{
DataflowName = "resource-name123",
DataflowProfileName = "resource-name123",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
Operations = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
BuiltInTransformationSettings = new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationSettingsArgs
{
Datasets = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationDatasetArgs
{
Description = "Lorem ipsum odor amet, consectetuer adipiscing elit.",
Expression = "aatbwomvflemsxialv",
Inputs = new[]
{
"mosffpsslifkq",
},
Key = "qsfqcgxaxnhfumrsdsokwyv",
SchemaRef = "n",
},
},
Filter = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationFilterArgs
{
Description = "Lorem ipsum odor amet, consectetuer adipiscing elit.",
Expression = "n",
Inputs = new[]
{
"sxmjkbntgb",
},
Type = AzureNative.IoTOperations.FilterType.Filter,
},
},
Map = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Description = "Lorem ipsum odor amet, consectetuer adipiscing elit.",
Expression = "txoiltogsarwkzalsphvlmt",
Inputs = new[]
{
"xsbxuk",
},
Output = "nvgtmkfl",
Type = AzureNative.IoTOperations.DataflowMappingType.NewProperties,
},
},
SchemaRef = "mcdc",
SerializationFormat = AzureNative.IoTOperations.TransformationSerializationFormat.Delta,
},
DestinationSettings = new AzureNative.IoTOperations.Inputs.DataflowDestinationOperationSettingsArgs
{
DataDestination = "cbrh",
EndpointRef = "kybkchnzimerguekuvqlqiqdvvrt",
},
Name = "knnafvkwoeakm",
OperationType = AzureNative.IoTOperations.OperationType.Source,
SourceSettings = new AzureNative.IoTOperations.Inputs.DataflowSourceOperationSettingsArgs
{
AssetRef = "zayyykwmckaocywdkohmu",
DataSources = new[]
{
"chkkpymxhp",
},
EndpointRef = "iixotodhvhkkfcfyrkoveslqig",
SchemaRef = "pknmdzqll",
SerializationFormat = AzureNative.IoTOperations.SourceSerializationFormat.Json,
},
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflow(ctx, "dataflow", &iotoperations.DataflowArgs{
DataflowName: pulumi.String("resource-name123"),
DataflowProfileName: pulumi.String("resource-name123"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
Operations: iotoperations.DataflowOperationArray{
&iotoperations.DataflowOperationArgs{
BuiltInTransformationSettings: &iotoperations.DataflowBuiltInTransformationSettingsArgs{
Datasets: iotoperations.DataflowBuiltInTransformationDatasetArray{
&iotoperations.DataflowBuiltInTransformationDatasetArgs{
Description: pulumi.String("Lorem ipsum odor amet, consectetuer adipiscing elit."),
Expression: pulumi.String("aatbwomvflemsxialv"),
Inputs: pulumi.StringArray{
pulumi.String("mosffpsslifkq"),
},
Key: pulumi.String("qsfqcgxaxnhfumrsdsokwyv"),
SchemaRef: pulumi.String("n"),
},
},
Filter: iotoperations.DataflowBuiltInTransformationFilterArray{
&iotoperations.DataflowBuiltInTransformationFilterArgs{
Description: pulumi.String("Lorem ipsum odor amet, consectetuer adipiscing elit."),
Expression: pulumi.String("n"),
Inputs: pulumi.StringArray{
pulumi.String("sxmjkbntgb"),
},
Type: pulumi.String(iotoperations.FilterTypeFilter),
},
},
Map: iotoperations.DataflowBuiltInTransformationMapArray{
&iotoperations.DataflowBuiltInTransformationMapArgs{
Description: pulumi.String("Lorem ipsum odor amet, consectetuer adipiscing elit."),
Expression: pulumi.String("txoiltogsarwkzalsphvlmt"),
Inputs: pulumi.StringArray{
pulumi.String("xsbxuk"),
},
Output: pulumi.String("nvgtmkfl"),
Type: pulumi.String(iotoperations.DataflowMappingTypeNewProperties),
},
},
SchemaRef: pulumi.String("mcdc"),
SerializationFormat: pulumi.String(iotoperations.TransformationSerializationFormatDelta),
},
DestinationSettings: &iotoperations.DataflowDestinationOperationSettingsArgs{
DataDestination: pulumi.String("cbrh"),
EndpointRef: pulumi.String("kybkchnzimerguekuvqlqiqdvvrt"),
},
Name: pulumi.String("knnafvkwoeakm"),
OperationType: pulumi.String(iotoperations.OperationTypeSource),
SourceSettings: &iotoperations.DataflowSourceOperationSettingsArgs{
AssetRef: pulumi.String("zayyykwmckaocywdkohmu"),
DataSources: pulumi.StringArray{
pulumi.String("chkkpymxhp"),
},
EndpointRef: pulumi.String("iixotodhvhkkfcfyrkoveslqig"),
SchemaRef: pulumi.String("pknmdzqll"),
SerializationFormat: pulumi.String(iotoperations.SourceSerializationFormatJson),
},
},
},
},
ResourceGroupName: pulumi.String("rgiotoperations"),
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperations.Dataflow;
import com.pulumi.azurenative.iotoperations.DataflowArgs;
import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowPropertiesArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var dataflow = new Dataflow("dataflow", DataflowArgs.builder()
.dataflowName("resource-name123")
.dataflowProfileName("resource-name123")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowPropertiesArgs.builder()
.mode("Enabled")
.operations(DataflowOperationArgs.builder()
.builtInTransformationSettings(DataflowBuiltInTransformationSettingsArgs.builder()
.datasets(DataflowBuiltInTransformationDatasetArgs.builder()
.description("Lorem ipsum odor amet, consectetuer adipiscing elit.")
.expression("aatbwomvflemsxialv")
.inputs("mosffpsslifkq")
.key("qsfqcgxaxnhfumrsdsokwyv")
.schemaRef("n")
.build())
.filter(DataflowBuiltInTransformationFilterArgs.builder()
.description("Lorem ipsum odor amet, consectetuer adipiscing elit.")
.expression("n")
.inputs("sxmjkbntgb")
.type("Filter")
.build())
.map(DataflowBuiltInTransformationMapArgs.builder()
.description("Lorem ipsum odor amet, consectetuer adipiscing elit.")
.expression("txoiltogsarwkzalsphvlmt")
.inputs("xsbxuk")
.output("nvgtmkfl")
.type("NewProperties")
.build())
.schemaRef("mcdc")
.serializationFormat("Delta")
.build())
.destinationSettings(DataflowDestinationOperationSettingsArgs.builder()
.dataDestination("cbrh")
.endpointRef("kybkchnzimerguekuvqlqiqdvvrt")
.build())
.name("knnafvkwoeakm")
.operationType("Source")
.sourceSettings(DataflowSourceOperationSettingsArgs.builder()
.assetRef("zayyykwmckaocywdkohmu")
.dataSources("chkkpymxhp")
.endpointRef("iixotodhvhkkfcfyrkoveslqig")
.schemaRef("pknmdzqll")
.serializationFormat("Json")
.build())
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflow = new azure_native.iotoperations.Dataflow("dataflow", {
dataflowName: "resource-name123",
dataflowProfileName: "resource-name123",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
operations: [{
builtInTransformationSettings: {
datasets: [{
description: "Lorem ipsum odor amet, consectetuer adipiscing elit.",
expression: "aatbwomvflemsxialv",
inputs: ["mosffpsslifkq"],
key: "qsfqcgxaxnhfumrsdsokwyv",
schemaRef: "n",
}],
filter: [{
description: "Lorem ipsum odor amet, consectetuer adipiscing elit.",
expression: "n",
inputs: ["sxmjkbntgb"],
type: azure_native.iotoperations.FilterType.Filter,
}],
map: [{
description: "Lorem ipsum odor amet, consectetuer adipiscing elit.",
expression: "txoiltogsarwkzalsphvlmt",
inputs: ["xsbxuk"],
output: "nvgtmkfl",
type: azure_native.iotoperations.DataflowMappingType.NewProperties,
}],
schemaRef: "mcdc",
serializationFormat: azure_native.iotoperations.TransformationSerializationFormat.Delta,
},
destinationSettings: {
dataDestination: "cbrh",
endpointRef: "kybkchnzimerguekuvqlqiqdvvrt",
},
name: "knnafvkwoeakm",
operationType: azure_native.iotoperations.OperationType.Source,
sourceSettings: {
assetRef: "zayyykwmckaocywdkohmu",
dataSources: ["chkkpymxhp"],
endpointRef: "iixotodhvhkkfcfyrkoveslqig",
schemaRef: "pknmdzqll",
serializationFormat: azure_native.iotoperations.SourceSerializationFormat.Json,
},
}],
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow = azure_native.iotoperations.Dataflow("dataflow",
dataflow_name="resource-name123",
dataflow_profile_name="resource-name123",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
"operations": [{
"built_in_transformation_settings": {
"datasets": [{
"description": "Lorem ipsum odor amet, consectetuer adipiscing elit.",
"expression": "aatbwomvflemsxialv",
"inputs": ["mosffpsslifkq"],
"key": "qsfqcgxaxnhfumrsdsokwyv",
"schema_ref": "n",
}],
"filter": [{
"description": "Lorem ipsum odor amet, consectetuer adipiscing elit.",
"expression": "n",
"inputs": ["sxmjkbntgb"],
"type": azure_native.iotoperations.FilterType.FILTER,
}],
"map": [{
"description": "Lorem ipsum odor amet, consectetuer adipiscing elit.",
"expression": "txoiltogsarwkzalsphvlmt",
"inputs": ["xsbxuk"],
"output": "nvgtmkfl",
"type": azure_native.iotoperations.DataflowMappingType.NEW_PROPERTIES,
}],
"schema_ref": "mcdc",
"serialization_format": azure_native.iotoperations.TransformationSerializationFormat.DELTA,
},
"destination_settings": {
"data_destination": "cbrh",
"endpoint_ref": "kybkchnzimerguekuvqlqiqdvvrt",
},
"name": "knnafvkwoeakm",
"operation_type": azure_native.iotoperations.OperationType.SOURCE,
"source_settings": {
"asset_ref": "zayyykwmckaocywdkohmu",
"data_sources": ["chkkpymxhp"],
"endpoint_ref": "iixotodhvhkkfcfyrkoveslqig",
"schema_ref": "pknmdzqll",
"serialization_format": azure_native.iotoperations.SourceSerializationFormat.JSON,
},
}],
},
resource_group_name="rgiotoperations")
resources:
dataflow:
type: azure-native:iotoperations:Dataflow
properties:
dataflowName: resource-name123
dataflowProfileName: resource-name123
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
mode: Enabled
operations:
- builtInTransformationSettings:
datasets:
- description: Lorem ipsum odor amet, consectetuer adipiscing elit.
expression: aatbwomvflemsxialv
inputs:
- mosffpsslifkq
key: qsfqcgxaxnhfumrsdsokwyv
schemaRef: n
filter:
- description: Lorem ipsum odor amet, consectetuer adipiscing elit.
expression: n
inputs:
- sxmjkbntgb
type: Filter
map:
- description: Lorem ipsum odor amet, consectetuer adipiscing elit.
expression: txoiltogsarwkzalsphvlmt
inputs:
- xsbxuk
output: nvgtmkfl
type: NewProperties
schemaRef: mcdc
serializationFormat: Delta
destinationSettings:
dataDestination: cbrh
endpointRef: kybkchnzimerguekuvqlqiqdvvrt
name: knnafvkwoeakm
operationType: Source
sourceSettings:
assetRef: zayyykwmckaocywdkohmu
dataSources:
- chkkpymxhp
endpointRef: iixotodhvhkkfcfyrkoveslqig
schemaRef: pknmdzqll
serializationFormat: Json
resourceGroupName: rgiotoperations
Dataflow_CreateOrUpdate_ComplexContextualization
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var dataflow = new AzureNative.IoTOperations.Dataflow("dataflow", new()
{
DataflowName = "aio-to-adx-contexualized",
DataflowProfileName = "resource-name123",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
Operations = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
Name = "source1",
OperationType = AzureNative.IoTOperations.OperationType.Source,
SourceSettings = new AzureNative.IoTOperations.Inputs.DataflowSourceOperationSettingsArgs
{
DataSources = new[]
{
"azure-iot-operations/data/thermostat",
},
EndpointRef = "aio-builtin-broker-endpoint",
},
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
BuiltInTransformationSettings = new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationSettingsArgs
{
Datasets = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationDatasetArgs
{
Expression = "$1 == $2",
Inputs = new[]
{
"$source.country",
"$context.country",
},
Key = "quality",
},
},
Map = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Inputs = new[]
{
"*",
},
Output = "*",
},
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Inputs = new[]
{
"$context(quality).*",
},
Output = "enriched.*",
},
},
},
Name = "transformation1",
OperationType = AzureNative.IoTOperations.OperationType.BuiltInTransformation,
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
DestinationSettings = new AzureNative.IoTOperations.Inputs.DataflowDestinationOperationSettingsArgs
{
DataDestination = "mytable",
EndpointRef = "adx-endpoint",
},
Name = "destination1",
OperationType = AzureNative.IoTOperations.OperationType.Destination,
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflow(ctx, "dataflow", &iotoperations.DataflowArgs{
DataflowName: pulumi.String("aio-to-adx-contexualized"),
DataflowProfileName: pulumi.String("resource-name123"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
Operations: iotoperations.DataflowOperationArray{
&iotoperations.DataflowOperationArgs{
Name: pulumi.String("source1"),
OperationType: pulumi.String(iotoperations.OperationTypeSource),
SourceSettings: &iotoperations.DataflowSourceOperationSettingsArgs{
DataSources: pulumi.StringArray{
pulumi.String("azure-iot-operations/data/thermostat"),
},
EndpointRef: pulumi.String("aio-builtin-broker-endpoint"),
},
},
&iotoperations.DataflowOperationArgs{
BuiltInTransformationSettings: &iotoperations.DataflowBuiltInTransformationSettingsArgs{
Datasets: iotoperations.DataflowBuiltInTransformationDatasetArray{
&iotoperations.DataflowBuiltInTransformationDatasetArgs{
Expression: pulumi.String("$1 == $2"),
Inputs: pulumi.StringArray{
pulumi.String("$source.country"),
pulumi.String("$context.country"),
},
Key: pulumi.String("quality"),
},
},
Map: iotoperations.DataflowBuiltInTransformationMapArray{
&iotoperations.DataflowBuiltInTransformationMapArgs{
Inputs: pulumi.StringArray{
pulumi.String("*"),
},
Output: pulumi.String("*"),
},
&iotoperations.DataflowBuiltInTransformationMapArgs{
Inputs: pulumi.StringArray{
pulumi.String("$context(quality).*"),
},
Output: pulumi.String("enriched.*"),
},
},
},
Name: pulumi.String("transformation1"),
OperationType: pulumi.String(iotoperations.OperationTypeBuiltInTransformation),
},
&iotoperations.DataflowOperationArgs{
DestinationSettings: &iotoperations.DataflowDestinationOperationSettingsArgs{
DataDestination: pulumi.String("mytable"),
EndpointRef: pulumi.String("adx-endpoint"),
},
Name: pulumi.String("destination1"),
OperationType: pulumi.String(iotoperations.OperationTypeDestination),
},
},
},
ResourceGroupName: pulumi.String("rgiotoperations"),
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperations.Dataflow;
import com.pulumi.azurenative.iotoperations.DataflowArgs;
import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowPropertiesArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var dataflow = new Dataflow("dataflow", DataflowArgs.builder()
.dataflowName("aio-to-adx-contexualized")
.dataflowProfileName("resource-name123")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowPropertiesArgs.builder()
.mode("Enabled")
.operations(
DataflowOperationArgs.builder()
.name("source1")
.operationType("Source")
.sourceSettings(DataflowSourceOperationSettingsArgs.builder()
.dataSources("azure-iot-operations/data/thermostat")
.endpointRef("aio-builtin-broker-endpoint")
.build())
.build(),
DataflowOperationArgs.builder()
.builtInTransformationSettings(DataflowBuiltInTransformationSettingsArgs.builder()
.datasets(DataflowBuiltInTransformationDatasetArgs.builder()
.expression("$1 == $2")
.inputs(
"$source.country",
"$context.country")
.key("quality")
.build())
.map(
DataflowBuiltInTransformationMapArgs.builder()
.inputs("*")
.output("*")
.build(),
DataflowBuiltInTransformationMapArgs.builder()
.inputs("$context(quality).*")
.output("enriched.*")
.build())
.build())
.name("transformation1")
.operationType("BuiltInTransformation")
.build(),
DataflowOperationArgs.builder()
.destinationSettings(DataflowDestinationOperationSettingsArgs.builder()
.dataDestination("mytable")
.endpointRef("adx-endpoint")
.build())
.name("destination1")
.operationType("Destination")
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflow = new azure_native.iotoperations.Dataflow("dataflow", {
dataflowName: "aio-to-adx-contexualized",
dataflowProfileName: "resource-name123",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
operations: [
{
name: "source1",
operationType: azure_native.iotoperations.OperationType.Source,
sourceSettings: {
dataSources: ["azure-iot-operations/data/thermostat"],
endpointRef: "aio-builtin-broker-endpoint",
},
},
{
builtInTransformationSettings: {
datasets: [{
expression: "$1 == $2",
inputs: [
"$source.country",
"$context.country",
],
key: "quality",
}],
map: [
{
inputs: ["*"],
output: "*",
},
{
inputs: ["$context(quality).*"],
output: "enriched.*",
},
],
},
name: "transformation1",
operationType: azure_native.iotoperations.OperationType.BuiltInTransformation,
},
{
destinationSettings: {
dataDestination: "mytable",
endpointRef: "adx-endpoint",
},
name: "destination1",
operationType: azure_native.iotoperations.OperationType.Destination,
},
],
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow = azure_native.iotoperations.Dataflow("dataflow",
dataflow_name="aio-to-adx-contexualized",
dataflow_profile_name="resource-name123",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
"operations": [
{
"name": "source1",
"operation_type": azure_native.iotoperations.OperationType.SOURCE,
"source_settings": {
"data_sources": ["azure-iot-operations/data/thermostat"],
"endpoint_ref": "aio-builtin-broker-endpoint",
},
},
{
"built_in_transformation_settings": {
"datasets": [{
"expression": "$1 == $2",
"inputs": [
"$source.country",
"$context.country",
],
"key": "quality",
}],
"map": [
{
"inputs": ["*"],
"output": "*",
},
{
"inputs": ["$context(quality).*"],
"output": "enriched.*",
},
],
},
"name": "transformation1",
"operation_type": azure_native.iotoperations.OperationType.BUILT_IN_TRANSFORMATION,
},
{
"destination_settings": {
"data_destination": "mytable",
"endpoint_ref": "adx-endpoint",
},
"name": "destination1",
"operation_type": azure_native.iotoperations.OperationType.DESTINATION,
},
],
},
resource_group_name="rgiotoperations")
resources:
dataflow:
type: azure-native:iotoperations:Dataflow
properties:
dataflowName: aio-to-adx-contexualized
dataflowProfileName: resource-name123
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
mode: Enabled
operations:
- name: source1
operationType: Source
sourceSettings:
dataSources:
- azure-iot-operations/data/thermostat
endpointRef: aio-builtin-broker-endpoint
- builtInTransformationSettings:
datasets:
- expression: $1 == $2
inputs:
- $source.country
- $context.country
key: quality
map:
- inputs:
- '*'
output: '*'
- inputs:
- $context(quality).*
output: enriched.*
name: transformation1
operationType: BuiltInTransformation
- destinationSettings:
dataDestination: mytable
endpointRef: adx-endpoint
name: destination1
operationType: Destination
resourceGroupName: rgiotoperations
Dataflow_CreateOrUpdate_ComplexEventHub
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var dataflow = new AzureNative.IoTOperations.Dataflow("dataflow", new()
{
DataflowName = "aio-to-event-hub-transformed",
DataflowProfileName = "resource-name123",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
Operations = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
Name = "source1",
OperationType = AzureNative.IoTOperations.OperationType.Source,
SourceSettings = new AzureNative.IoTOperations.Inputs.DataflowSourceOperationSettingsArgs
{
DataSources = new[]
{
"azure-iot-operations/data/thermostat",
},
EndpointRef = "aio-builtin-broker-endpoint",
},
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
BuiltInTransformationSettings = new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationSettingsArgs
{
Filter = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationFilterArgs
{
Expression = "$1 > 9000 && $2 >= 8000",
Inputs = new[]
{
"temperature.Value",
"\"Tag 10\".Value",
},
},
},
Map = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Inputs = new[]
{
"*",
},
Output = "*",
},
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Expression = "($1+$2)/2",
Inputs = new[]
{
"temperature.Value",
"\"Tag 10\".Value",
},
Output = "AvgTemp.Value",
},
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Expression = "true",
Inputs = new() { },
Output = "dataflow-processed",
},
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Expression = "",
Inputs = new[]
{
"temperature.SourceTimestamp",
},
Output = "",
},
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Expression = "",
Inputs = new[]
{
"\"Tag 10\"",
},
Output = "pressure",
},
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Expression = "cToF($1)",
Inputs = new[]
{
"temperature.Value",
},
Output = "temperatureF.Value",
},
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Expression = "scale ($1,0,10,0,100)",
Inputs = new[]
{
"\"Tag 10\".Value",
},
Output = "\"Scale Tag 10\".Value",
},
},
},
OperationType = AzureNative.IoTOperations.OperationType.BuiltInTransformation,
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
DestinationSettings = new AzureNative.IoTOperations.Inputs.DataflowDestinationOperationSettingsArgs
{
DataDestination = "myuniqueeventhub",
EndpointRef = "event-hub-endpoint",
},
Name = "destination1",
OperationType = AzureNative.IoTOperations.OperationType.Destination,
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflow(ctx, "dataflow", &iotoperations.DataflowArgs{
DataflowName: pulumi.String("aio-to-event-hub-transformed"),
DataflowProfileName: pulumi.String("resource-name123"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
Operations: iotoperations.DataflowOperationArray{
&iotoperations.DataflowOperationArgs{
Name: pulumi.String("source1"),
OperationType: pulumi.String(iotoperations.OperationTypeSource),
SourceSettings: &iotoperations.DataflowSourceOperationSettingsArgs{
DataSources: pulumi.StringArray{
pulumi.String("azure-iot-operations/data/thermostat"),
},
EndpointRef: pulumi.String("aio-builtin-broker-endpoint"),
},
},
&iotoperations.DataflowOperationArgs{
BuiltInTransformationSettings: &iotoperations.DataflowBuiltInTransformationSettingsArgs{
Filter: iotoperations.DataflowBuiltInTransformationFilterArray{
&iotoperations.DataflowBuiltInTransformationFilterArgs{
Expression: pulumi.String("$1 > 9000 && $2 >= 8000"),
Inputs: pulumi.StringArray{
pulumi.String("temperature.Value"),
pulumi.String("\"Tag 10\".Value"),
},
},
},
Map: iotoperations.DataflowBuiltInTransformationMapArray{
&iotoperations.DataflowBuiltInTransformationMapArgs{
Inputs: pulumi.StringArray{
pulumi.String("*"),
},
Output: pulumi.String("*"),
},
&iotoperations.DataflowBuiltInTransformationMapArgs{
Expression: pulumi.String("($1+$2)/2"),
Inputs: pulumi.StringArray{
pulumi.String("temperature.Value"),
pulumi.String("\"Tag 10\".Value"),
},
Output: pulumi.String("AvgTemp.Value"),
},
&iotoperations.DataflowBuiltInTransformationMapArgs{
Expression: pulumi.String("true"),
Inputs: pulumi.StringArray{},
Output: pulumi.String("dataflow-processed"),
},
&iotoperations.DataflowBuiltInTransformationMapArgs{
Expression: pulumi.String(""),
Inputs: pulumi.StringArray{
pulumi.String("temperature.SourceTimestamp"),
},
Output: pulumi.String(""),
},
&iotoperations.DataflowBuiltInTransformationMapArgs{
Expression: pulumi.String(""),
Inputs: pulumi.StringArray{
pulumi.String("\"Tag 10\""),
},
Output: pulumi.String("pressure"),
},
&iotoperations.DataflowBuiltInTransformationMapArgs{
Expression: pulumi.String("cToF($1)"),
Inputs: pulumi.StringArray{
pulumi.String("temperature.Value"),
},
Output: pulumi.String("temperatureF.Value"),
},
&iotoperations.DataflowBuiltInTransformationMapArgs{
Expression: pulumi.String("scale ($1,0,10,0,100)"),
Inputs: pulumi.StringArray{
pulumi.String("\"Tag 10\".Value"),
},
Output: pulumi.String("\"Scale Tag 10\".Value"),
},
},
},
OperationType: pulumi.String(iotoperations.OperationTypeBuiltInTransformation),
},
&iotoperations.DataflowOperationArgs{
DestinationSettings: &iotoperations.DataflowDestinationOperationSettingsArgs{
DataDestination: pulumi.String("myuniqueeventhub"),
EndpointRef: pulumi.String("event-hub-endpoint"),
},
Name: pulumi.String("destination1"),
OperationType: pulumi.String(iotoperations.OperationTypeDestination),
},
},
},
ResourceGroupName: pulumi.String("rgiotoperations"),
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperations.Dataflow;
import com.pulumi.azurenative.iotoperations.DataflowArgs;
import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowPropertiesArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var dataflow = new Dataflow("dataflow", DataflowArgs.builder()
.dataflowName("aio-to-event-hub-transformed")
.dataflowProfileName("resource-name123")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowPropertiesArgs.builder()
.mode("Enabled")
.operations(
DataflowOperationArgs.builder()
.name("source1")
.operationType("Source")
.sourceSettings(DataflowSourceOperationSettingsArgs.builder()
.dataSources("azure-iot-operations/data/thermostat")
.endpointRef("aio-builtin-broker-endpoint")
.build())
.build(),
DataflowOperationArgs.builder()
.builtInTransformationSettings(DataflowBuiltInTransformationSettingsArgs.builder()
.filter(DataflowBuiltInTransformationFilterArgs.builder()
.expression("$1 > 9000 && $2 >= 8000")
.inputs(
"temperature.Value",
"\"Tag 10\".Value")
.build())
.map(
DataflowBuiltInTransformationMapArgs.builder()
.inputs("*")
.output("*")
.build(),
DataflowBuiltInTransformationMapArgs.builder()
.expression("($1+$2)/2")
.inputs(
"temperature.Value",
"\"Tag 10\".Value")
.output("AvgTemp.Value")
.build(),
DataflowBuiltInTransformationMapArgs.builder()
.expression("true")
.inputs()
.output("dataflow-processed")
.build(),
DataflowBuiltInTransformationMapArgs.builder()
.expression("")
.inputs("temperature.SourceTimestamp")
.output("")
.build(),
DataflowBuiltInTransformationMapArgs.builder()
.expression("")
.inputs("\"Tag 10\"")
.output("pressure")
.build(),
DataflowBuiltInTransformationMapArgs.builder()
.expression("cToF($1)")
.inputs("temperature.Value")
.output("temperatureF.Value")
.build(),
DataflowBuiltInTransformationMapArgs.builder()
.expression("scale ($1,0,10,0,100)")
.inputs("\"Tag 10\".Value")
.output("\"Scale Tag 10\".Value")
.build())
.build())
.operationType("BuiltInTransformation")
.build(),
DataflowOperationArgs.builder()
.destinationSettings(DataflowDestinationOperationSettingsArgs.builder()
.dataDestination("myuniqueeventhub")
.endpointRef("event-hub-endpoint")
.build())
.name("destination1")
.operationType("Destination")
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflow = new azure_native.iotoperations.Dataflow("dataflow", {
dataflowName: "aio-to-event-hub-transformed",
dataflowProfileName: "resource-name123",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
operations: [
{
name: "source1",
operationType: azure_native.iotoperations.OperationType.Source,
sourceSettings: {
dataSources: ["azure-iot-operations/data/thermostat"],
endpointRef: "aio-builtin-broker-endpoint",
},
},
{
builtInTransformationSettings: {
filter: [{
expression: "$1 > 9000 && $2 >= 8000",
inputs: [
"temperature.Value",
"\"Tag 10\".Value",
],
}],
map: [
{
inputs: ["*"],
output: "*",
},
{
expression: "($1+$2)/2",
inputs: [
"temperature.Value",
"\"Tag 10\".Value",
],
output: "AvgTemp.Value",
},
{
expression: "true",
inputs: [],
output: "dataflow-processed",
},
{
expression: "",
inputs: ["temperature.SourceTimestamp"],
output: "",
},
{
expression: "",
inputs: ["\"Tag 10\""],
output: "pressure",
},
{
expression: "cToF($1)",
inputs: ["temperature.Value"],
output: "temperatureF.Value",
},
{
expression: "scale ($1,0,10,0,100)",
inputs: ["\"Tag 10\".Value"],
output: "\"Scale Tag 10\".Value",
},
],
},
operationType: azure_native.iotoperations.OperationType.BuiltInTransformation,
},
{
destinationSettings: {
dataDestination: "myuniqueeventhub",
endpointRef: "event-hub-endpoint",
},
name: "destination1",
operationType: azure_native.iotoperations.OperationType.Destination,
},
],
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow = azure_native.iotoperations.Dataflow("dataflow",
dataflow_name="aio-to-event-hub-transformed",
dataflow_profile_name="resource-name123",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
"operations": [
{
"name": "source1",
"operation_type": azure_native.iotoperations.OperationType.SOURCE,
"source_settings": {
"data_sources": ["azure-iot-operations/data/thermostat"],
"endpoint_ref": "aio-builtin-broker-endpoint",
},
},
{
"built_in_transformation_settings": {
"filter": [{
"expression": "$1 > 9000 && $2 >= 8000",
"inputs": [
"temperature.Value",
"\"Tag 10\".Value",
],
}],
"map": [
{
"inputs": ["*"],
"output": "*",
},
{
"expression": "($1+$2)/2",
"inputs": [
"temperature.Value",
"\"Tag 10\".Value",
],
"output": "AvgTemp.Value",
},
{
"expression": "true",
"inputs": [],
"output": "dataflow-processed",
},
{
"expression": "",
"inputs": ["temperature.SourceTimestamp"],
"output": "",
},
{
"expression": "",
"inputs": ["\"Tag 10\""],
"output": "pressure",
},
{
"expression": "cToF($1)",
"inputs": ["temperature.Value"],
"output": "temperatureF.Value",
},
{
"expression": "scale ($1,0,10,0,100)",
"inputs": ["\"Tag 10\".Value"],
"output": "\"Scale Tag 10\".Value",
},
],
},
"operation_type": azure_native.iotoperations.OperationType.BUILT_IN_TRANSFORMATION,
},
{
"destination_settings": {
"data_destination": "myuniqueeventhub",
"endpoint_ref": "event-hub-endpoint",
},
"name": "destination1",
"operation_type": azure_native.iotoperations.OperationType.DESTINATION,
},
],
},
resource_group_name="rgiotoperations")
resources:
dataflow:
type: azure-native:iotoperations:Dataflow
properties:
dataflowName: aio-to-event-hub-transformed
dataflowProfileName: resource-name123
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
mode: Enabled
operations:
- name: source1
operationType: Source
sourceSettings:
dataSources:
- azure-iot-operations/data/thermostat
endpointRef: aio-builtin-broker-endpoint
- builtInTransformationSettings:
filter:
- expression: $1 > 9000 && $2 >= 8000
inputs:
- temperature.Value
- '"Tag 10".Value'
map:
- inputs:
- '*'
output: '*'
- expression: ($1+$2)/2
inputs:
- temperature.Value
- '"Tag 10".Value'
output: AvgTemp.Value
- expression: 'true'
inputs: []
output: dataflow-processed
- expression: ""
inputs:
- temperature.SourceTimestamp
output: ""
- expression: ""
inputs:
- '"Tag 10"'
output: pressure
- expression: cToF($1)
inputs:
- temperature.Value
output: temperatureF.Value
- expression: scale ($1,0,10,0,100)
inputs:
- '"Tag 10".Value'
output: '"Scale Tag 10".Value'
operationType: BuiltInTransformation
- destinationSettings:
dataDestination: myuniqueeventhub
endpointRef: event-hub-endpoint
name: destination1
operationType: Destination
resourceGroupName: rgiotoperations
Dataflow_CreateOrUpdate_FilterToTopic
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var dataflow = new AzureNative.IoTOperations.Dataflow("dataflow", new()
{
DataflowName = "mqtt-filter-to-topic",
DataflowProfileName = "resource-name123",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
Operations = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
Name = "source1",
OperationType = AzureNative.IoTOperations.OperationType.Source,
SourceSettings = new AzureNative.IoTOperations.Inputs.DataflowSourceOperationSettingsArgs
{
DataSources = new[]
{
"azure-iot-operations/data/thermostat",
},
EndpointRef = "aio-builtin-broker-endpoint",
},
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
BuiltInTransformationSettings = new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationSettingsArgs
{
Filter = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationFilterArgs
{
Description = "filter-datapoint",
Expression = "$1 > 9000 && $2 >= 8000",
Inputs = new[]
{
"temperature.Value",
"\"Tag 10\".Value",
},
Type = AzureNative.IoTOperations.FilterType.Filter,
},
},
Map = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Inputs = new[]
{
"*",
},
Output = "*",
Type = AzureNative.IoTOperations.DataflowMappingType.PassThrough,
},
},
},
Name = "transformation1",
OperationType = AzureNative.IoTOperations.OperationType.BuiltInTransformation,
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
DestinationSettings = new AzureNative.IoTOperations.Inputs.DataflowDestinationOperationSettingsArgs
{
DataDestination = "data/filtered/thermostat",
EndpointRef = "aio-builtin-broker-endpoint",
},
Name = "destination1",
OperationType = AzureNative.IoTOperations.OperationType.Destination,
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflow(ctx, "dataflow", &iotoperations.DataflowArgs{
DataflowName: pulumi.String("mqtt-filter-to-topic"),
DataflowProfileName: pulumi.String("resource-name123"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
Operations: iotoperations.DataflowOperationArray{
&iotoperations.DataflowOperationArgs{
Name: pulumi.String("source1"),
OperationType: pulumi.String(iotoperations.OperationTypeSource),
SourceSettings: &iotoperations.DataflowSourceOperationSettingsArgs{
DataSources: pulumi.StringArray{
pulumi.String("azure-iot-operations/data/thermostat"),
},
EndpointRef: pulumi.String("aio-builtin-broker-endpoint"),
},
},
&iotoperations.DataflowOperationArgs{
BuiltInTransformationSettings: &iotoperations.DataflowBuiltInTransformationSettingsArgs{
Filter: iotoperations.DataflowBuiltInTransformationFilterArray{
&iotoperations.DataflowBuiltInTransformationFilterArgs{
Description: pulumi.String("filter-datapoint"),
Expression: pulumi.String("$1 > 9000 && $2 >= 8000"),
Inputs: pulumi.StringArray{
pulumi.String("temperature.Value"),
pulumi.String("\"Tag 10\".Value"),
},
Type: pulumi.String(iotoperations.FilterTypeFilter),
},
},
Map: iotoperations.DataflowBuiltInTransformationMapArray{
&iotoperations.DataflowBuiltInTransformationMapArgs{
Inputs: pulumi.StringArray{
pulumi.String("*"),
},
Output: pulumi.String("*"),
Type: pulumi.String(iotoperations.DataflowMappingTypePassThrough),
},
},
},
Name: pulumi.String("transformation1"),
OperationType: pulumi.String(iotoperations.OperationTypeBuiltInTransformation),
},
&iotoperations.DataflowOperationArgs{
DestinationSettings: &iotoperations.DataflowDestinationOperationSettingsArgs{
DataDestination: pulumi.String("data/filtered/thermostat"),
EndpointRef: pulumi.String("aio-builtin-broker-endpoint"),
},
Name: pulumi.String("destination1"),
OperationType: pulumi.String(iotoperations.OperationTypeDestination),
},
},
},
ResourceGroupName: pulumi.String("rgiotoperations"),
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperations.Dataflow;
import com.pulumi.azurenative.iotoperations.DataflowArgs;
import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowPropertiesArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var dataflow = new Dataflow("dataflow", DataflowArgs.builder()
.dataflowName("mqtt-filter-to-topic")
.dataflowProfileName("resource-name123")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowPropertiesArgs.builder()
.mode("Enabled")
.operations(
DataflowOperationArgs.builder()
.name("source1")
.operationType("Source")
.sourceSettings(DataflowSourceOperationSettingsArgs.builder()
.dataSources("azure-iot-operations/data/thermostat")
.endpointRef("aio-builtin-broker-endpoint")
.build())
.build(),
DataflowOperationArgs.builder()
.builtInTransformationSettings(DataflowBuiltInTransformationSettingsArgs.builder()
.filter(DataflowBuiltInTransformationFilterArgs.builder()
.description("filter-datapoint")
.expression("$1 > 9000 && $2 >= 8000")
.inputs(
"temperature.Value",
"\"Tag 10\".Value")
.type("Filter")
.build())
.map(DataflowBuiltInTransformationMapArgs.builder()
.inputs("*")
.output("*")
.type("PassThrough")
.build())
.build())
.name("transformation1")
.operationType("BuiltInTransformation")
.build(),
DataflowOperationArgs.builder()
.destinationSettings(DataflowDestinationOperationSettingsArgs.builder()
.dataDestination("data/filtered/thermostat")
.endpointRef("aio-builtin-broker-endpoint")
.build())
.name("destination1")
.operationType("Destination")
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflow = new azure_native.iotoperations.Dataflow("dataflow", {
dataflowName: "mqtt-filter-to-topic",
dataflowProfileName: "resource-name123",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
operations: [
{
name: "source1",
operationType: azure_native.iotoperations.OperationType.Source,
sourceSettings: {
dataSources: ["azure-iot-operations/data/thermostat"],
endpointRef: "aio-builtin-broker-endpoint",
},
},
{
builtInTransformationSettings: {
filter: [{
description: "filter-datapoint",
expression: "$1 > 9000 && $2 >= 8000",
inputs: [
"temperature.Value",
"\"Tag 10\".Value",
],
type: azure_native.iotoperations.FilterType.Filter,
}],
map: [{
inputs: ["*"],
output: "*",
type: azure_native.iotoperations.DataflowMappingType.PassThrough,
}],
},
name: "transformation1",
operationType: azure_native.iotoperations.OperationType.BuiltInTransformation,
},
{
destinationSettings: {
dataDestination: "data/filtered/thermostat",
endpointRef: "aio-builtin-broker-endpoint",
},
name: "destination1",
operationType: azure_native.iotoperations.OperationType.Destination,
},
],
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow = azure_native.iotoperations.Dataflow("dataflow",
dataflow_name="mqtt-filter-to-topic",
dataflow_profile_name="resource-name123",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
"operations": [
{
"name": "source1",
"operation_type": azure_native.iotoperations.OperationType.SOURCE,
"source_settings": {
"data_sources": ["azure-iot-operations/data/thermostat"],
"endpoint_ref": "aio-builtin-broker-endpoint",
},
},
{
"built_in_transformation_settings": {
"filter": [{
"description": "filter-datapoint",
"expression": "$1 > 9000 && $2 >= 8000",
"inputs": [
"temperature.Value",
"\"Tag 10\".Value",
],
"type": azure_native.iotoperations.FilterType.FILTER,
}],
"map": [{
"inputs": ["*"],
"output": "*",
"type": azure_native.iotoperations.DataflowMappingType.PASS_THROUGH,
}],
},
"name": "transformation1",
"operation_type": azure_native.iotoperations.OperationType.BUILT_IN_TRANSFORMATION,
},
{
"destination_settings": {
"data_destination": "data/filtered/thermostat",
"endpoint_ref": "aio-builtin-broker-endpoint",
},
"name": "destination1",
"operation_type": azure_native.iotoperations.OperationType.DESTINATION,
},
],
},
resource_group_name="rgiotoperations")
resources:
dataflow:
type: azure-native:iotoperations:Dataflow
properties:
dataflowName: mqtt-filter-to-topic
dataflowProfileName: resource-name123
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
mode: Enabled
operations:
- name: source1
operationType: Source
sourceSettings:
dataSources:
- azure-iot-operations/data/thermostat
endpointRef: aio-builtin-broker-endpoint
- builtInTransformationSettings:
filter:
- description: filter-datapoint
expression: $1 > 9000 && $2 >= 8000
inputs:
- temperature.Value
- '"Tag 10".Value'
type: Filter
map:
- inputs:
- '*'
output: '*'
type: PassThrough
name: transformation1
operationType: BuiltInTransformation
- destinationSettings:
dataDestination: data/filtered/thermostat
endpointRef: aio-builtin-broker-endpoint
name: destination1
operationType: Destination
resourceGroupName: rgiotoperations
Dataflow_CreateOrUpdate_SimpleEventGrid
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var dataflow = new AzureNative.IoTOperations.Dataflow("dataflow", new()
{
DataflowName = "aio-to-event-grid",
DataflowProfileName = "resource-name123",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
Operations = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
Name = "source1",
OperationType = AzureNative.IoTOperations.OperationType.Source,
SourceSettings = new AzureNative.IoTOperations.Inputs.DataflowSourceOperationSettingsArgs
{
DataSources = new[]
{
"thermostats/+/telemetry/temperature/#",
},
EndpointRef = "aio-builtin-broker-endpoint",
},
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
DestinationSettings = new AzureNative.IoTOperations.Inputs.DataflowDestinationOperationSettingsArgs
{
DataDestination = "factory/telemetry",
EndpointRef = "event-grid-endpoint",
},
Name = "destination1",
OperationType = AzureNative.IoTOperations.OperationType.Destination,
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflow(ctx, "dataflow", &iotoperations.DataflowArgs{
DataflowName: pulumi.String("aio-to-event-grid"),
DataflowProfileName: pulumi.String("resource-name123"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
Operations: iotoperations.DataflowOperationArray{
&iotoperations.DataflowOperationArgs{
Name: pulumi.String("source1"),
OperationType: pulumi.String(iotoperations.OperationTypeSource),
SourceSettings: &iotoperations.DataflowSourceOperationSettingsArgs{
DataSources: pulumi.StringArray{
pulumi.String("thermostats/+/telemetry/temperature/#"),
},
EndpointRef: pulumi.String("aio-builtin-broker-endpoint"),
},
},
&iotoperations.DataflowOperationArgs{
DestinationSettings: &iotoperations.DataflowDestinationOperationSettingsArgs{
DataDestination: pulumi.String("factory/telemetry"),
EndpointRef: pulumi.String("event-grid-endpoint"),
},
Name: pulumi.String("destination1"),
OperationType: pulumi.String(iotoperations.OperationTypeDestination),
},
},
},
ResourceGroupName: pulumi.String("rgiotoperations"),
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperations.Dataflow;
import com.pulumi.azurenative.iotoperations.DataflowArgs;
import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowPropertiesArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var dataflow = new Dataflow("dataflow", DataflowArgs.builder()
.dataflowName("aio-to-event-grid")
.dataflowProfileName("resource-name123")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowPropertiesArgs.builder()
.mode("Enabled")
.operations(
DataflowOperationArgs.builder()
.name("source1")
.operationType("Source")
.sourceSettings(DataflowSourceOperationSettingsArgs.builder()
.dataSources("thermostats/+/telemetry/temperature/#")
.endpointRef("aio-builtin-broker-endpoint")
.build())
.build(),
DataflowOperationArgs.builder()
.destinationSettings(DataflowDestinationOperationSettingsArgs.builder()
.dataDestination("factory/telemetry")
.endpointRef("event-grid-endpoint")
.build())
.name("destination1")
.operationType("Destination")
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflow = new azure_native.iotoperations.Dataflow("dataflow", {
dataflowName: "aio-to-event-grid",
dataflowProfileName: "resource-name123",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
operations: [
{
name: "source1",
operationType: azure_native.iotoperations.OperationType.Source,
sourceSettings: {
dataSources: ["thermostats/+/telemetry/temperature/#"],
endpointRef: "aio-builtin-broker-endpoint",
},
},
{
destinationSettings: {
dataDestination: "factory/telemetry",
endpointRef: "event-grid-endpoint",
},
name: "destination1",
operationType: azure_native.iotoperations.OperationType.Destination,
},
],
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow = azure_native.iotoperations.Dataflow("dataflow",
dataflow_name="aio-to-event-grid",
dataflow_profile_name="resource-name123",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
"operations": [
{
"name": "source1",
"operation_type": azure_native.iotoperations.OperationType.SOURCE,
"source_settings": {
"data_sources": ["thermostats/+/telemetry/temperature/#"],
"endpoint_ref": "aio-builtin-broker-endpoint",
},
},
{
"destination_settings": {
"data_destination": "factory/telemetry",
"endpoint_ref": "event-grid-endpoint",
},
"name": "destination1",
"operation_type": azure_native.iotoperations.OperationType.DESTINATION,
},
],
},
resource_group_name="rgiotoperations")
resources:
dataflow:
type: azure-native:iotoperations:Dataflow
properties:
dataflowName: aio-to-event-grid
dataflowProfileName: resource-name123
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
mode: Enabled
operations:
- name: source1
operationType: Source
sourceSettings:
dataSources:
- thermostats/+/telemetry/temperature/#
endpointRef: aio-builtin-broker-endpoint
- destinationSettings:
dataDestination: factory/telemetry
endpointRef: event-grid-endpoint
name: destination1
operationType: Destination
resourceGroupName: rgiotoperations
Dataflow_CreateOrUpdate_SimpleFabric
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var dataflow = new AzureNative.IoTOperations.Dataflow("dataflow", new()
{
DataflowName = "aio-to-fabric",
DataflowProfileName = "resource-name123",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
Operations = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
Name = "source1",
OperationType = AzureNative.IoTOperations.OperationType.Source,
SourceSettings = new AzureNative.IoTOperations.Inputs.DataflowSourceOperationSettingsArgs
{
DataSources = new[]
{
"azure-iot-operations/data/thermostat",
},
EndpointRef = "aio-builtin-broker-endpoint",
},
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
BuiltInTransformationSettings = new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationSettingsArgs
{
SchemaRef = "aio-sr://exampleNamespace/exmapleParquetSchema:1.0.0",
SerializationFormat = AzureNative.IoTOperations.TransformationSerializationFormat.Parquet,
},
OperationType = AzureNative.IoTOperations.OperationType.BuiltInTransformation,
},
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
DestinationSettings = new AzureNative.IoTOperations.Inputs.DataflowDestinationOperationSettingsArgs
{
DataDestination = "telemetryTable",
EndpointRef = "fabric-endpoint",
},
Name = "destination1",
OperationType = AzureNative.IoTOperations.OperationType.Destination,
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflow(ctx, "dataflow", &iotoperations.DataflowArgs{
DataflowName: pulumi.String("aio-to-fabric"),
DataflowProfileName: pulumi.String("resource-name123"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
Operations: iotoperations.DataflowOperationArray{
&iotoperations.DataflowOperationArgs{
Name: pulumi.String("source1"),
OperationType: pulumi.String(iotoperations.OperationTypeSource),
SourceSettings: &iotoperations.DataflowSourceOperationSettingsArgs{
DataSources: pulumi.StringArray{
pulumi.String("azure-iot-operations/data/thermostat"),
},
EndpointRef: pulumi.String("aio-builtin-broker-endpoint"),
},
},
&iotoperations.DataflowOperationArgs{
BuiltInTransformationSettings: &iotoperations.DataflowBuiltInTransformationSettingsArgs{
SchemaRef: pulumi.String("aio-sr://exampleNamespace/exmapleParquetSchema:1.0.0"),
SerializationFormat: pulumi.String(iotoperations.TransformationSerializationFormatParquet),
},
OperationType: pulumi.String(iotoperations.OperationTypeBuiltInTransformation),
},
&iotoperations.DataflowOperationArgs{
DestinationSettings: &iotoperations.DataflowDestinationOperationSettingsArgs{
DataDestination: pulumi.String("telemetryTable"),
EndpointRef: pulumi.String("fabric-endpoint"),
},
Name: pulumi.String("destination1"),
OperationType: pulumi.String(iotoperations.OperationTypeDestination),
},
},
},
ResourceGroupName: pulumi.String("rgiotoperations"),
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperations.Dataflow;
import com.pulumi.azurenative.iotoperations.DataflowArgs;
import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowPropertiesArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var dataflow = new Dataflow("dataflow", DataflowArgs.builder()
.dataflowName("aio-to-fabric")
.dataflowProfileName("resource-name123")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowPropertiesArgs.builder()
.mode("Enabled")
.operations(
DataflowOperationArgs.builder()
.name("source1")
.operationType("Source")
.sourceSettings(DataflowSourceOperationSettingsArgs.builder()
.dataSources("azure-iot-operations/data/thermostat")
.endpointRef("aio-builtin-broker-endpoint")
.build())
.build(),
DataflowOperationArgs.builder()
.builtInTransformationSettings(DataflowBuiltInTransformationSettingsArgs.builder()
.schemaRef("aio-sr://exampleNamespace/exmapleParquetSchema:1.0.0")
.serializationFormat("Parquet")
.build())
.operationType("BuiltInTransformation")
.build(),
DataflowOperationArgs.builder()
.destinationSettings(DataflowDestinationOperationSettingsArgs.builder()
.dataDestination("telemetryTable")
.endpointRef("fabric-endpoint")
.build())
.name("destination1")
.operationType("Destination")
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflow = new azure_native.iotoperations.Dataflow("dataflow", {
dataflowName: "aio-to-fabric",
dataflowProfileName: "resource-name123",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
operations: [
{
name: "source1",
operationType: azure_native.iotoperations.OperationType.Source,
sourceSettings: {
dataSources: ["azure-iot-operations/data/thermostat"],
endpointRef: "aio-builtin-broker-endpoint",
},
},
{
builtInTransformationSettings: {
schemaRef: "aio-sr://exampleNamespace/exmapleParquetSchema:1.0.0",
serializationFormat: azure_native.iotoperations.TransformationSerializationFormat.Parquet,
},
operationType: azure_native.iotoperations.OperationType.BuiltInTransformation,
},
{
destinationSettings: {
dataDestination: "telemetryTable",
endpointRef: "fabric-endpoint",
},
name: "destination1",
operationType: azure_native.iotoperations.OperationType.Destination,
},
],
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow = azure_native.iotoperations.Dataflow("dataflow",
dataflow_name="aio-to-fabric",
dataflow_profile_name="resource-name123",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
"operations": [
{
"name": "source1",
"operation_type": azure_native.iotoperations.OperationType.SOURCE,
"source_settings": {
"data_sources": ["azure-iot-operations/data/thermostat"],
"endpoint_ref": "aio-builtin-broker-endpoint",
},
},
{
"built_in_transformation_settings": {
"schema_ref": "aio-sr://exampleNamespace/exmapleParquetSchema:1.0.0",
"serialization_format": azure_native.iotoperations.TransformationSerializationFormat.PARQUET,
},
"operation_type": azure_native.iotoperations.OperationType.BUILT_IN_TRANSFORMATION,
},
{
"destination_settings": {
"data_destination": "telemetryTable",
"endpoint_ref": "fabric-endpoint",
},
"name": "destination1",
"operation_type": azure_native.iotoperations.OperationType.DESTINATION,
},
],
},
resource_group_name="rgiotoperations")
resources:
dataflow:
type: azure-native:iotoperations:Dataflow
properties:
dataflowName: aio-to-fabric
dataflowProfileName: resource-name123
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
mode: Enabled
operations:
- name: source1
operationType: Source
sourceSettings:
dataSources:
- azure-iot-operations/data/thermostat
endpointRef: aio-builtin-broker-endpoint
- builtInTransformationSettings:
schemaRef: aio-sr://exampleNamespace/exmapleParquetSchema:1.0.0
serializationFormat: Parquet
operationType: BuiltInTransformation
- destinationSettings:
dataDestination: telemetryTable
endpointRef: fabric-endpoint
name: destination1
operationType: Destination
resourceGroupName: rgiotoperations
Create Dataflow Resource
Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.
Constructor syntax
new Dataflow(name: string, args: DataflowArgs, opts?: CustomResourceOptions);@overload
def Dataflow(resource_name: str,
args: DataflowArgs,
opts: Optional[ResourceOptions] = None)
@overload
def Dataflow(resource_name: str,
opts: Optional[ResourceOptions] = None,
dataflow_profile_name: Optional[str] = None,
extended_location: Optional[ExtendedLocationArgs] = None,
instance_name: Optional[str] = None,
resource_group_name: Optional[str] = None,
dataflow_name: Optional[str] = None,
properties: Optional[DataflowPropertiesArgs] = None)func NewDataflow(ctx *Context, name string, args DataflowArgs, opts ...ResourceOption) (*Dataflow, error)public Dataflow(string name, DataflowArgs args, CustomResourceOptions? opts = null)
public Dataflow(String name, DataflowArgs args)
public Dataflow(String name, DataflowArgs args, CustomResourceOptions options)
type: azure-native:iotoperations:Dataflow
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.
Parameters
- name string
- The unique name of the resource.
- args DataflowArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- resource_name str
- The unique name of the resource.
- args DataflowArgs
- The arguments to resource properties.
- opts ResourceOptions
- Bag of options to control resource's behavior.
- ctx Context
- Context object for the current deployment.
- name string
- The unique name of the resource.
- args DataflowArgs
- The arguments to resource properties.
- opts ResourceOption
- Bag of options to control resource's behavior.
- name string
- The unique name of the resource.
- args DataflowArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- name String
- The unique name of the resource.
- args DataflowArgs
- The arguments to resource properties.
- options CustomResourceOptions
- Bag of options to control resource's behavior.
Constructor example
The following reference example uses placeholder values for all input properties.
var dataflowResource = new AzureNative.IoTOperations.Dataflow("dataflowResource", new()
{
DataflowProfileName = "string",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "string",
Type = "string",
},
InstanceName = "string",
ResourceGroupName = "string",
DataflowName = "string",
Properties = new AzureNative.IoTOperations.Inputs.DataflowPropertiesArgs
{
Operations = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowOperationArgs
{
OperationType = "string",
BuiltInTransformationSettings = new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationSettingsArgs
{
Datasets = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationDatasetArgs
{
Inputs = new[]
{
"string",
},
Key = "string",
Description = "string",
Expression = "string",
SchemaRef = "string",
},
},
Filter = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationFilterArgs
{
Expression = "string",
Inputs = new[]
{
"string",
},
Description = "string",
Type = "string",
},
},
Map = new[]
{
new AzureNative.IoTOperations.Inputs.DataflowBuiltInTransformationMapArgs
{
Inputs = new[]
{
"string",
},
Output = "string",
Description = "string",
Expression = "string",
Type = "string",
},
},
SchemaRef = "string",
SerializationFormat = "string",
},
DestinationSettings = new AzureNative.IoTOperations.Inputs.DataflowDestinationOperationSettingsArgs
{
DataDestination = "string",
EndpointRef = "string",
},
Name = "string",
SourceSettings = new AzureNative.IoTOperations.Inputs.DataflowSourceOperationSettingsArgs
{
DataSources = new[]
{
"string",
},
EndpointRef = "string",
AssetRef = "string",
SchemaRef = "string",
SerializationFormat = "string",
},
},
},
Mode = "string",
},
});
example, err := iotoperations.NewDataflow(ctx, "dataflowResource", &iotoperations.DataflowArgs{
DataflowProfileName: pulumi.String("string"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("string"),
Type: pulumi.String("string"),
},
InstanceName: pulumi.String("string"),
ResourceGroupName: pulumi.String("string"),
DataflowName: pulumi.String("string"),
Properties: &iotoperations.DataflowPropertiesArgs{
Operations: iotoperations.DataflowOperationArray{
&iotoperations.DataflowOperationArgs{
OperationType: pulumi.String("string"),
BuiltInTransformationSettings: &iotoperations.DataflowBuiltInTransformationSettingsArgs{
Datasets: iotoperations.DataflowBuiltInTransformationDatasetArray{
&iotoperations.DataflowBuiltInTransformationDatasetArgs{
Inputs: pulumi.StringArray{
pulumi.String("string"),
},
Key: pulumi.String("string"),
Description: pulumi.String("string"),
Expression: pulumi.String("string"),
SchemaRef: pulumi.String("string"),
},
},
Filter: iotoperations.DataflowBuiltInTransformationFilterArray{
&iotoperations.DataflowBuiltInTransformationFilterArgs{
Expression: pulumi.String("string"),
Inputs: pulumi.StringArray{
pulumi.String("string"),
},
Description: pulumi.String("string"),
Type: pulumi.String("string"),
},
},
Map: iotoperations.DataflowBuiltInTransformationMapArray{
&iotoperations.DataflowBuiltInTransformationMapArgs{
Inputs: pulumi.StringArray{
pulumi.String("string"),
},
Output: pulumi.String("string"),
Description: pulumi.String("string"),
Expression: pulumi.String("string"),
Type: pulumi.String("string"),
},
},
SchemaRef: pulumi.String("string"),
SerializationFormat: pulumi.String("string"),
},
DestinationSettings: &iotoperations.DataflowDestinationOperationSettingsArgs{
DataDestination: pulumi.String("string"),
EndpointRef: pulumi.String("string"),
},
Name: pulumi.String("string"),
SourceSettings: &iotoperations.DataflowSourceOperationSettingsArgs{
DataSources: pulumi.StringArray{
pulumi.String("string"),
},
EndpointRef: pulumi.String("string"),
AssetRef: pulumi.String("string"),
SchemaRef: pulumi.String("string"),
SerializationFormat: pulumi.String("string"),
},
},
},
Mode: pulumi.String("string"),
},
})
var dataflowResource = new Dataflow("dataflowResource", DataflowArgs.builder()
.dataflowProfileName("string")
.extendedLocation(ExtendedLocationArgs.builder()
.name("string")
.type("string")
.build())
.instanceName("string")
.resourceGroupName("string")
.dataflowName("string")
.properties(DataflowPropertiesArgs.builder()
.operations(DataflowOperationArgs.builder()
.operationType("string")
.builtInTransformationSettings(DataflowBuiltInTransformationSettingsArgs.builder()
.datasets(DataflowBuiltInTransformationDatasetArgs.builder()
.inputs("string")
.key("string")
.description("string")
.expression("string")
.schemaRef("string")
.build())
.filter(DataflowBuiltInTransformationFilterArgs.builder()
.expression("string")
.inputs("string")
.description("string")
.type("string")
.build())
.map(DataflowBuiltInTransformationMapArgs.builder()
.inputs("string")
.output("string")
.description("string")
.expression("string")
.type("string")
.build())
.schemaRef("string")
.serializationFormat("string")
.build())
.destinationSettings(DataflowDestinationOperationSettingsArgs.builder()
.dataDestination("string")
.endpointRef("string")
.build())
.name("string")
.sourceSettings(DataflowSourceOperationSettingsArgs.builder()
.dataSources("string")
.endpointRef("string")
.assetRef("string")
.schemaRef("string")
.serializationFormat("string")
.build())
.build())
.mode("string")
.build())
.build());
dataflow_resource = azure_native.iotoperations.Dataflow("dataflowResource",
dataflow_profile_name="string",
extended_location={
"name": "string",
"type": "string",
},
instance_name="string",
resource_group_name="string",
dataflow_name="string",
properties={
"operations": [{
"operation_type": "string",
"built_in_transformation_settings": {
"datasets": [{
"inputs": ["string"],
"key": "string",
"description": "string",
"expression": "string",
"schema_ref": "string",
}],
"filter": [{
"expression": "string",
"inputs": ["string"],
"description": "string",
"type": "string",
}],
"map": [{
"inputs": ["string"],
"output": "string",
"description": "string",
"expression": "string",
"type": "string",
}],
"schema_ref": "string",
"serialization_format": "string",
},
"destination_settings": {
"data_destination": "string",
"endpoint_ref": "string",
},
"name": "string",
"source_settings": {
"data_sources": ["string"],
"endpoint_ref": "string",
"asset_ref": "string",
"schema_ref": "string",
"serialization_format": "string",
},
}],
"mode": "string",
})
const dataflowResource = new azure_native.iotoperations.Dataflow("dataflowResource", {
dataflowProfileName: "string",
extendedLocation: {
name: "string",
type: "string",
},
instanceName: "string",
resourceGroupName: "string",
dataflowName: "string",
properties: {
operations: [{
operationType: "string",
builtInTransformationSettings: {
datasets: [{
inputs: ["string"],
key: "string",
description: "string",
expression: "string",
schemaRef: "string",
}],
filter: [{
expression: "string",
inputs: ["string"],
description: "string",
type: "string",
}],
map: [{
inputs: ["string"],
output: "string",
description: "string",
expression: "string",
type: "string",
}],
schemaRef: "string",
serializationFormat: "string",
},
destinationSettings: {
dataDestination: "string",
endpointRef: "string",
},
name: "string",
sourceSettings: {
dataSources: ["string"],
endpointRef: "string",
assetRef: "string",
schemaRef: "string",
serializationFormat: "string",
},
}],
mode: "string",
},
});
type: azure-native:iotoperations:Dataflow
properties:
dataflowName: string
dataflowProfileName: string
extendedLocation:
name: string
type: string
instanceName: string
properties:
mode: string
operations:
- builtInTransformationSettings:
datasets:
- description: string
expression: string
inputs:
- string
key: string
schemaRef: string
filter:
- description: string
expression: string
inputs:
- string
type: string
map:
- description: string
expression: string
inputs:
- string
output: string
type: string
schemaRef: string
serializationFormat: string
destinationSettings:
dataDestination: string
endpointRef: string
name: string
operationType: string
sourceSettings:
assetRef: string
dataSources:
- string
endpointRef: string
schemaRef: string
serializationFormat: string
resourceGroupName: string
Dataflow Resource Properties
To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.
Inputs
In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.
The Dataflow resource accepts the following input properties:
- Dataflow
Profile stringName - Name of Instance dataflowProfile resource
- Extended
Location Pulumi.Azure Native. Io TOperations. Inputs. Extended Location - Edge location of the resource.
- Instance
Name string - Name of instance.
- Resource
Group stringName - The name of the resource group. The name is case insensitive.
- Dataflow
Name string - Name of Instance dataflowProfile dataflow resource
- Properties
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Properties - The resource-specific properties for this resource.
- Dataflow
Profile stringName - Name of Instance dataflowProfile resource
- Extended
Location ExtendedLocation Args - Edge location of the resource.
- Instance
Name string - Name of instance.
- Resource
Group stringName - The name of the resource group. The name is case insensitive.
- Dataflow
Name string - Name of Instance dataflowProfile dataflow resource
- Properties
Dataflow
Properties Args - The resource-specific properties for this resource.
- dataflow
Profile StringName - Name of Instance dataflowProfile resource
- extended
Location ExtendedLocation - Edge location of the resource.
- instance
Name String - Name of instance.
- resource
Group StringName - The name of the resource group. The name is case insensitive.
- dataflow
Name String - Name of Instance dataflowProfile dataflow resource
- properties
Dataflow
Properties - The resource-specific properties for this resource.
- dataflow
Profile stringName - Name of Instance dataflowProfile resource
- extended
Location ExtendedLocation - Edge location of the resource.
- instance
Name string - Name of instance.
- resource
Group stringName - The name of the resource group. The name is case insensitive.
- dataflow
Name string - Name of Instance dataflowProfile dataflow resource
- properties
Dataflow
Properties - The resource-specific properties for this resource.
- dataflow_
profile_ strname - Name of Instance dataflowProfile resource
- extended_
location ExtendedLocation Args - Edge location of the resource.
- instance_
name str - Name of instance.
- resource_
group_ strname - The name of the resource group. The name is case insensitive.
- dataflow_
name str - Name of Instance dataflowProfile dataflow resource
- properties
Dataflow
Properties Args - The resource-specific properties for this resource.
- dataflow
Profile StringName - Name of Instance dataflowProfile resource
- extended
Location Property Map - Edge location of the resource.
- instance
Name String - Name of instance.
- resource
Group StringName - The name of the resource group. The name is case insensitive.
- dataflow
Name String - Name of Instance dataflowProfile dataflow resource
- properties Property Map
- The resource-specific properties for this resource.
Outputs
All input properties are implicitly available as output properties. Additionally, the Dataflow resource produces the following output properties:
- Azure
Api stringVersion - The Azure API version of the resource.
- Id string
- The provider-assigned unique ID for this managed resource.
- Name string
- The name of the resource
- System
Data Pulumi.Azure Native. Io TOperations. Outputs. System Data Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- Type string
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- Azure
Api stringVersion - The Azure API version of the resource.
- Id string
- The provider-assigned unique ID for this managed resource.
- Name string
- The name of the resource
- System
Data SystemData Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- Type string
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- azure
Api StringVersion - The Azure API version of the resource.
- id String
- The provider-assigned unique ID for this managed resource.
- name String
- The name of the resource
- system
Data SystemData Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- type String
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- azure
Api stringVersion - The Azure API version of the resource.
- id string
- The provider-assigned unique ID for this managed resource.
- name string
- The name of the resource
- system
Data SystemData Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- type string
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- azure_
api_ strversion - The Azure API version of the resource.
- id str
- The provider-assigned unique ID for this managed resource.
- name str
- The name of the resource
- system_
data SystemData Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- type str
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- azure
Api StringVersion - The Azure API version of the resource.
- id String
- The provider-assigned unique ID for this managed resource.
- name String
- The name of the resource
- system
Data Property Map - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- type String
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
Supporting Types
DataflowBuiltInTransformationDataset, DataflowBuiltInTransformationDatasetArgs
- Inputs List<string>
- List of fields for enriching from the Broker State Store.
- Key string
- The key of the dataset.
- Description string
- A user provided optional description of the dataset.
- Expression string
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- Schema
Ref string - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- Inputs []string
- List of fields for enriching from the Broker State Store.
- Key string
- The key of the dataset.
- Description string
- A user provided optional description of the dataset.
- Expression string
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- Schema
Ref string - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- inputs List<String>
- List of fields for enriching from the Broker State Store.
- key String
- The key of the dataset.
- description String
- A user provided optional description of the dataset.
- expression String
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- schema
Ref String - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- inputs string[]
- List of fields for enriching from the Broker State Store.
- key string
- The key of the dataset.
- description string
- A user provided optional description of the dataset.
- expression string
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- schema
Ref string - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- inputs Sequence[str]
- List of fields for enriching from the Broker State Store.
- key str
- The key of the dataset.
- description str
- A user provided optional description of the dataset.
- expression str
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- schema_
ref str - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- inputs List<String>
- List of fields for enriching from the Broker State Store.
- key String
- The key of the dataset.
- description String
- A user provided optional description of the dataset.
- expression String
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- schema
Ref String - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
DataflowBuiltInTransformationDatasetResponse, DataflowBuiltInTransformationDatasetResponseArgs
- Inputs List<string>
- List of fields for enriching from the Broker State Store.
- Key string
- The key of the dataset.
- Description string
- A user provided optional description of the dataset.
- Expression string
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- Schema
Ref string - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- Inputs []string
- List of fields for enriching from the Broker State Store.
- Key string
- The key of the dataset.
- Description string
- A user provided optional description of the dataset.
- Expression string
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- Schema
Ref string - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- inputs List<String>
- List of fields for enriching from the Broker State Store.
- key String
- The key of the dataset.
- description String
- A user provided optional description of the dataset.
- expression String
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- schema
Ref String - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- inputs string[]
- List of fields for enriching from the Broker State Store.
- key string
- The key of the dataset.
- description string
- A user provided optional description of the dataset.
- expression string
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- schema
Ref string - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- inputs Sequence[str]
- List of fields for enriching from the Broker State Store.
- key str
- The key of the dataset.
- description str
- A user provided optional description of the dataset.
- expression str
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- schema_
ref str - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
- inputs List<String>
- List of fields for enriching from the Broker State Store.
- key String
- The key of the dataset.
- description String
- A user provided optional description of the dataset.
- expression String
- Condition to enrich data from Broker State Store. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- schema
Ref String - The reference to the schema that describes the dataset. Allowed: JSON Schema/draft-7.
DataflowBuiltInTransformationFilter, DataflowBuiltInTransformationFilterArgs
- Expression string
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- Inputs List<string>
- List of fields for filtering in JSON path expression.
- Description string
- A user provided optional description of the filter.
- Type
string | Pulumi.
Azure Native. Io TOperations. Filter Type - The type of dataflow operation.
- Expression string
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- Inputs []string
- List of fields for filtering in JSON path expression.
- Description string
- A user provided optional description of the filter.
- Type
string | Filter
Type - The type of dataflow operation.
- expression String
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- inputs List<String>
- List of fields for filtering in JSON path expression.
- description String
- A user provided optional description of the filter.
- type
String | Filter
Type - The type of dataflow operation.
- expression string
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- inputs string[]
- List of fields for filtering in JSON path expression.
- description string
- A user provided optional description of the filter.
- type
string | Filter
Type - The type of dataflow operation.
- expression str
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- inputs Sequence[str]
- List of fields for filtering in JSON path expression.
- description str
- A user provided optional description of the filter.
- type
str | Filter
Type - The type of dataflow operation.
- expression String
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- inputs List<String>
- List of fields for filtering in JSON path expression.
- description String
- A user provided optional description of the filter.
- type String | "Filter"
- The type of dataflow operation.
DataflowBuiltInTransformationFilterResponse, DataflowBuiltInTransformationFilterResponseArgs
- Expression string
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- Inputs List<string>
- List of fields for filtering in JSON path expression.
- Description string
- A user provided optional description of the filter.
- Type string
- The type of dataflow operation.
- Expression string
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- Inputs []string
- List of fields for filtering in JSON path expression.
- Description string
- A user provided optional description of the filter.
- Type string
- The type of dataflow operation.
- expression String
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- inputs List<String>
- List of fields for filtering in JSON path expression.
- description String
- A user provided optional description of the filter.
- type String
- The type of dataflow operation.
- expression string
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- inputs string[]
- List of fields for filtering in JSON path expression.
- description string
- A user provided optional description of the filter.
- type string
- The type of dataflow operation.
- expression str
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- inputs Sequence[str]
- List of fields for filtering in JSON path expression.
- description str
- A user provided optional description of the filter.
- type str
- The type of dataflow operation.
- expression String
- Condition to filter data. Can reference input fields with {n} where n is the index of the input field starting from 1. Example: $1 < 0 || $1 > $2 (Assuming inputs section $1 and $2 are provided)
- inputs List<String>
- List of fields for filtering in JSON path expression.
- description String
- A user provided optional description of the filter.
- type String
- The type of dataflow operation.
DataflowBuiltInTransformationMap, DataflowBuiltInTransformationMapArgs
- Inputs List<string>
- List of fields for mapping in JSON path expression.
- Output string
- Where and how the input fields to be organized in the output record.
- Description string
- A user provided optional description of the mapping function.
- Expression string
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- Type
string | Pulumi.
Azure Native. Io TOperations. Dataflow Mapping Type - Type of transformation.
- Inputs []string
- List of fields for mapping in JSON path expression.
- Output string
- Where and how the input fields to be organized in the output record.
- Description string
- A user provided optional description of the mapping function.
- Expression string
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- Type
string | Dataflow
Mapping Type - Type of transformation.
- inputs List<String>
- List of fields for mapping in JSON path expression.
- output String
- Where and how the input fields to be organized in the output record.
- description String
- A user provided optional description of the mapping function.
- expression String
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- type
String | Dataflow
Mapping Type - Type of transformation.
- inputs string[]
- List of fields for mapping in JSON path expression.
- output string
- Where and how the input fields to be organized in the output record.
- description string
- A user provided optional description of the mapping function.
- expression string
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- type
string | Dataflow
Mapping Type - Type of transformation.
- inputs Sequence[str]
- List of fields for mapping in JSON path expression.
- output str
- Where and how the input fields to be organized in the output record.
- description str
- A user provided optional description of the mapping function.
- expression str
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- type
str | Dataflow
Mapping Type - Type of transformation.
- inputs List<String>
- List of fields for mapping in JSON path expression.
- output String
- Where and how the input fields to be organized in the output record.
- description String
- A user provided optional description of the mapping function.
- expression String
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- type
String | "New
Properties" | "Rename" | "Compute" | "Pass Through" | "Built In Function" - Type of transformation.
DataflowBuiltInTransformationMapResponse, DataflowBuiltInTransformationMapResponseArgs
- Inputs List<string>
- List of fields for mapping in JSON path expression.
- Output string
- Where and how the input fields to be organized in the output record.
- Description string
- A user provided optional description of the mapping function.
- Expression string
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- Type string
- Type of transformation.
- Inputs []string
- List of fields for mapping in JSON path expression.
- Output string
- Where and how the input fields to be organized in the output record.
- Description string
- A user provided optional description of the mapping function.
- Expression string
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- Type string
- Type of transformation.
- inputs List<String>
- List of fields for mapping in JSON path expression.
- output String
- Where and how the input fields to be organized in the output record.
- description String
- A user provided optional description of the mapping function.
- expression String
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- type String
- Type of transformation.
- inputs string[]
- List of fields for mapping in JSON path expression.
- output string
- Where and how the input fields to be organized in the output record.
- description string
- A user provided optional description of the mapping function.
- expression string
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- type string
- Type of transformation.
- inputs Sequence[str]
- List of fields for mapping in JSON path expression.
- output str
- Where and how the input fields to be organized in the output record.
- description str
- A user provided optional description of the mapping function.
- expression str
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- type str
- Type of transformation.
- inputs List<String>
- List of fields for mapping in JSON path expression.
- output String
- Where and how the input fields to be organized in the output record.
- description String
- A user provided optional description of the mapping function.
- expression String
- Modify the inputs field(s) to the final output field. Example: $1 * 2.2 (Assuming inputs section $1 is provided)
- type String
- Type of transformation.
DataflowBuiltInTransformationSettings, DataflowBuiltInTransformationSettingsArgs
- Datasets
List<Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Built In Transformation Dataset> - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- Filter
List<Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Built In Transformation Filter> - Filters input record or datapoints based on condition.
- Map
List<Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Built In Transformation Map> - Maps input to output message.
- Schema
Ref string - Reference to the schema that describes the output of the transformation.
- Serialization
Format string | Pulumi.Azure Native. Io TOperations. Transformation Serialization Format - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- Datasets
[]Dataflow
Built In Transformation Dataset - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- Filter
[]Dataflow
Built In Transformation Filter - Filters input record or datapoints based on condition.
- Map
[]Dataflow
Built In Transformation Map - Maps input to output message.
- Schema
Ref string - Reference to the schema that describes the output of the transformation.
- Serialization
Format string | TransformationSerialization Format - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- datasets
List<Dataflow
Built In Transformation Dataset> - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- filter
List<Dataflow
Built In Transformation Filter> - Filters input record or datapoints based on condition.
- map
List<Dataflow
Built In Transformation Map> - Maps input to output message.
- schema
Ref String - Reference to the schema that describes the output of the transformation.
- serialization
Format String | TransformationSerialization Format - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- datasets
Dataflow
Built In Transformation Dataset[] - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- filter
Dataflow
Built In Transformation Filter[] - Filters input record or datapoints based on condition.
- map
Dataflow
Built In Transformation Map[] - Maps input to output message.
- schema
Ref string - Reference to the schema that describes the output of the transformation.
- serialization
Format string | TransformationSerialization Format - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- datasets
Sequence[Dataflow
Built In Transformation Dataset] - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- filter
Sequence[Dataflow
Built In Transformation Filter] - Filters input record or datapoints based on condition.
- map
Sequence[Dataflow
Built In Transformation Map] - Maps input to output message.
- schema_
ref str - Reference to the schema that describes the output of the transformation.
- serialization_
format str | TransformationSerialization Format - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- datasets List<Property Map>
- Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- filter List<Property Map>
- Filters input record or datapoints based on condition.
- map List<Property Map>
- Maps input to output message.
- schema
Ref String - Reference to the schema that describes the output of the transformation.
- serialization
Format String | "Delta" | "Json" | "Parquet" - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
DataflowBuiltInTransformationSettingsResponse, DataflowBuiltInTransformationSettingsResponseArgs
- Datasets
List<Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Built In Transformation Dataset Response> - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- Filter
List<Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Built In Transformation Filter Response> - Filters input record or datapoints based on condition.
- Map
List<Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Built In Transformation Map Response> - Maps input to output message.
- Schema
Ref string - Reference to the schema that describes the output of the transformation.
- Serialization
Format string - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- Datasets
[]Dataflow
Built In Transformation Dataset Response - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- Filter
[]Dataflow
Built In Transformation Filter Response - Filters input record or datapoints based on condition.
- Map
[]Dataflow
Built In Transformation Map Response - Maps input to output message.
- Schema
Ref string - Reference to the schema that describes the output of the transformation.
- Serialization
Format string - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- datasets
List<Dataflow
Built In Transformation Dataset Response> - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- filter
List<Dataflow
Built In Transformation Filter Response> - Filters input record or datapoints based on condition.
- map
List<Dataflow
Built In Transformation Map Response> - Maps input to output message.
- schema
Ref String - Reference to the schema that describes the output of the transformation.
- serialization
Format String - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- datasets
Dataflow
Built In Transformation Dataset Response[] - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- filter
Dataflow
Built In Transformation Filter Response[] - Filters input record or datapoints based on condition.
- map
Dataflow
Built In Transformation Map Response[] - Maps input to output message.
- schema
Ref string - Reference to the schema that describes the output of the transformation.
- serialization
Format string - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- datasets
Sequence[Dataflow
Built In Transformation Dataset Response] - Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- filter
Sequence[Dataflow
Built In Transformation Filter Response] - Filters input record or datapoints based on condition.
- map
Sequence[Dataflow
Built In Transformation Map Response] - Maps input to output message.
- schema_
ref str - Reference to the schema that describes the output of the transformation.
- serialization_
format str - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
- datasets List<Property Map>
- Enrich data from Broker State Store. Dataset references a key in Broker State Store.
- filter List<Property Map>
- Filters input record or datapoints based on condition.
- map List<Property Map>
- Maps input to output message.
- schema
Ref String - Reference to the schema that describes the output of the transformation.
- serialization
Format String - Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json
DataflowDestinationOperationSettings, DataflowDestinationOperationSettingsArgs
- Data
Destination string - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- Endpoint
Ref string - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- Data
Destination string - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- Endpoint
Ref string - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- data
Destination String - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- endpoint
Ref String - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- data
Destination string - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- endpoint
Ref string - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- data_
destination str - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- endpoint_
ref str - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- data
Destination String - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- endpoint
Ref String - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
DataflowDestinationOperationSettingsResponse, DataflowDestinationOperationSettingsResponseArgs
- Data
Destination string - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- Endpoint
Ref string - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- Data
Destination string - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- Endpoint
Ref string - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- data
Destination String - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- endpoint
Ref String - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- data
Destination string - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- endpoint
Ref string - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- data_
destination str - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- endpoint_
ref str - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
- data
Destination String - Destination location, can be a topic or table name. Supports dynamic values with $topic, $systemProperties, $userProperties, $payload, $context, and $subscription.
- endpoint
Ref String - Reference to the Endpoint CR. Can be of Broker, Kafka, Fabric, ADLS, ADX type.
DataflowMappingType, DataflowMappingTypeArgs
- New
Properties - NewPropertiesNew Properties type
- Rename
- RenameRename type
- Compute
- ComputeCompute type
- Pass
Through - PassThroughPass-through type
- Built
In Function - BuiltInFunctionBuilt in function type
- Dataflow
Mapping Type New Properties - NewPropertiesNew Properties type
- Dataflow
Mapping Type Rename - RenameRename type
- Dataflow
Mapping Type Compute - ComputeCompute type
- Dataflow
Mapping Type Pass Through - PassThroughPass-through type
- Dataflow
Mapping Type Built In Function - BuiltInFunctionBuilt in function type
- New
Properties - NewPropertiesNew Properties type
- Rename
- RenameRename type
- Compute
- ComputeCompute type
- Pass
Through - PassThroughPass-through type
- Built
In Function - BuiltInFunctionBuilt in function type
- New
Properties - NewPropertiesNew Properties type
- Rename
- RenameRename type
- Compute
- ComputeCompute type
- Pass
Through - PassThroughPass-through type
- Built
In Function - BuiltInFunctionBuilt in function type
- NEW_PROPERTIES
- NewPropertiesNew Properties type
- RENAME
- RenameRename type
- COMPUTE
- ComputeCompute type
- PASS_THROUGH
- PassThroughPass-through type
- BUILT_IN_FUNCTION
- BuiltInFunctionBuilt in function type
- "New
Properties" - NewPropertiesNew Properties type
- "Rename"
- RenameRename type
- "Compute"
- ComputeCompute type
- "Pass
Through" - PassThroughPass-through type
- "Built
In Function" - BuiltInFunctionBuilt in function type
DataflowOperation, DataflowOperationArgs
- Operation
Type string | Pulumi.Azure Native. Io TOperations. Operation Type - Type of operation.
- Built
In Pulumi.Transformation Settings Azure Native. Io TOperations. Inputs. Dataflow Built In Transformation Settings - Built In Transformation configuration.
- Destination
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Destination Operation Settings - Destination configuration.
- Name string
- Optional user provided name of the transformation.
- Source
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Source Operation Settings - Source configuration.
- Operation
Type string | OperationType - Type of operation.
- Built
In DataflowTransformation Settings Built In Transformation Settings - Built In Transformation configuration.
- Destination
Settings DataflowDestination Operation Settings - Destination configuration.
- Name string
- Optional user provided name of the transformation.
- Source
Settings DataflowSource Operation Settings - Source configuration.
- operation
Type String | OperationType - Type of operation.
- built
In DataflowTransformation Settings Built In Transformation Settings - Built In Transformation configuration.
- destination
Settings DataflowDestination Operation Settings - Destination configuration.
- name String
- Optional user provided name of the transformation.
- source
Settings DataflowSource Operation Settings - Source configuration.
- operation
Type string | OperationType - Type of operation.
- built
In DataflowTransformation Settings Built In Transformation Settings - Built In Transformation configuration.
- destination
Settings DataflowDestination Operation Settings - Destination configuration.
- name string
- Optional user provided name of the transformation.
- source
Settings DataflowSource Operation Settings - Source configuration.
- operation_
type str | OperationType - Type of operation.
- built_
in_ Dataflowtransformation_ settings Built In Transformation Settings - Built In Transformation configuration.
- destination_
settings DataflowDestination Operation Settings - Destination configuration.
- name str
- Optional user provided name of the transformation.
- source_
settings DataflowSource Operation Settings - Source configuration.
- operation
Type String | "Source" | "Destination" | "BuiltIn Transformation" - Type of operation.
- built
In Property MapTransformation Settings - Built In Transformation configuration.
- destination
Settings Property Map - Destination configuration.
- name String
- Optional user provided name of the transformation.
- source
Settings Property Map - Source configuration.
DataflowOperationResponse, DataflowOperationResponseArgs
- Operation
Type string - Type of operation.
- Built
In Pulumi.Transformation Settings Azure Native. Io TOperations. Inputs. Dataflow Built In Transformation Settings Response - Built In Transformation configuration.
- Destination
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Destination Operation Settings Response - Destination configuration.
- Name string
- Optional user provided name of the transformation.
- Source
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Source Operation Settings Response - Source configuration.
- Operation
Type string - Type of operation.
- Built
In DataflowTransformation Settings Built In Transformation Settings Response - Built In Transformation configuration.
- Destination
Settings DataflowDestination Operation Settings Response - Destination configuration.
- Name string
- Optional user provided name of the transformation.
- Source
Settings DataflowSource Operation Settings Response - Source configuration.
- operation
Type String - Type of operation.
- built
In DataflowTransformation Settings Built In Transformation Settings Response - Built In Transformation configuration.
- destination
Settings DataflowDestination Operation Settings Response - Destination configuration.
- name String
- Optional user provided name of the transformation.
- source
Settings DataflowSource Operation Settings Response - Source configuration.
- operation
Type string - Type of operation.
- built
In DataflowTransformation Settings Built In Transformation Settings Response - Built In Transformation configuration.
- destination
Settings DataflowDestination Operation Settings Response - Destination configuration.
- name string
- Optional user provided name of the transformation.
- source
Settings DataflowSource Operation Settings Response - Source configuration.
- operation_
type str - Type of operation.
- built_
in_ Dataflowtransformation_ settings Built In Transformation Settings Response - Built In Transformation configuration.
- destination_
settings DataflowDestination Operation Settings Response - Destination configuration.
- name str
- Optional user provided name of the transformation.
- source_
settings DataflowSource Operation Settings Response - Source configuration.
- operation
Type String - Type of operation.
- built
In Property MapTransformation Settings - Built In Transformation configuration.
- destination
Settings Property Map - Destination configuration.
- name String
- Optional user provided name of the transformation.
- source
Settings Property Map - Source configuration.
DataflowProperties, DataflowPropertiesArgs
- Operations
List<Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Operation> - List of operations including source and destination references as well as transformation.
- Mode
string | Pulumi.
Azure Native. Io TOperations. Operational Mode - Mode for Dataflow. Optional; defaults to Enabled.
- Operations
[]Dataflow
Operation - List of operations including source and destination references as well as transformation.
- Mode
string | Operational
Mode - Mode for Dataflow. Optional; defaults to Enabled.
- operations
List<Dataflow
Operation> - List of operations including source and destination references as well as transformation.
- mode
String | Operational
Mode - Mode for Dataflow. Optional; defaults to Enabled.
- operations
Dataflow
Operation[] - List of operations including source and destination references as well as transformation.
- mode
string | Operational
Mode - Mode for Dataflow. Optional; defaults to Enabled.
- operations
Sequence[Dataflow
Operation] - List of operations including source and destination references as well as transformation.
- mode
str | Operational
Mode - Mode for Dataflow. Optional; defaults to Enabled.
- operations List<Property Map>
- List of operations including source and destination references as well as transformation.
- mode String | "Enabled" | "Disabled"
- Mode for Dataflow. Optional; defaults to Enabled.
DataflowPropertiesResponse, DataflowPropertiesResponseArgs
- Operations
List<Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Operation Response> - List of operations including source and destination references as well as transformation.
- Provisioning
State string - The status of the last operation.
- Mode string
- Mode for Dataflow. Optional; defaults to Enabled.
- Operations
[]Dataflow
Operation Response - List of operations including source and destination references as well as transformation.
- Provisioning
State string - The status of the last operation.
- Mode string
- Mode for Dataflow. Optional; defaults to Enabled.
- operations
List<Dataflow
Operation Response> - List of operations including source and destination references as well as transformation.
- provisioning
State String - The status of the last operation.
- mode String
- Mode for Dataflow. Optional; defaults to Enabled.
- operations
Dataflow
Operation Response[] - List of operations including source and destination references as well as transformation.
- provisioning
State string - The status of the last operation.
- mode string
- Mode for Dataflow. Optional; defaults to Enabled.
- operations
Sequence[Dataflow
Operation Response] - List of operations including source and destination references as well as transformation.
- provisioning_
state str - The status of the last operation.
- mode str
- Mode for Dataflow. Optional; defaults to Enabled.
- operations List<Property Map>
- List of operations including source and destination references as well as transformation.
- provisioning
State String - The status of the last operation.
- mode String
- Mode for Dataflow. Optional; defaults to Enabled.
DataflowSourceOperationSettings, DataflowSourceOperationSettingsArgs
- Data
Sources List<string> - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- Endpoint
Ref string - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- Asset
Ref string - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- Schema
Ref string - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- Serialization
Format string | Pulumi.Azure Native. Io TOperations. Source Serialization Format - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- Data
Sources []string - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- Endpoint
Ref string - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- Asset
Ref string - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- Schema
Ref string - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- Serialization
Format string | SourceSerialization Format - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- data
Sources List<String> - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- endpoint
Ref String - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- asset
Ref String - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- schema
Ref String - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- serialization
Format String | SourceSerialization Format - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- data
Sources string[] - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- endpoint
Ref string - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- asset
Ref string - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- schema
Ref string - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- serialization
Format string | SourceSerialization Format - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- data_
sources Sequence[str] - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- endpoint_
ref str - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- asset_
ref str - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- schema_
ref str - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- serialization_
format str | SourceSerialization Format - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- data
Sources List<String> - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- endpoint
Ref String - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- asset
Ref String - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- schema
Ref String - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- serialization
Format String | "Json" - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
DataflowSourceOperationSettingsResponse, DataflowSourceOperationSettingsResponseArgs
- Data
Sources List<string> - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- Endpoint
Ref string - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- Asset
Ref string - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- Schema
Ref string - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- Serialization
Format string - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- Data
Sources []string - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- Endpoint
Ref string - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- Asset
Ref string - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- Schema
Ref string - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- Serialization
Format string - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- data
Sources List<String> - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- endpoint
Ref String - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- asset
Ref String - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- schema
Ref String - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- serialization
Format String - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- data
Sources string[] - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- endpoint
Ref string - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- asset
Ref string - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- schema
Ref string - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- serialization
Format string - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- data_
sources Sequence[str] - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- endpoint_
ref str - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- asset_
ref str - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- schema_
ref str - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- serialization_
format str - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
- data
Sources List<String> - List of source locations. Can be Broker or Kafka topics. Supports wildcards # and +.
- endpoint
Ref String - Reference to the Dataflow Endpoint resource. Can only be of Broker and Kafka type.
- asset
Ref String - Reference to the resource in Azure Device Registry where the data in the endpoint originates from.
- schema
Ref String - Schema CR reference. Data will be deserialized according to the schema, and dropped if it doesn't match.
- serialization
Format String - Content is a JSON Schema. Allowed: JSON Schema/draft-7.
ExtendedLocation, ExtendedLocationArgs
- Name string
- The name of the extended location.
- Type
string | Pulumi.
Azure Native. Io TOperations. Extended Location Type - Type of ExtendedLocation.
- Name string
- The name of the extended location.
- Type
string | Extended
Location Type - Type of ExtendedLocation.
- name String
- The name of the extended location.
- type
String | Extended
Location Type - Type of ExtendedLocation.
- name string
- The name of the extended location.
- type
string | Extended
Location Type - Type of ExtendedLocation.
- name str
- The name of the extended location.
- type
str | Extended
Location Type - Type of ExtendedLocation.
- name String
- The name of the extended location.
- type
String | "Custom
Location" - Type of ExtendedLocation.
ExtendedLocationResponse, ExtendedLocationResponseArgs
ExtendedLocationType, ExtendedLocationTypeArgs
- Custom
Location - CustomLocationCustomLocation type
- Extended
Location Type Custom Location - CustomLocationCustomLocation type
- Custom
Location - CustomLocationCustomLocation type
- Custom
Location - CustomLocationCustomLocation type
- CUSTOM_LOCATION
- CustomLocationCustomLocation type
- "Custom
Location" - CustomLocationCustomLocation type
FilterType, FilterTypeArgs
- Filter
- FilterFilter type
- Filter
Type Filter - FilterFilter type
- Filter
- FilterFilter type
- Filter
- FilterFilter type
- FILTER
- FilterFilter type
- "Filter"
- FilterFilter type
OperationType, OperationTypeArgs
- Source
- SourceDataflow Source Operation
- Destination
- DestinationDataflow Destination Operation
- Built
In Transformation - BuiltInTransformationDataflow BuiltIn Transformation Operation
- Operation
Type Source - SourceDataflow Source Operation
- Operation
Type Destination - DestinationDataflow Destination Operation
- Operation
Type Built In Transformation - BuiltInTransformationDataflow BuiltIn Transformation Operation
- Source
- SourceDataflow Source Operation
- Destination
- DestinationDataflow Destination Operation
- Built
In Transformation - BuiltInTransformationDataflow BuiltIn Transformation Operation
- Source
- SourceDataflow Source Operation
- Destination
- DestinationDataflow Destination Operation
- Built
In Transformation - BuiltInTransformationDataflow BuiltIn Transformation Operation
- SOURCE
- SourceDataflow Source Operation
- DESTINATION
- DestinationDataflow Destination Operation
- BUILT_IN_TRANSFORMATION
- BuiltInTransformationDataflow BuiltIn Transformation Operation
- "Source"
- SourceDataflow Source Operation
- "Destination"
- DestinationDataflow Destination Operation
- "Built
In Transformation" - BuiltInTransformationDataflow BuiltIn Transformation Operation
OperationalMode, OperationalModeArgs
- Enabled
- EnabledEnabled is equivalent to True
- Disabled
- DisabledDisabled is equivalent to False.
- Operational
Mode Enabled - EnabledEnabled is equivalent to True
- Operational
Mode Disabled - DisabledDisabled is equivalent to False.
- Enabled
- EnabledEnabled is equivalent to True
- Disabled
- DisabledDisabled is equivalent to False.
- Enabled
- EnabledEnabled is equivalent to True
- Disabled
- DisabledDisabled is equivalent to False.
- ENABLED
- EnabledEnabled is equivalent to True
- DISABLED
- DisabledDisabled is equivalent to False.
- "Enabled"
- EnabledEnabled is equivalent to True
- "Disabled"
- DisabledDisabled is equivalent to False.
SourceSerializationFormat, SourceSerializationFormatArgs
- Json
- JsonJSON Format
- Source
Serialization Format Json - JsonJSON Format
- Json
- JsonJSON Format
- Json
- JsonJSON Format
- JSON
- JsonJSON Format
- "Json"
- JsonJSON Format
SystemDataResponse, SystemDataResponseArgs
- Created
At string - The timestamp of resource creation (UTC).
- Created
By string - The identity that created the resource.
- Created
By stringType - The type of identity that created the resource.
- Last
Modified stringAt - The timestamp of resource last modification (UTC)
- Last
Modified stringBy - The identity that last modified the resource.
- Last
Modified stringBy Type - The type of identity that last modified the resource.
- Created
At string - The timestamp of resource creation (UTC).
- Created
By string - The identity that created the resource.
- Created
By stringType - The type of identity that created the resource.
- Last
Modified stringAt - The timestamp of resource last modification (UTC)
- Last
Modified stringBy - The identity that last modified the resource.
- Last
Modified stringBy Type - The type of identity that last modified the resource.
- created
At String - The timestamp of resource creation (UTC).
- created
By String - The identity that created the resource.
- created
By StringType - The type of identity that created the resource.
- last
Modified StringAt - The timestamp of resource last modification (UTC)
- last
Modified StringBy - The identity that last modified the resource.
- last
Modified StringBy Type - The type of identity that last modified the resource.
- created
At string - The timestamp of resource creation (UTC).
- created
By string - The identity that created the resource.
- created
By stringType - The type of identity that created the resource.
- last
Modified stringAt - The timestamp of resource last modification (UTC)
- last
Modified stringBy - The identity that last modified the resource.
- last
Modified stringBy Type - The type of identity that last modified the resource.
- created_
at str - The timestamp of resource creation (UTC).
- created_
by str - The identity that created the resource.
- created_
by_ strtype - The type of identity that created the resource.
- last_
modified_ strat - The timestamp of resource last modification (UTC)
- last_
modified_ strby - The identity that last modified the resource.
- last_
modified_ strby_ type - The type of identity that last modified the resource.
- created
At String - The timestamp of resource creation (UTC).
- created
By String - The identity that created the resource.
- created
By StringType - The type of identity that created the resource.
- last
Modified StringAt - The timestamp of resource last modification (UTC)
- last
Modified StringBy - The identity that last modified the resource.
- last
Modified StringBy Type - The type of identity that last modified the resource.
TransformationSerializationFormat, TransformationSerializationFormatArgs
- Delta
- DeltaDelta Format
- Json
- JsonJSON Format
- Parquet
- ParquetParquet Format
- Transformation
Serialization Format Delta - DeltaDelta Format
- Transformation
Serialization Format Json - JsonJSON Format
- Transformation
Serialization Format Parquet - ParquetParquet Format
- Delta
- DeltaDelta Format
- Json
- JsonJSON Format
- Parquet
- ParquetParquet Format
- Delta
- DeltaDelta Format
- Json
- JsonJSON Format
- Parquet
- ParquetParquet Format
- DELTA
- DeltaDelta Format
- JSON
- JsonJSON Format
- PARQUET
- ParquetParquet Format
- "Delta"
- DeltaDelta Format
- "Json"
- JsonJSON Format
- "Parquet"
- ParquetParquet Format
Import
An existing resource can be imported using its type token, name, and identifier, e.g.
$ pulumi import azure-native:iotoperations:Dataflow jxhcpwgfkxqasbexkookvxk /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperations/instances/{instanceName}/dataflowProfiles/{dataflowProfileName}/dataflows/{dataflowName}
To learn more about importing existing cloud resources, see Importing resources.
Package Details
- Repository
- Azure Native pulumi/pulumi-azure-native
- License
- Apache-2.0
This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
Azure Native v3.3.0 published on Monday, Apr 28, 2025 by Pulumi