1. Packages
  2. Azure Native
  3. API Docs
  4. iotoperations
  5. DataFlowEndpoint
This is the latest version of Azure Native. Use the Azure Native v1 docs if using the v1 version of this package.
Azure Native v2.73.0 published on Wednesday, Nov 20, 2024 by Pulumi

azure-native.iotoperations.DataFlowEndpoint

Explore with Pulumi AI

azure-native logo
This is the latest version of Azure Native. Use the Azure Native v1 docs if using the v1 version of this package.
Azure Native v2.73.0 published on Wednesday, Nov 20, 2024 by Pulumi

    Instance dataflowEndpoint resource Azure REST API version: 2024-07-01-preview.

    Example Usage

    DataFlowEndpoint_CreateOrUpdate

    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using AzureNative = Pulumi.AzureNative;
    
    return await Deployment.RunAsync(() => 
    {
        var dataFlowEndpoint = new AzureNative.IoTOperations.DataFlowEndpoint("dataFlowEndpoint", new()
        {
            DataflowEndpointName = "aio-dataflowendpoint",
            ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
            {
                Name = "ycsyubcxttlusbhfdqaynmkaatnbyv",
                Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
            },
            InstanceName = "aio-instance",
            Properties = new AzureNative.IoTOperations.Inputs.DataFlowEndpointPropertiesArgs
            {
                Authentication = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationArgs
                {
                    AccessTokenSecretRef = "tnwgineiasofrjwmpvrpxrvgxesxge",
                    Method = AzureNative.IoTOperations.AuthenticationMethod.SystemAssignedManagedIdentity,
                    SaslSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationSaslArgs
                    {
                        SaslType = AzureNative.IoTOperations.DataFlowEndpointAuthenticationSaslType.Plain,
                        TokenSecretRef = "yveihxxdxfczlnsp",
                    },
                    ServiceAccountTokenSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationServiceAccountTokenArgs
                    {
                        Audience = "jwqprkifp",
                    },
                    SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationSystemAssignedManagedIdentityArgs
                    {
                        Audience = "imuwrt",
                    },
                    UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationUserAssignedManagedIdentityArgs
                    {
                        Audience = "lwqpynroxkgvk",
                        ClientId = "qjwbqdunldmwiknaifmjtdzc",
                        TenantId = "xuhbmockgsjanbccm",
                    },
                    X509CredentialsSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationX509Args
                    {
                        SecretRef = "ginzjdbcaebellwqjwiy",
                    },
                },
                DataExplorerSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointDataExplorerArgs
                {
                    Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
                    {
                        LatencySeconds = 9312,
                        MaxMessages = 9028,
                    },
                    Database = "vlzldgzfnjrenepi",
                    Host = "<cluster>.<region>.kusto.windows.net",
                },
                DataLakeStorageSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointDataLakeStorageArgs
                {
                    Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
                    {
                        LatencySeconds = 9312,
                        MaxMessages = 9028,
                    },
                    Host = "<account>.blob.core.windows.net",
                },
                EndpointType = AzureNative.IoTOperations.EndpointType.DataExplorer,
                FabricOneLakeSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointFabricOneLakeArgs
                {
                    Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
                    {
                        LatencySeconds = 9312,
                        MaxMessages = 9028,
                    },
                    Host = "https://<host>.fabric.microsoft.com",
                    Names = new AzureNative.IoTOperations.Inputs.DataFlowEndpointFabricOneLakeNamesArgs
                    {
                        LakehouseName = "wlkswgqkputd",
                        WorkspaceName = "jpixitkilnnznphuv",
                    },
                    OneLakePathType = AzureNative.IoTOperations.DataFlowEndpointFabricPathType.Files,
                },
                KafkaSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointKafkaArgs
                {
                    Batching = new AzureNative.IoTOperations.Inputs.DataFlowEndpointKafkaBatchingArgs
                    {
                        LatencyMs = 5560,
                        MaxBytes = 2289,
                        MaxMessages = 7908,
                        Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
                    },
                    Compression = AzureNative.IoTOperations.DataFlowEndpointKafkaCompression.None,
                    ConsumerGroupId = "bpihkcqsi",
                    CopyMqttProperties = AzureNative.IoTOperations.OperationalMode.Enabled,
                    Host = "duqkazfangmbwtfnivqmhpxfqigi",
                    KafkaAcks = AzureNative.IoTOperations.DataFlowEndpointKafkaAcks.Zero,
                    PartitionStrategy = AzureNative.IoTOperations.DataFlowEndpointKafkaPartitionStrategy.Default,
                    Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
                    {
                        Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
                        TrustedCaCertificateConfigMapRef = "p",
                    },
                },
                LocalStorageSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointLocalStorageArgs
                {
                    PersistentVolumeClaimRef = "fnswdfocruvmkzqbtfvzhzremdohtv",
                },
                MqttSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointMqttArgs
                {
                    ClientIdPrefix = "vhfupaialczfkrcmo",
                    Host = "lenprkulhttcpqop",
                    KeepAliveSeconds = 0,
                    MaxInflightMessages = 0,
                    Protocol = AzureNative.IoTOperations.BrokerProtocolType.Mqtt,
                    Qos = 1,
                    Retain = AzureNative.IoTOperations.MqttRetainType.Keep,
                    SessionExpirySeconds = 0,
                    Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
                    {
                        Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
                        TrustedCaCertificateConfigMapRef = "p",
                    },
                },
            },
            ResourceGroupName = "rgiotoperations",
        });
    
    });
    
    package main
    
    import (
    	iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v2"
    	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
    )
    
    func main() {
    	pulumi.Run(func(ctx *pulumi.Context) error {
    		_, err := iotoperations.NewDataFlowEndpoint(ctx, "dataFlowEndpoint", &iotoperations.DataFlowEndpointArgs{
    			DataflowEndpointName: pulumi.String("aio-dataflowendpoint"),
    			ExtendedLocation: &iotoperations.ExtendedLocationArgs{
    				Name: pulumi.String("ycsyubcxttlusbhfdqaynmkaatnbyv"),
    				Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
    			},
    			InstanceName: pulumi.String("aio-instance"),
    			Properties: &iotoperations.DataFlowEndpointPropertiesArgs{
    				Authentication: &iotoperations.DataFlowEndpointAuthenticationArgs{
    					AccessTokenSecretRef: pulumi.String("tnwgineiasofrjwmpvrpxrvgxesxge"),
    					Method:               pulumi.String(iotoperations.AuthenticationMethodSystemAssignedManagedIdentity),
    					SaslSettings: &iotoperations.DataFlowEndpointAuthenticationSaslArgs{
    						SaslType:       pulumi.String(iotoperations.DataFlowEndpointAuthenticationSaslTypePlain),
    						TokenSecretRef: pulumi.String("yveihxxdxfczlnsp"),
    					},
    					ServiceAccountTokenSettings: &iotoperations.DataFlowEndpointAuthenticationServiceAccountTokenArgs{
    						Audience: pulumi.String("jwqprkifp"),
    					},
    					SystemAssignedManagedIdentitySettings: &iotoperations.DataFlowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
    						Audience: pulumi.String("imuwrt"),
    					},
    					UserAssignedManagedIdentitySettings: &iotoperations.DataFlowEndpointAuthenticationUserAssignedManagedIdentityArgs{
    						Audience: pulumi.String("lwqpynroxkgvk"),
    						ClientId: pulumi.String("qjwbqdunldmwiknaifmjtdzc"),
    						TenantId: pulumi.String("xuhbmockgsjanbccm"),
    					},
    					X509CredentialsSettings: &iotoperations.DataFlowEndpointAuthenticationX509Args{
    						SecretRef: pulumi.String("ginzjdbcaebellwqjwiy"),
    					},
    				},
    				DataExplorerSettings: &iotoperations.DataFlowEndpointDataExplorerArgs{
    					Batching: &iotoperations.BatchingConfigurationArgs{
    						LatencySeconds: pulumi.Int(9312),
    						MaxMessages:    pulumi.Int(9028),
    					},
    					Database: pulumi.String("vlzldgzfnjrenepi"),
    					Host:     pulumi.String("<cluster>.<region>.kusto.windows.net"),
    				},
    				DataLakeStorageSettings: &iotoperations.DataFlowEndpointDataLakeStorageArgs{
    					Batching: &iotoperations.BatchingConfigurationArgs{
    						LatencySeconds: pulumi.Int(9312),
    						MaxMessages:    pulumi.Int(9028),
    					},
    					Host: pulumi.String("<account>.blob.core.windows.net"),
    				},
    				EndpointType: pulumi.String(iotoperations.EndpointTypeDataExplorer),
    				FabricOneLakeSettings: &iotoperations.DataFlowEndpointFabricOneLakeArgs{
    					Batching: &iotoperations.BatchingConfigurationArgs{
    						LatencySeconds: pulumi.Int(9312),
    						MaxMessages:    pulumi.Int(9028),
    					},
    					Host: pulumi.String("https://<host>.fabric.microsoft.com"),
    					Names: &iotoperations.DataFlowEndpointFabricOneLakeNamesArgs{
    						LakehouseName: pulumi.String("wlkswgqkputd"),
    						WorkspaceName: pulumi.String("jpixitkilnnznphuv"),
    					},
    					OneLakePathType: pulumi.String(iotoperations.DataFlowEndpointFabricPathTypeFiles),
    				},
    				KafkaSettings: &iotoperations.DataFlowEndpointKafkaArgs{
    					Batching: &iotoperations.DataFlowEndpointKafkaBatchingArgs{
    						LatencyMs:   pulumi.Int(5560),
    						MaxBytes:    pulumi.Int(2289),
    						MaxMessages: pulumi.Int(7908),
    						Mode:        pulumi.String(iotoperations.OperationalModeEnabled),
    					},
    					Compression:        pulumi.String(iotoperations.DataFlowEndpointKafkaCompressionNone),
    					ConsumerGroupId:    pulumi.String("bpihkcqsi"),
    					CopyMqttProperties: pulumi.String(iotoperations.OperationalModeEnabled),
    					Host:               pulumi.String("duqkazfangmbwtfnivqmhpxfqigi"),
    					KafkaAcks:          pulumi.String(iotoperations.DataFlowEndpointKafkaAcksZero),
    					PartitionStrategy:  pulumi.String(iotoperations.DataFlowEndpointKafkaPartitionStrategyDefault),
    					Tls: &iotoperations.TlsPropertiesArgs{
    						Mode:                             pulumi.String(iotoperations.OperationalModeEnabled),
    						TrustedCaCertificateConfigMapRef: pulumi.String("p"),
    					},
    				},
    				LocalStorageSettings: &iotoperations.DataFlowEndpointLocalStorageArgs{
    					PersistentVolumeClaimRef: pulumi.String("fnswdfocruvmkzqbtfvzhzremdohtv"),
    				},
    				MqttSettings: &iotoperations.DataFlowEndpointMqttArgs{
    					ClientIdPrefix:       pulumi.String("vhfupaialczfkrcmo"),
    					Host:                 pulumi.String("lenprkulhttcpqop"),
    					KeepAliveSeconds:     pulumi.Int(0),
    					MaxInflightMessages:  pulumi.Int(0),
    					Protocol:             pulumi.String(iotoperations.BrokerProtocolTypeMqtt),
    					Qos:                  pulumi.Int(1),
    					Retain:               pulumi.String(iotoperations.MqttRetainTypeKeep),
    					SessionExpirySeconds: pulumi.Int(0),
    					Tls: &iotoperations.TlsPropertiesArgs{
    						Mode:                             pulumi.String(iotoperations.OperationalModeEnabled),
    						TrustedCaCertificateConfigMapRef: pulumi.String("p"),
    					},
    				},
    			},
    			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.DataFlowEndpoint;
    import com.pulumi.azurenative.iotoperations.DataFlowEndpointArgs;
    import com.pulumi.azurenative.iotoperations.inputs.ExtendedLocationArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointPropertiesArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointAuthenticationArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointAuthenticationSaslArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointAuthenticationServiceAccountTokenArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointAuthenticationSystemAssignedManagedIdentityArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointAuthenticationUserAssignedManagedIdentityArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointAuthenticationX509Args;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointDataExplorerArgs;
    import com.pulumi.azurenative.iotoperations.inputs.BatchingConfigurationArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointDataLakeStorageArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointFabricOneLakeArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointFabricOneLakeNamesArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointKafkaArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointKafkaBatchingArgs;
    import com.pulumi.azurenative.iotoperations.inputs.TlsPropertiesArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointLocalStorageArgs;
    import com.pulumi.azurenative.iotoperations.inputs.DataFlowEndpointMqttArgs;
    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 dataFlowEndpoint = new DataFlowEndpoint("dataFlowEndpoint", DataFlowEndpointArgs.builder()
                .dataflowEndpointName("aio-dataflowendpoint")
                .extendedLocation(ExtendedLocationArgs.builder()
                    .name("ycsyubcxttlusbhfdqaynmkaatnbyv")
                    .type("CustomLocation")
                    .build())
                .instanceName("aio-instance")
                .properties(DataFlowEndpointPropertiesArgs.builder()
                    .authentication(DataFlowEndpointAuthenticationArgs.builder()
                        .accessTokenSecretRef("tnwgineiasofrjwmpvrpxrvgxesxge")
                        .method("SystemAssignedManagedIdentity")
                        .saslSettings(DataFlowEndpointAuthenticationSaslArgs.builder()
                            .saslType("Plain")
                            .tokenSecretRef("yveihxxdxfczlnsp")
                            .build())
                        .serviceAccountTokenSettings(DataFlowEndpointAuthenticationServiceAccountTokenArgs.builder()
                            .audience("jwqprkifp")
                            .build())
                        .systemAssignedManagedIdentitySettings(DataFlowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
                            .audience("imuwrt")
                            .build())
                        .userAssignedManagedIdentitySettings(DataFlowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
                            .audience("lwqpynroxkgvk")
                            .clientId("qjwbqdunldmwiknaifmjtdzc")
                            .tenantId("xuhbmockgsjanbccm")
                            .build())
                        .x509CredentialsSettings(DataFlowEndpointAuthenticationX509Args.builder()
                            .secretRef("ginzjdbcaebellwqjwiy")
                            .build())
                        .build())
                    .dataExplorerSettings(DataFlowEndpointDataExplorerArgs.builder()
                        .batching(BatchingConfigurationArgs.builder()
                            .latencySeconds(9312)
                            .maxMessages(9028)
                            .build())
                        .database("vlzldgzfnjrenepi")
                        .host("<cluster>.<region>.kusto.windows.net")
                        .build())
                    .dataLakeStorageSettings(DataFlowEndpointDataLakeStorageArgs.builder()
                        .batching(BatchingConfigurationArgs.builder()
                            .latencySeconds(9312)
                            .maxMessages(9028)
                            .build())
                        .host("<account>.blob.core.windows.net")
                        .build())
                    .endpointType("DataExplorer")
                    .fabricOneLakeSettings(DataFlowEndpointFabricOneLakeArgs.builder()
                        .batching(BatchingConfigurationArgs.builder()
                            .latencySeconds(9312)
                            .maxMessages(9028)
                            .build())
                        .host("https://<host>.fabric.microsoft.com")
                        .names(DataFlowEndpointFabricOneLakeNamesArgs.builder()
                            .lakehouseName("wlkswgqkputd")
                            .workspaceName("jpixitkilnnznphuv")
                            .build())
                        .oneLakePathType("Files")
                        .build())
                    .kafkaSettings(DataFlowEndpointKafkaArgs.builder()
                        .batching(DataFlowEndpointKafkaBatchingArgs.builder()
                            .latencyMs(5560)
                            .maxBytes(2289)
                            .maxMessages(7908)
                            .mode("Enabled")
                            .build())
                        .compression("None")
                        .consumerGroupId("bpihkcqsi")
                        .copyMqttProperties("Enabled")
                        .host("duqkazfangmbwtfnivqmhpxfqigi")
                        .kafkaAcks("Zero")
                        .partitionStrategy("Default")
                        .tls(TlsPropertiesArgs.builder()
                            .mode("Enabled")
                            .trustedCaCertificateConfigMapRef("p")
                            .build())
                        .build())
                    .localStorageSettings(DataFlowEndpointLocalStorageArgs.builder()
                        .persistentVolumeClaimRef("fnswdfocruvmkzqbtfvzhzremdohtv")
                        .build())
                    .mqttSettings(DataFlowEndpointMqttArgs.builder()
                        .clientIdPrefix("vhfupaialczfkrcmo")
                        .host("lenprkulhttcpqop")
                        .keepAliveSeconds(0)
                        .maxInflightMessages(0)
                        .protocol("Mqtt")
                        .qos(1)
                        .retain("Keep")
                        .sessionExpirySeconds(0)
                        .tls(TlsPropertiesArgs.builder()
                            .mode("Enabled")
                            .trustedCaCertificateConfigMapRef("p")
                            .build())
                        .build())
                    .build())
                .resourceGroupName("rgiotoperations")
                .build());
    
        }
    }
    
    import pulumi
    import pulumi_azure_native as azure_native
    
    data_flow_endpoint = azure_native.iotoperations.DataFlowEndpoint("dataFlowEndpoint",
        dataflow_endpoint_name="aio-dataflowendpoint",
        extended_location={
            "name": "ycsyubcxttlusbhfdqaynmkaatnbyv",
            "type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
        },
        instance_name="aio-instance",
        properties={
            "authentication": {
                "access_token_secret_ref": "tnwgineiasofrjwmpvrpxrvgxesxge",
                "method": azure_native.iotoperations.AuthenticationMethod.SYSTEM_ASSIGNED_MANAGED_IDENTITY,
                "sasl_settings": {
                    "sasl_type": azure_native.iotoperations.DataFlowEndpointAuthenticationSaslType.PLAIN,
                    "token_secret_ref": "yveihxxdxfczlnsp",
                },
                "service_account_token_settings": {
                    "audience": "jwqprkifp",
                },
                "system_assigned_managed_identity_settings": {
                    "audience": "imuwrt",
                },
                "user_assigned_managed_identity_settings": {
                    "audience": "lwqpynroxkgvk",
                    "client_id": "qjwbqdunldmwiknaifmjtdzc",
                    "tenant_id": "xuhbmockgsjanbccm",
                },
                "x509_credentials_settings": {
                    "secret_ref": "ginzjdbcaebellwqjwiy",
                },
            },
            "data_explorer_settings": {
                "batching": {
                    "latency_seconds": 9312,
                    "max_messages": 9028,
                },
                "database": "vlzldgzfnjrenepi",
                "host": "<cluster>.<region>.kusto.windows.net",
            },
            "data_lake_storage_settings": {
                "batching": {
                    "latency_seconds": 9312,
                    "max_messages": 9028,
                },
                "host": "<account>.blob.core.windows.net",
            },
            "endpoint_type": azure_native.iotoperations.EndpointType.DATA_EXPLORER,
            "fabric_one_lake_settings": {
                "batching": {
                    "latency_seconds": 9312,
                    "max_messages": 9028,
                },
                "host": "https://<host>.fabric.microsoft.com",
                "names": {
                    "lakehouse_name": "wlkswgqkputd",
                    "workspace_name": "jpixitkilnnznphuv",
                },
                "one_lake_path_type": azure_native.iotoperations.DataFlowEndpointFabricPathType.FILES,
            },
            "kafka_settings": {
                "batching": {
                    "latency_ms": 5560,
                    "max_bytes": 2289,
                    "max_messages": 7908,
                    "mode": azure_native.iotoperations.OperationalMode.ENABLED,
                },
                "compression": azure_native.iotoperations.DataFlowEndpointKafkaCompression.NONE,
                "consumer_group_id": "bpihkcqsi",
                "copy_mqtt_properties": azure_native.iotoperations.OperationalMode.ENABLED,
                "host": "duqkazfangmbwtfnivqmhpxfqigi",
                "kafka_acks": azure_native.iotoperations.DataFlowEndpointKafkaAcks.ZERO,
                "partition_strategy": azure_native.iotoperations.DataFlowEndpointKafkaPartitionStrategy.DEFAULT,
                "tls": {
                    "mode": azure_native.iotoperations.OperationalMode.ENABLED,
                    "trusted_ca_certificate_config_map_ref": "p",
                },
            },
            "local_storage_settings": {
                "persistent_volume_claim_ref": "fnswdfocruvmkzqbtfvzhzremdohtv",
            },
            "mqtt_settings": {
                "client_id_prefix": "vhfupaialczfkrcmo",
                "host": "lenprkulhttcpqop",
                "keep_alive_seconds": 0,
                "max_inflight_messages": 0,
                "protocol": azure_native.iotoperations.BrokerProtocolType.MQTT,
                "qos": 1,
                "retain": azure_native.iotoperations.MqttRetainType.KEEP,
                "session_expiry_seconds": 0,
                "tls": {
                    "mode": azure_native.iotoperations.OperationalMode.ENABLED,
                    "trusted_ca_certificate_config_map_ref": "p",
                },
            },
        },
        resource_group_name="rgiotoperations")
    
    import * as pulumi from "@pulumi/pulumi";
    import * as azure_native from "@pulumi/azure-native";
    
    const dataFlowEndpoint = new azure_native.iotoperations.DataFlowEndpoint("dataFlowEndpoint", {
        dataflowEndpointName: "aio-dataflowendpoint",
        extendedLocation: {
            name: "ycsyubcxttlusbhfdqaynmkaatnbyv",
            type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
        },
        instanceName: "aio-instance",
        properties: {
            authentication: {
                accessTokenSecretRef: "tnwgineiasofrjwmpvrpxrvgxesxge",
                method: azure_native.iotoperations.AuthenticationMethod.SystemAssignedManagedIdentity,
                saslSettings: {
                    saslType: azure_native.iotoperations.DataFlowEndpointAuthenticationSaslType.Plain,
                    tokenSecretRef: "yveihxxdxfczlnsp",
                },
                serviceAccountTokenSettings: {
                    audience: "jwqprkifp",
                },
                systemAssignedManagedIdentitySettings: {
                    audience: "imuwrt",
                },
                userAssignedManagedIdentitySettings: {
                    audience: "lwqpynroxkgvk",
                    clientId: "qjwbqdunldmwiknaifmjtdzc",
                    tenantId: "xuhbmockgsjanbccm",
                },
                x509CredentialsSettings: {
                    secretRef: "ginzjdbcaebellwqjwiy",
                },
            },
            dataExplorerSettings: {
                batching: {
                    latencySeconds: 9312,
                    maxMessages: 9028,
                },
                database: "vlzldgzfnjrenepi",
                host: "<cluster>.<region>.kusto.windows.net",
            },
            dataLakeStorageSettings: {
                batching: {
                    latencySeconds: 9312,
                    maxMessages: 9028,
                },
                host: "<account>.blob.core.windows.net",
            },
            endpointType: azure_native.iotoperations.EndpointType.DataExplorer,
            fabricOneLakeSettings: {
                batching: {
                    latencySeconds: 9312,
                    maxMessages: 9028,
                },
                host: "https://<host>.fabric.microsoft.com",
                names: {
                    lakehouseName: "wlkswgqkputd",
                    workspaceName: "jpixitkilnnznphuv",
                },
                oneLakePathType: azure_native.iotoperations.DataFlowEndpointFabricPathType.Files,
            },
            kafkaSettings: {
                batching: {
                    latencyMs: 5560,
                    maxBytes: 2289,
                    maxMessages: 7908,
                    mode: azure_native.iotoperations.OperationalMode.Enabled,
                },
                compression: azure_native.iotoperations.DataFlowEndpointKafkaCompression.None,
                consumerGroupId: "bpihkcqsi",
                copyMqttProperties: azure_native.iotoperations.OperationalMode.Enabled,
                host: "duqkazfangmbwtfnivqmhpxfqigi",
                kafkaAcks: azure_native.iotoperations.DataFlowEndpointKafkaAcks.Zero,
                partitionStrategy: azure_native.iotoperations.DataFlowEndpointKafkaPartitionStrategy.Default,
                tls: {
                    mode: azure_native.iotoperations.OperationalMode.Enabled,
                    trustedCaCertificateConfigMapRef: "p",
                },
            },
            localStorageSettings: {
                persistentVolumeClaimRef: "fnswdfocruvmkzqbtfvzhzremdohtv",
            },
            mqttSettings: {
                clientIdPrefix: "vhfupaialczfkrcmo",
                host: "lenprkulhttcpqop",
                keepAliveSeconds: 0,
                maxInflightMessages: 0,
                protocol: azure_native.iotoperations.BrokerProtocolType.Mqtt,
                qos: 1,
                retain: azure_native.iotoperations.MqttRetainType.Keep,
                sessionExpirySeconds: 0,
                tls: {
                    mode: azure_native.iotoperations.OperationalMode.Enabled,
                    trustedCaCertificateConfigMapRef: "p",
                },
            },
        },
        resourceGroupName: "rgiotoperations",
    });
    
    resources:
      dataFlowEndpoint:
        type: azure-native:iotoperations:DataFlowEndpoint
        properties:
          dataflowEndpointName: aio-dataflowendpoint
          extendedLocation:
            name: ycsyubcxttlusbhfdqaynmkaatnbyv
            type: CustomLocation
          instanceName: aio-instance
          properties:
            authentication:
              accessTokenSecretRef: tnwgineiasofrjwmpvrpxrvgxesxge
              method: SystemAssignedManagedIdentity
              saslSettings:
                saslType: Plain
                tokenSecretRef: yveihxxdxfczlnsp
              serviceAccountTokenSettings:
                audience: jwqprkifp
              systemAssignedManagedIdentitySettings:
                audience: imuwrt
              userAssignedManagedIdentitySettings:
                audience: lwqpynroxkgvk
                clientId: qjwbqdunldmwiknaifmjtdzc
                tenantId: xuhbmockgsjanbccm
              x509CredentialsSettings:
                secretRef: ginzjdbcaebellwqjwiy
            dataExplorerSettings:
              batching:
                latencySeconds: 9312
                maxMessages: 9028
              database: vlzldgzfnjrenepi
              host: <cluster>.<region>.kusto.windows.net
            dataLakeStorageSettings:
              batching:
                latencySeconds: 9312
                maxMessages: 9028
              host: <account>.blob.core.windows.net
            endpointType: DataExplorer
            fabricOneLakeSettings:
              batching:
                latencySeconds: 9312
                maxMessages: 9028
              host: https://<host>.fabric.microsoft.com
              names:
                lakehouseName: wlkswgqkputd
                workspaceName: jpixitkilnnznphuv
              oneLakePathType: Files
            kafkaSettings:
              batching:
                latencyMs: 5560
                maxBytes: 2289
                maxMessages: 7908
                mode: Enabled
              compression: None
              consumerGroupId: bpihkcqsi
              copyMqttProperties: Enabled
              host: duqkazfangmbwtfnivqmhpxfqigi
              kafkaAcks: Zero
              partitionStrategy: Default
              tls:
                mode: Enabled
                trustedCaCertificateConfigMapRef: p
            localStorageSettings:
              persistentVolumeClaimRef: fnswdfocruvmkzqbtfvzhzremdohtv
            mqttSettings:
              clientIdPrefix: vhfupaialczfkrcmo
              host: lenprkulhttcpqop
              keepAliveSeconds: 0
              maxInflightMessages: 0
              protocol: Mqtt
              qos: 1
              retain: Keep
              sessionExpirySeconds: 0
              tls:
                mode: Enabled
                trustedCaCertificateConfigMapRef: p
          resourceGroupName: rgiotoperations
    

    Create DataFlowEndpoint Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new DataFlowEndpoint(name: string, args: DataFlowEndpointArgs, opts?: CustomResourceOptions);
    @overload
    def DataFlowEndpoint(resource_name: str,
                         args: DataFlowEndpointArgs,
                         opts: Optional[ResourceOptions] = None)
    
    @overload
    def DataFlowEndpoint(resource_name: str,
                         opts: Optional[ResourceOptions] = None,
                         extended_location: Optional[ExtendedLocationArgs] = None,
                         instance_name: Optional[str] = None,
                         resource_group_name: Optional[str] = None,
                         dataflow_endpoint_name: Optional[str] = None,
                         properties: Optional[DataFlowEndpointPropertiesArgs] = None)
    func NewDataFlowEndpoint(ctx *Context, name string, args DataFlowEndpointArgs, opts ...ResourceOption) (*DataFlowEndpoint, error)
    public DataFlowEndpoint(string name, DataFlowEndpointArgs args, CustomResourceOptions? opts = null)
    public DataFlowEndpoint(String name, DataFlowEndpointArgs args)
    public DataFlowEndpoint(String name, DataFlowEndpointArgs args, CustomResourceOptions options)
    
    type: azure-native:iotoperations:DataFlowEndpoint
    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 DataFlowEndpointArgs
    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 DataFlowEndpointArgs
    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 DataFlowEndpointArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args DataFlowEndpointArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args DataFlowEndpointArgs
    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 dataFlowEndpointResource = new AzureNative.IoTOperations.DataFlowEndpoint("dataFlowEndpointResource", new()
    {
        ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
        {
            Name = "string",
            Type = "string",
        },
        InstanceName = "string",
        ResourceGroupName = "string",
        DataflowEndpointName = "string",
        Properties = new AzureNative.IoTOperations.Inputs.DataFlowEndpointPropertiesArgs
        {
            Authentication = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationArgs
            {
                Method = "string",
                AccessTokenSecretRef = "string",
                SaslSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationSaslArgs
                {
                    SaslType = "string",
                    TokenSecretRef = "string",
                },
                ServiceAccountTokenSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationServiceAccountTokenArgs
                {
                    Audience = "string",
                },
                SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationSystemAssignedManagedIdentityArgs
                {
                    Audience = "string",
                },
                UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationUserAssignedManagedIdentityArgs
                {
                    Audience = "string",
                    ClientId = "string",
                    TenantId = "string",
                },
                X509CredentialsSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationX509Args
                {
                    SecretRef = "string",
                },
            },
            EndpointType = "string",
            DataExplorerSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointDataExplorerArgs
            {
                Database = "string",
                Host = "string",
                Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
                {
                    LatencySeconds = 0,
                    MaxMessages = 0,
                },
            },
            DataLakeStorageSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointDataLakeStorageArgs
            {
                Host = "string",
                Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
                {
                    LatencySeconds = 0,
                    MaxMessages = 0,
                },
            },
            FabricOneLakeSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointFabricOneLakeArgs
            {
                Host = "string",
                Names = new AzureNative.IoTOperations.Inputs.DataFlowEndpointFabricOneLakeNamesArgs
                {
                    LakehouseName = "string",
                    WorkspaceName = "string",
                },
                OneLakePathType = "string",
                Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
                {
                    LatencySeconds = 0,
                    MaxMessages = 0,
                },
            },
            KafkaSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointKafkaArgs
            {
                Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
                {
                    Mode = "string",
                    TrustedCaCertificateConfigMapRef = "string",
                },
                Batching = new AzureNative.IoTOperations.Inputs.DataFlowEndpointKafkaBatchingArgs
                {
                    LatencyMs = 0,
                    MaxBytes = 0,
                    MaxMessages = 0,
                    Mode = "string",
                },
                Compression = "string",
                ConsumerGroupId = "string",
                CopyMqttProperties = "string",
                Host = "string",
                KafkaAcks = "string",
                PartitionStrategy = "string",
            },
            LocalStorageSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointLocalStorageArgs
            {
                PersistentVolumeClaimRef = "string",
            },
            MqttSettings = new AzureNative.IoTOperations.Inputs.DataFlowEndpointMqttArgs
            {
                ClientIdPrefix = "string",
                Host = "string",
                KeepAliveSeconds = 0,
                MaxInflightMessages = 0,
                Protocol = "string",
                Qos = 0,
                Retain = "string",
                SessionExpirySeconds = 0,
                Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
                {
                    Mode = "string",
                    TrustedCaCertificateConfigMapRef = "string",
                },
            },
        },
    });
    
    example, err := iotoperations.NewDataFlowEndpoint(ctx, "dataFlowEndpointResource", &iotoperations.DataFlowEndpointArgs{
    	ExtendedLocation: &iotoperations.ExtendedLocationArgs{
    		Name: pulumi.String("string"),
    		Type: pulumi.String("string"),
    	},
    	InstanceName:         pulumi.String("string"),
    	ResourceGroupName:    pulumi.String("string"),
    	DataflowEndpointName: pulumi.String("string"),
    	Properties: &iotoperations.DataFlowEndpointPropertiesArgs{
    		Authentication: &iotoperations.DataFlowEndpointAuthenticationArgs{
    			Method:               pulumi.String("string"),
    			AccessTokenSecretRef: pulumi.String("string"),
    			SaslSettings: &iotoperations.DataFlowEndpointAuthenticationSaslArgs{
    				SaslType:       pulumi.String("string"),
    				TokenSecretRef: pulumi.String("string"),
    			},
    			ServiceAccountTokenSettings: &iotoperations.DataFlowEndpointAuthenticationServiceAccountTokenArgs{
    				Audience: pulumi.String("string"),
    			},
    			SystemAssignedManagedIdentitySettings: &iotoperations.DataFlowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
    				Audience: pulumi.String("string"),
    			},
    			UserAssignedManagedIdentitySettings: &iotoperations.DataFlowEndpointAuthenticationUserAssignedManagedIdentityArgs{
    				Audience: pulumi.String("string"),
    				ClientId: pulumi.String("string"),
    				TenantId: pulumi.String("string"),
    			},
    			X509CredentialsSettings: &iotoperations.DataFlowEndpointAuthenticationX509Args{
    				SecretRef: pulumi.String("string"),
    			},
    		},
    		EndpointType: pulumi.String("string"),
    		DataExplorerSettings: &iotoperations.DataFlowEndpointDataExplorerArgs{
    			Database: pulumi.String("string"),
    			Host:     pulumi.String("string"),
    			Batching: &iotoperations.BatchingConfigurationArgs{
    				LatencySeconds: pulumi.Int(0),
    				MaxMessages:    pulumi.Int(0),
    			},
    		},
    		DataLakeStorageSettings: &iotoperations.DataFlowEndpointDataLakeStorageArgs{
    			Host: pulumi.String("string"),
    			Batching: &iotoperations.BatchingConfigurationArgs{
    				LatencySeconds: pulumi.Int(0),
    				MaxMessages:    pulumi.Int(0),
    			},
    		},
    		FabricOneLakeSettings: &iotoperations.DataFlowEndpointFabricOneLakeArgs{
    			Host: pulumi.String("string"),
    			Names: &iotoperations.DataFlowEndpointFabricOneLakeNamesArgs{
    				LakehouseName: pulumi.String("string"),
    				WorkspaceName: pulumi.String("string"),
    			},
    			OneLakePathType: pulumi.String("string"),
    			Batching: &iotoperations.BatchingConfigurationArgs{
    				LatencySeconds: pulumi.Int(0),
    				MaxMessages:    pulumi.Int(0),
    			},
    		},
    		KafkaSettings: &iotoperations.DataFlowEndpointKafkaArgs{
    			Tls: &iotoperations.TlsPropertiesArgs{
    				Mode:                             pulumi.String("string"),
    				TrustedCaCertificateConfigMapRef: pulumi.String("string"),
    			},
    			Batching: &iotoperations.DataFlowEndpointKafkaBatchingArgs{
    				LatencyMs:   pulumi.Int(0),
    				MaxBytes:    pulumi.Int(0),
    				MaxMessages: pulumi.Int(0),
    				Mode:        pulumi.String("string"),
    			},
    			Compression:        pulumi.String("string"),
    			ConsumerGroupId:    pulumi.String("string"),
    			CopyMqttProperties: pulumi.String("string"),
    			Host:               pulumi.String("string"),
    			KafkaAcks:          pulumi.String("string"),
    			PartitionStrategy:  pulumi.String("string"),
    		},
    		LocalStorageSettings: &iotoperations.DataFlowEndpointLocalStorageArgs{
    			PersistentVolumeClaimRef: pulumi.String("string"),
    		},
    		MqttSettings: &iotoperations.DataFlowEndpointMqttArgs{
    			ClientIdPrefix:       pulumi.String("string"),
    			Host:                 pulumi.String("string"),
    			KeepAliveSeconds:     pulumi.Int(0),
    			MaxInflightMessages:  pulumi.Int(0),
    			Protocol:             pulumi.String("string"),
    			Qos:                  pulumi.Int(0),
    			Retain:               pulumi.String("string"),
    			SessionExpirySeconds: pulumi.Int(0),
    			Tls: &iotoperations.TlsPropertiesArgs{
    				Mode:                             pulumi.String("string"),
    				TrustedCaCertificateConfigMapRef: pulumi.String("string"),
    			},
    		},
    	},
    })
    
    var dataFlowEndpointResource = new DataFlowEndpoint("dataFlowEndpointResource", DataFlowEndpointArgs.builder()
        .extendedLocation(ExtendedLocationArgs.builder()
            .name("string")
            .type("string")
            .build())
        .instanceName("string")
        .resourceGroupName("string")
        .dataflowEndpointName("string")
        .properties(DataFlowEndpointPropertiesArgs.builder()
            .authentication(DataFlowEndpointAuthenticationArgs.builder()
                .method("string")
                .accessTokenSecretRef("string")
                .saslSettings(DataFlowEndpointAuthenticationSaslArgs.builder()
                    .saslType("string")
                    .tokenSecretRef("string")
                    .build())
                .serviceAccountTokenSettings(DataFlowEndpointAuthenticationServiceAccountTokenArgs.builder()
                    .audience("string")
                    .build())
                .systemAssignedManagedIdentitySettings(DataFlowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
                    .audience("string")
                    .build())
                .userAssignedManagedIdentitySettings(DataFlowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
                    .audience("string")
                    .clientId("string")
                    .tenantId("string")
                    .build())
                .x509CredentialsSettings(DataFlowEndpointAuthenticationX509Args.builder()
                    .secretRef("string")
                    .build())
                .build())
            .endpointType("string")
            .dataExplorerSettings(DataFlowEndpointDataExplorerArgs.builder()
                .database("string")
                .host("string")
                .batching(BatchingConfigurationArgs.builder()
                    .latencySeconds(0)
                    .maxMessages(0)
                    .build())
                .build())
            .dataLakeStorageSettings(DataFlowEndpointDataLakeStorageArgs.builder()
                .host("string")
                .batching(BatchingConfigurationArgs.builder()
                    .latencySeconds(0)
                    .maxMessages(0)
                    .build())
                .build())
            .fabricOneLakeSettings(DataFlowEndpointFabricOneLakeArgs.builder()
                .host("string")
                .names(DataFlowEndpointFabricOneLakeNamesArgs.builder()
                    .lakehouseName("string")
                    .workspaceName("string")
                    .build())
                .oneLakePathType("string")
                .batching(BatchingConfigurationArgs.builder()
                    .latencySeconds(0)
                    .maxMessages(0)
                    .build())
                .build())
            .kafkaSettings(DataFlowEndpointKafkaArgs.builder()
                .tls(TlsPropertiesArgs.builder()
                    .mode("string")
                    .trustedCaCertificateConfigMapRef("string")
                    .build())
                .batching(DataFlowEndpointKafkaBatchingArgs.builder()
                    .latencyMs(0)
                    .maxBytes(0)
                    .maxMessages(0)
                    .mode("string")
                    .build())
                .compression("string")
                .consumerGroupId("string")
                .copyMqttProperties("string")
                .host("string")
                .kafkaAcks("string")
                .partitionStrategy("string")
                .build())
            .localStorageSettings(DataFlowEndpointLocalStorageArgs.builder()
                .persistentVolumeClaimRef("string")
                .build())
            .mqttSettings(DataFlowEndpointMqttArgs.builder()
                .clientIdPrefix("string")
                .host("string")
                .keepAliveSeconds(0)
                .maxInflightMessages(0)
                .protocol("string")
                .qos(0)
                .retain("string")
                .sessionExpirySeconds(0)
                .tls(TlsPropertiesArgs.builder()
                    .mode("string")
                    .trustedCaCertificateConfigMapRef("string")
                    .build())
                .build())
            .build())
        .build());
    
    data_flow_endpoint_resource = azure_native.iotoperations.DataFlowEndpoint("dataFlowEndpointResource",
        extended_location={
            "name": "string",
            "type": "string",
        },
        instance_name="string",
        resource_group_name="string",
        dataflow_endpoint_name="string",
        properties={
            "authentication": {
                "method": "string",
                "access_token_secret_ref": "string",
                "sasl_settings": {
                    "sasl_type": "string",
                    "token_secret_ref": "string",
                },
                "service_account_token_settings": {
                    "audience": "string",
                },
                "system_assigned_managed_identity_settings": {
                    "audience": "string",
                },
                "user_assigned_managed_identity_settings": {
                    "audience": "string",
                    "client_id": "string",
                    "tenant_id": "string",
                },
                "x509_credentials_settings": {
                    "secret_ref": "string",
                },
            },
            "endpoint_type": "string",
            "data_explorer_settings": {
                "database": "string",
                "host": "string",
                "batching": {
                    "latency_seconds": 0,
                    "max_messages": 0,
                },
            },
            "data_lake_storage_settings": {
                "host": "string",
                "batching": {
                    "latency_seconds": 0,
                    "max_messages": 0,
                },
            },
            "fabric_one_lake_settings": {
                "host": "string",
                "names": {
                    "lakehouse_name": "string",
                    "workspace_name": "string",
                },
                "one_lake_path_type": "string",
                "batching": {
                    "latency_seconds": 0,
                    "max_messages": 0,
                },
            },
            "kafka_settings": {
                "tls": {
                    "mode": "string",
                    "trusted_ca_certificate_config_map_ref": "string",
                },
                "batching": {
                    "latency_ms": 0,
                    "max_bytes": 0,
                    "max_messages": 0,
                    "mode": "string",
                },
                "compression": "string",
                "consumer_group_id": "string",
                "copy_mqtt_properties": "string",
                "host": "string",
                "kafka_acks": "string",
                "partition_strategy": "string",
            },
            "local_storage_settings": {
                "persistent_volume_claim_ref": "string",
            },
            "mqtt_settings": {
                "client_id_prefix": "string",
                "host": "string",
                "keep_alive_seconds": 0,
                "max_inflight_messages": 0,
                "protocol": "string",
                "qos": 0,
                "retain": "string",
                "session_expiry_seconds": 0,
                "tls": {
                    "mode": "string",
                    "trusted_ca_certificate_config_map_ref": "string",
                },
            },
        })
    
    const dataFlowEndpointResource = new azure_native.iotoperations.DataFlowEndpoint("dataFlowEndpointResource", {
        extendedLocation: {
            name: "string",
            type: "string",
        },
        instanceName: "string",
        resourceGroupName: "string",
        dataflowEndpointName: "string",
        properties: {
            authentication: {
                method: "string",
                accessTokenSecretRef: "string",
                saslSettings: {
                    saslType: "string",
                    tokenSecretRef: "string",
                },
                serviceAccountTokenSettings: {
                    audience: "string",
                },
                systemAssignedManagedIdentitySettings: {
                    audience: "string",
                },
                userAssignedManagedIdentitySettings: {
                    audience: "string",
                    clientId: "string",
                    tenantId: "string",
                },
                x509CredentialsSettings: {
                    secretRef: "string",
                },
            },
            endpointType: "string",
            dataExplorerSettings: {
                database: "string",
                host: "string",
                batching: {
                    latencySeconds: 0,
                    maxMessages: 0,
                },
            },
            dataLakeStorageSettings: {
                host: "string",
                batching: {
                    latencySeconds: 0,
                    maxMessages: 0,
                },
            },
            fabricOneLakeSettings: {
                host: "string",
                names: {
                    lakehouseName: "string",
                    workspaceName: "string",
                },
                oneLakePathType: "string",
                batching: {
                    latencySeconds: 0,
                    maxMessages: 0,
                },
            },
            kafkaSettings: {
                tls: {
                    mode: "string",
                    trustedCaCertificateConfigMapRef: "string",
                },
                batching: {
                    latencyMs: 0,
                    maxBytes: 0,
                    maxMessages: 0,
                    mode: "string",
                },
                compression: "string",
                consumerGroupId: "string",
                copyMqttProperties: "string",
                host: "string",
                kafkaAcks: "string",
                partitionStrategy: "string",
            },
            localStorageSettings: {
                persistentVolumeClaimRef: "string",
            },
            mqttSettings: {
                clientIdPrefix: "string",
                host: "string",
                keepAliveSeconds: 0,
                maxInflightMessages: 0,
                protocol: "string",
                qos: 0,
                retain: "string",
                sessionExpirySeconds: 0,
                tls: {
                    mode: "string",
                    trustedCaCertificateConfigMapRef: "string",
                },
            },
        },
    });
    
    type: azure-native:iotoperations:DataFlowEndpoint
    properties:
        dataflowEndpointName: string
        extendedLocation:
            name: string
            type: string
        instanceName: string
        properties:
            authentication:
                accessTokenSecretRef: string
                method: string
                saslSettings:
                    saslType: string
                    tokenSecretRef: string
                serviceAccountTokenSettings:
                    audience: string
                systemAssignedManagedIdentitySettings:
                    audience: string
                userAssignedManagedIdentitySettings:
                    audience: string
                    clientId: string
                    tenantId: string
                x509CredentialsSettings:
                    secretRef: string
            dataExplorerSettings:
                batching:
                    latencySeconds: 0
                    maxMessages: 0
                database: string
                host: string
            dataLakeStorageSettings:
                batching:
                    latencySeconds: 0
                    maxMessages: 0
                host: string
            endpointType: string
            fabricOneLakeSettings:
                batching:
                    latencySeconds: 0
                    maxMessages: 0
                host: string
                names:
                    lakehouseName: string
                    workspaceName: string
                oneLakePathType: string
            kafkaSettings:
                batching:
                    latencyMs: 0
                    maxBytes: 0
                    maxMessages: 0
                    mode: string
                compression: string
                consumerGroupId: string
                copyMqttProperties: string
                host: string
                kafkaAcks: string
                partitionStrategy: string
                tls:
                    mode: string
                    trustedCaCertificateConfigMapRef: string
            localStorageSettings:
                persistentVolumeClaimRef: string
            mqttSettings:
                clientIdPrefix: string
                host: string
                keepAliveSeconds: 0
                maxInflightMessages: 0
                protocol: string
                qos: 0
                retain: string
                sessionExpirySeconds: 0
                tls:
                    mode: string
                    trustedCaCertificateConfigMapRef: string
        resourceGroupName: string
    

    DataFlowEndpoint 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 DataFlowEndpoint resource accepts the following input properties:

    ExtendedLocation Pulumi.AzureNative.IoTOperations.Inputs.ExtendedLocation
    Edge location of the resource.
    InstanceName string
    Name of instance.
    ResourceGroupName string
    The name of the resource group. The name is case insensitive.
    DataflowEndpointName string
    Name of Instance dataflowEndpoint resource
    Properties Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointProperties
    The resource-specific properties for this resource.
    ExtendedLocation ExtendedLocationArgs
    Edge location of the resource.
    InstanceName string
    Name of instance.
    ResourceGroupName string
    The name of the resource group. The name is case insensitive.
    DataflowEndpointName string
    Name of Instance dataflowEndpoint resource
    Properties DataFlowEndpointPropertiesArgs
    The resource-specific properties for this resource.
    extendedLocation ExtendedLocation
    Edge location of the resource.
    instanceName String
    Name of instance.
    resourceGroupName String
    The name of the resource group. The name is case insensitive.
    dataflowEndpointName String
    Name of Instance dataflowEndpoint resource
    properties DataFlowEndpointProperties
    The resource-specific properties for this resource.
    extendedLocation ExtendedLocation
    Edge location of the resource.
    instanceName string
    Name of instance.
    resourceGroupName string
    The name of the resource group. The name is case insensitive.
    dataflowEndpointName string
    Name of Instance dataflowEndpoint resource
    properties DataFlowEndpointProperties
    The resource-specific properties for this resource.
    extended_location ExtendedLocationArgs
    Edge location of the resource.
    instance_name str
    Name of instance.
    resource_group_name str
    The name of the resource group. The name is case insensitive.
    dataflow_endpoint_name str
    Name of Instance dataflowEndpoint resource
    properties DataFlowEndpointPropertiesArgs
    The resource-specific properties for this resource.
    extendedLocation Property Map
    Edge location of the resource.
    instanceName String
    Name of instance.
    resourceGroupName String
    The name of the resource group. The name is case insensitive.
    dataflowEndpointName String
    Name of Instance dataflowEndpoint resource
    properties Property Map
    The resource-specific properties for this resource.

    Outputs

    All input properties are implicitly available as output properties. Additionally, the DataFlowEndpoint resource produces the following output properties:

    Id string
    The provider-assigned unique ID for this managed resource.
    Name string
    The name of the resource
    SystemData Pulumi.AzureNative.IoTOperations.Outputs.SystemDataResponse
    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"
    Id string
    The provider-assigned unique ID for this managed resource.
    Name string
    The name of the resource
    SystemData SystemDataResponse
    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"
    id String
    The provider-assigned unique ID for this managed resource.
    name String
    The name of the resource
    systemData SystemDataResponse
    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"
    id string
    The provider-assigned unique ID for this managed resource.
    name string
    The name of the resource
    systemData SystemDataResponse
    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"
    id str
    The provider-assigned unique ID for this managed resource.
    name str
    The name of the resource
    system_data SystemDataResponse
    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"
    id String
    The provider-assigned unique ID for this managed resource.
    name String
    The name of the resource
    systemData 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

    AuthenticationMethod, AuthenticationMethodArgs

    SystemAssignedManagedIdentity
    SystemAssignedManagedIdentitySystemAssignedManagedIdentity Option
    UserAssignedManagedIdentity
    UserAssignedManagedIdentityUserAssignedManagedIdentity Option
    AccessToken
    AccessTokenAccessToken Option
    Sasl
    SaslSasl Option
    X509Credentials
    X509CredentialsX509Credentials Option
    AuthenticationMethodSystemAssignedManagedIdentity
    SystemAssignedManagedIdentitySystemAssignedManagedIdentity Option
    AuthenticationMethodUserAssignedManagedIdentity
    UserAssignedManagedIdentityUserAssignedManagedIdentity Option
    AuthenticationMethodAccessToken
    AccessTokenAccessToken Option
    AuthenticationMethodSasl
    SaslSasl Option
    AuthenticationMethodX509Credentials
    X509CredentialsX509Credentials Option
    SystemAssignedManagedIdentity
    SystemAssignedManagedIdentitySystemAssignedManagedIdentity Option
    UserAssignedManagedIdentity
    UserAssignedManagedIdentityUserAssignedManagedIdentity Option
    AccessToken
    AccessTokenAccessToken Option
    Sasl
    SaslSasl Option
    X509Credentials
    X509CredentialsX509Credentials Option
    SystemAssignedManagedIdentity
    SystemAssignedManagedIdentitySystemAssignedManagedIdentity Option
    UserAssignedManagedIdentity
    UserAssignedManagedIdentityUserAssignedManagedIdentity Option
    AccessToken
    AccessTokenAccessToken Option
    Sasl
    SaslSasl Option
    X509Credentials
    X509CredentialsX509Credentials Option
    SYSTEM_ASSIGNED_MANAGED_IDENTITY
    SystemAssignedManagedIdentitySystemAssignedManagedIdentity Option
    USER_ASSIGNED_MANAGED_IDENTITY
    UserAssignedManagedIdentityUserAssignedManagedIdentity Option
    ACCESS_TOKEN
    AccessTokenAccessToken Option
    SASL
    SaslSasl Option
    X509_CREDENTIALS
    X509CredentialsX509Credentials Option
    "SystemAssignedManagedIdentity"
    SystemAssignedManagedIdentitySystemAssignedManagedIdentity Option
    "UserAssignedManagedIdentity"
    UserAssignedManagedIdentityUserAssignedManagedIdentity Option
    "AccessToken"
    AccessTokenAccessToken Option
    "Sasl"
    SaslSasl Option
    "X509Credentials"
    X509CredentialsX509Credentials Option

    BatchingConfiguration, BatchingConfigurationArgs

    LatencySeconds int
    Batching latency in seconds.
    MaxMessages int
    Maximum number of messages in a batch.
    LatencySeconds int
    Batching latency in seconds.
    MaxMessages int
    Maximum number of messages in a batch.
    latencySeconds Integer
    Batching latency in seconds.
    maxMessages Integer
    Maximum number of messages in a batch.
    latencySeconds number
    Batching latency in seconds.
    maxMessages number
    Maximum number of messages in a batch.
    latency_seconds int
    Batching latency in seconds.
    max_messages int
    Maximum number of messages in a batch.
    latencySeconds Number
    Batching latency in seconds.
    maxMessages Number
    Maximum number of messages in a batch.

    BatchingConfigurationResponse, BatchingConfigurationResponseArgs

    LatencySeconds int
    Batching latency in seconds.
    MaxMessages int
    Maximum number of messages in a batch.
    LatencySeconds int
    Batching latency in seconds.
    MaxMessages int
    Maximum number of messages in a batch.
    latencySeconds Integer
    Batching latency in seconds.
    maxMessages Integer
    Maximum number of messages in a batch.
    latencySeconds number
    Batching latency in seconds.
    maxMessages number
    Maximum number of messages in a batch.
    latency_seconds int
    Batching latency in seconds.
    max_messages int
    Maximum number of messages in a batch.
    latencySeconds Number
    Batching latency in seconds.
    maxMessages Number
    Maximum number of messages in a batch.

    BrokerProtocolType, BrokerProtocolTypeArgs

    Mqtt
    Mqttprotocol broker
    WebSockets
    WebSocketsprotocol websocket
    BrokerProtocolTypeMqtt
    Mqttprotocol broker
    BrokerProtocolTypeWebSockets
    WebSocketsprotocol websocket
    Mqtt
    Mqttprotocol broker
    WebSockets
    WebSocketsprotocol websocket
    Mqtt
    Mqttprotocol broker
    WebSockets
    WebSocketsprotocol websocket
    MQTT
    Mqttprotocol broker
    WEB_SOCKETS
    WebSocketsprotocol websocket
    "Mqtt"
    Mqttprotocol broker
    "WebSockets"
    WebSocketsprotocol websocket

    DataFlowEndpointAuthentication, DataFlowEndpointAuthenticationArgs

    Method string | Pulumi.AzureNative.IoTOperations.AuthenticationMethod
    Mode of Authentication.
    AccessTokenSecretRef string
    SAS token authentication.
    SaslSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationSasl
    SASL authentication.
    ServiceAccountTokenSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationServiceAccountToken
    Service Account Token authentication.
    SystemAssignedManagedIdentitySettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationSystemAssignedManagedIdentity
    System-assigned managed identity authentication.
    UserAssignedManagedIdentitySettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationUserAssignedManagedIdentity
    User-assigned managed identity authentication.
    X509CredentialsSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationX509
    X.509 certificate authentication.
    method String | "SystemAssignedManagedIdentity" | "UserAssignedManagedIdentity" | "AccessToken" | "Sasl" | "X509Credentials"
    Mode of Authentication.
    accessTokenSecretRef String
    SAS token authentication.
    saslSettings Property Map
    SASL authentication.
    serviceAccountTokenSettings Property Map
    Service Account Token authentication.
    systemAssignedManagedIdentitySettings Property Map
    System-assigned managed identity authentication.
    userAssignedManagedIdentitySettings Property Map
    User-assigned managed identity authentication.
    x509CredentialsSettings Property Map
    X.509 certificate authentication.

    DataFlowEndpointAuthenticationResponse, DataFlowEndpointAuthenticationResponseArgs

    Method string
    Mode of Authentication.
    AccessTokenSecretRef string
    SAS token authentication.
    SaslSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationSaslResponse
    SASL authentication.
    ServiceAccountTokenSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationServiceAccountTokenResponse
    Service Account Token authentication.
    SystemAssignedManagedIdentitySettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationSystemAssignedManagedIdentityResponse
    System-assigned managed identity authentication.
    UserAssignedManagedIdentitySettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationUserAssignedManagedIdentityResponse
    User-assigned managed identity authentication.
    X509CredentialsSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationX509Response
    X.509 certificate authentication.
    method String
    Mode of Authentication.
    accessTokenSecretRef String
    SAS token authentication.
    saslSettings Property Map
    SASL authentication.
    serviceAccountTokenSettings Property Map
    Service Account Token authentication.
    systemAssignedManagedIdentitySettings Property Map
    System-assigned managed identity authentication.
    userAssignedManagedIdentitySettings Property Map
    User-assigned managed identity authentication.
    x509CredentialsSettings Property Map
    X.509 certificate authentication.

    DataFlowEndpointAuthenticationSasl, DataFlowEndpointAuthenticationSaslArgs

    SaslType string | Pulumi.AzureNative.IoTOperations.DataFlowEndpointAuthenticationSaslType
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    TokenSecretRef string
    Token secret name.
    SaslType string | DataFlowEndpointAuthenticationSaslType
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    TokenSecretRef string
    Token secret name.
    saslType String | DataFlowEndpointAuthenticationSaslType
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    tokenSecretRef String
    Token secret name.
    saslType string | DataFlowEndpointAuthenticationSaslType
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    tokenSecretRef string
    Token secret name.
    sasl_type str | DataFlowEndpointAuthenticationSaslType
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    token_secret_ref str
    Token secret name.
    saslType String | "Plain" | "ScramSha256" | "ScramSha512"
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    tokenSecretRef String
    Token secret name.

    DataFlowEndpointAuthenticationSaslResponse, DataFlowEndpointAuthenticationSaslResponseArgs

    SaslType string
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    TokenSecretRef string
    Token secret name.
    SaslType string
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    TokenSecretRef string
    Token secret name.
    saslType String
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    tokenSecretRef String
    Token secret name.
    saslType string
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    tokenSecretRef string
    Token secret name.
    sasl_type str
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    token_secret_ref str
    Token secret name.
    saslType String
    Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
    tokenSecretRef String
    Token secret name.

    DataFlowEndpointAuthenticationSaslType, DataFlowEndpointAuthenticationSaslTypeArgs

    Plain
    PlainPLAIN Type
    ScramSha256
    ScramSha256SCRAM_SHA_256 Type
    ScramSha512
    ScramSha512SCRAM_SHA_512 Type
    DataFlowEndpointAuthenticationSaslTypePlain
    PlainPLAIN Type
    DataFlowEndpointAuthenticationSaslTypeScramSha256
    ScramSha256SCRAM_SHA_256 Type
    DataFlowEndpointAuthenticationSaslTypeScramSha512
    ScramSha512SCRAM_SHA_512 Type
    Plain
    PlainPLAIN Type
    ScramSha256
    ScramSha256SCRAM_SHA_256 Type
    ScramSha512
    ScramSha512SCRAM_SHA_512 Type
    Plain
    PlainPLAIN Type
    ScramSha256
    ScramSha256SCRAM_SHA_256 Type
    ScramSha512
    ScramSha512SCRAM_SHA_512 Type
    PLAIN
    PlainPLAIN Type
    SCRAM_SHA256
    ScramSha256SCRAM_SHA_256 Type
    SCRAM_SHA512
    ScramSha512SCRAM_SHA_512 Type
    "Plain"
    PlainPLAIN Type
    "ScramSha256"
    ScramSha256SCRAM_SHA_256 Type
    "ScramSha512"
    ScramSha512SCRAM_SHA_512 Type

    DataFlowEndpointAuthenticationServiceAccountToken, DataFlowEndpointAuthenticationServiceAccountTokenArgs

    Audience string
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    Audience string
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    audience String
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    audience string
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    audience str
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    audience String
    Audience of the service account. Optional, defaults to the broker internal service account audience.

    DataFlowEndpointAuthenticationServiceAccountTokenResponse, DataFlowEndpointAuthenticationServiceAccountTokenResponseArgs

    Audience string
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    Audience string
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    audience String
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    audience string
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    audience str
    Audience of the service account. Optional, defaults to the broker internal service account audience.
    audience String
    Audience of the service account. Optional, defaults to the broker internal service account audience.

    DataFlowEndpointAuthenticationSystemAssignedManagedIdentity, DataFlowEndpointAuthenticationSystemAssignedManagedIdentityArgs

    Audience string
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    Audience string
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    audience String
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    audience string
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    audience str
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    audience String
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.

    DataFlowEndpointAuthenticationSystemAssignedManagedIdentityResponse, DataFlowEndpointAuthenticationSystemAssignedManagedIdentityResponseArgs

    Audience string
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    Audience string
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    audience String
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    audience string
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    audience str
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.
    audience String
    Audience of the service to authenticate against. Optional; defaults to the audience for Service host configuration.

    DataFlowEndpointAuthenticationUserAssignedManagedIdentity, DataFlowEndpointAuthenticationUserAssignedManagedIdentityArgs

    Audience string
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    ClientId string
    Client ID for the user-assigned managed identity.
    TenantId string
    Tenant ID.
    Audience string
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    ClientId string
    Client ID for the user-assigned managed identity.
    TenantId string
    Tenant ID.
    audience String
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    clientId String
    Client ID for the user-assigned managed identity.
    tenantId String
    Tenant ID.
    audience string
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    clientId string
    Client ID for the user-assigned managed identity.
    tenantId string
    Tenant ID.
    audience str
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    client_id str
    Client ID for the user-assigned managed identity.
    tenant_id str
    Tenant ID.
    audience String
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    clientId String
    Client ID for the user-assigned managed identity.
    tenantId String
    Tenant ID.

    DataFlowEndpointAuthenticationUserAssignedManagedIdentityResponse, DataFlowEndpointAuthenticationUserAssignedManagedIdentityResponseArgs

    Audience string
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    ClientId string
    Client ID for the user-assigned managed identity.
    TenantId string
    Tenant ID.
    Audience string
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    ClientId string
    Client ID for the user-assigned managed identity.
    TenantId string
    Tenant ID.
    audience String
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    clientId String
    Client ID for the user-assigned managed identity.
    tenantId String
    Tenant ID.
    audience string
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    clientId string
    Client ID for the user-assigned managed identity.
    tenantId string
    Tenant ID.
    audience str
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    client_id str
    Client ID for the user-assigned managed identity.
    tenant_id str
    Tenant ID.
    audience String
    Resource identifier (application ID URI) of the resource, affixed with the .default suffix.
    clientId String
    Client ID for the user-assigned managed identity.
    tenantId String
    Tenant ID.

    DataFlowEndpointAuthenticationX509, DataFlowEndpointAuthenticationX509Args

    SecretRef string
    Secret reference of the X.509 certificate.
    SecretRef string
    Secret reference of the X.509 certificate.
    secretRef String
    Secret reference of the X.509 certificate.
    secretRef string
    Secret reference of the X.509 certificate.
    secret_ref str
    Secret reference of the X.509 certificate.
    secretRef String
    Secret reference of the X.509 certificate.

    DataFlowEndpointAuthenticationX509Response, DataFlowEndpointAuthenticationX509ResponseArgs

    SecretRef string
    Secret reference of the X.509 certificate.
    SecretRef string
    Secret reference of the X.509 certificate.
    secretRef String
    Secret reference of the X.509 certificate.
    secretRef string
    Secret reference of the X.509 certificate.
    secret_ref str
    Secret reference of the X.509 certificate.
    secretRef String
    Secret reference of the X.509 certificate.

    DataFlowEndpointDataExplorer, DataFlowEndpointDataExplorerArgs

    Database string
    Database name.
    Host string
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    Batching Pulumi.AzureNative.IoTOperations.Inputs.BatchingConfiguration
    Azure Data Explorer endpoint batching configuration.
    Database string
    Database name.
    Host string
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    Batching BatchingConfiguration
    Azure Data Explorer endpoint batching configuration.
    database String
    Database name.
    host String
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    batching BatchingConfiguration
    Azure Data Explorer endpoint batching configuration.
    database string
    Database name.
    host string
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    batching BatchingConfiguration
    Azure Data Explorer endpoint batching configuration.
    database str
    Database name.
    host str
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    batching BatchingConfiguration
    Azure Data Explorer endpoint batching configuration.
    database String
    Database name.
    host String
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    batching Property Map
    Azure Data Explorer endpoint batching configuration.

    DataFlowEndpointDataExplorerResponse, DataFlowEndpointDataExplorerResponseArgs

    Database string
    Database name.
    Host string
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    Batching Pulumi.AzureNative.IoTOperations.Inputs.BatchingConfigurationResponse
    Azure Data Explorer endpoint batching configuration.
    Database string
    Database name.
    Host string
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    Batching BatchingConfigurationResponse
    Azure Data Explorer endpoint batching configuration.
    database String
    Database name.
    host String
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    batching BatchingConfigurationResponse
    Azure Data Explorer endpoint batching configuration.
    database string
    Database name.
    host string
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    batching BatchingConfigurationResponse
    Azure Data Explorer endpoint batching configuration.
    database str
    Database name.
    host str
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    batching BatchingConfigurationResponse
    Azure Data Explorer endpoint batching configuration.
    database String
    Database name.
    host String
    Host of the Azure Data Explorer in the form of ..kusto.windows.net .
    batching Property Map
    Azure Data Explorer endpoint batching configuration.

    DataFlowEndpointDataLakeStorage, DataFlowEndpointDataLakeStorageArgs

    Host string
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    Batching Pulumi.AzureNative.IoTOperations.Inputs.BatchingConfiguration
    Azure Data Lake endpoint batching configuration.
    Host string
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    Batching BatchingConfiguration
    Azure Data Lake endpoint batching configuration.
    host String
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    batching BatchingConfiguration
    Azure Data Lake endpoint batching configuration.
    host string
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    batching BatchingConfiguration
    Azure Data Lake endpoint batching configuration.
    host str
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    batching BatchingConfiguration
    Azure Data Lake endpoint batching configuration.
    host String
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    batching Property Map
    Azure Data Lake endpoint batching configuration.

    DataFlowEndpointDataLakeStorageResponse, DataFlowEndpointDataLakeStorageResponseArgs

    Host string
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    Batching Pulumi.AzureNative.IoTOperations.Inputs.BatchingConfigurationResponse
    Azure Data Lake endpoint batching configuration.
    Host string
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    Batching BatchingConfigurationResponse
    Azure Data Lake endpoint batching configuration.
    host String
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    batching BatchingConfigurationResponse
    Azure Data Lake endpoint batching configuration.
    host string
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    batching BatchingConfigurationResponse
    Azure Data Lake endpoint batching configuration.
    host str
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    batching BatchingConfigurationResponse
    Azure Data Lake endpoint batching configuration.
    host String
    Host of the Azure Data Lake in the form of .blob.core.windows.net .
    batching Property Map
    Azure Data Lake endpoint batching configuration.

    DataFlowEndpointFabricOneLake, DataFlowEndpointFabricOneLakeArgs

    Host string
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    Names Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointFabricOneLakeNames
    Names of the workspace and lakehouse.
    OneLakePathType string | Pulumi.AzureNative.IoTOperations.DataFlowEndpointFabricPathType
    Type of location of the data in the workspace. Can be either tables or files.
    Batching Pulumi.AzureNative.IoTOperations.Inputs.BatchingConfiguration
    Batching configuration.
    Host string
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    Names DataFlowEndpointFabricOneLakeNames
    Names of the workspace and lakehouse.
    OneLakePathType string | DataFlowEndpointFabricPathType
    Type of location of the data in the workspace. Can be either tables or files.
    Batching BatchingConfiguration
    Batching configuration.
    host String
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    names DataFlowEndpointFabricOneLakeNames
    Names of the workspace and lakehouse.
    oneLakePathType String | DataFlowEndpointFabricPathType
    Type of location of the data in the workspace. Can be either tables or files.
    batching BatchingConfiguration
    Batching configuration.
    host string
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    names DataFlowEndpointFabricOneLakeNames
    Names of the workspace and lakehouse.
    oneLakePathType string | DataFlowEndpointFabricPathType
    Type of location of the data in the workspace. Can be either tables or files.
    batching BatchingConfiguration
    Batching configuration.
    host str
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    names DataFlowEndpointFabricOneLakeNames
    Names of the workspace and lakehouse.
    one_lake_path_type str | DataFlowEndpointFabricPathType
    Type of location of the data in the workspace. Can be either tables or files.
    batching BatchingConfiguration
    Batching configuration.
    host String
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    names Property Map
    Names of the workspace and lakehouse.
    oneLakePathType String | "Files" | "Tables"
    Type of location of the data in the workspace. Can be either tables or files.
    batching Property Map
    Batching configuration.

    DataFlowEndpointFabricOneLakeNames, DataFlowEndpointFabricOneLakeNamesArgs

    LakehouseName string
    Lakehouse name.
    WorkspaceName string
    Workspace name.
    LakehouseName string
    Lakehouse name.
    WorkspaceName string
    Workspace name.
    lakehouseName String
    Lakehouse name.
    workspaceName String
    Workspace name.
    lakehouseName string
    Lakehouse name.
    workspaceName string
    Workspace name.
    lakehouse_name str
    Lakehouse name.
    workspace_name str
    Workspace name.
    lakehouseName String
    Lakehouse name.
    workspaceName String
    Workspace name.

    DataFlowEndpointFabricOneLakeNamesResponse, DataFlowEndpointFabricOneLakeNamesResponseArgs

    LakehouseName string
    Lakehouse name.
    WorkspaceName string
    Workspace name.
    LakehouseName string
    Lakehouse name.
    WorkspaceName string
    Workspace name.
    lakehouseName String
    Lakehouse name.
    workspaceName String
    Workspace name.
    lakehouseName string
    Lakehouse name.
    workspaceName string
    Workspace name.
    lakehouse_name str
    Lakehouse name.
    workspace_name str
    Workspace name.
    lakehouseName String
    Lakehouse name.
    workspaceName String
    Workspace name.

    DataFlowEndpointFabricOneLakeResponse, DataFlowEndpointFabricOneLakeResponseArgs

    Host string
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    Names Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointFabricOneLakeNamesResponse
    Names of the workspace and lakehouse.
    OneLakePathType string
    Type of location of the data in the workspace. Can be either tables or files.
    Batching Pulumi.AzureNative.IoTOperations.Inputs.BatchingConfigurationResponse
    Batching configuration.
    Host string
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    Names DataFlowEndpointFabricOneLakeNamesResponse
    Names of the workspace and lakehouse.
    OneLakePathType string
    Type of location of the data in the workspace. Can be either tables or files.
    Batching BatchingConfigurationResponse
    Batching configuration.
    host String
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    names DataFlowEndpointFabricOneLakeNamesResponse
    Names of the workspace and lakehouse.
    oneLakePathType String
    Type of location of the data in the workspace. Can be either tables or files.
    batching BatchingConfigurationResponse
    Batching configuration.
    host string
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    names DataFlowEndpointFabricOneLakeNamesResponse
    Names of the workspace and lakehouse.
    oneLakePathType string
    Type of location of the data in the workspace. Can be either tables or files.
    batching BatchingConfigurationResponse
    Batching configuration.
    host str
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    names DataFlowEndpointFabricOneLakeNamesResponse
    Names of the workspace and lakehouse.
    one_lake_path_type str
    Type of location of the data in the workspace. Can be either tables or files.
    batching BatchingConfigurationResponse
    Batching configuration.
    host String
    Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
    names Property Map
    Names of the workspace and lakehouse.
    oneLakePathType String
    Type of location of the data in the workspace. Can be either tables or files.
    batching Property Map
    Batching configuration.

    DataFlowEndpointFabricPathType, DataFlowEndpointFabricPathTypeArgs

    Files
    FilesFILES Type
    Tables
    TablesTABLES Type
    DataFlowEndpointFabricPathTypeFiles
    FilesFILES Type
    DataFlowEndpointFabricPathTypeTables
    TablesTABLES Type
    Files
    FilesFILES Type
    Tables
    TablesTABLES Type
    Files
    FilesFILES Type
    Tables
    TablesTABLES Type
    FILES
    FilesFILES Type
    TABLES
    TablesTABLES Type
    "Files"
    FilesFILES Type
    "Tables"
    TablesTABLES Type

    DataFlowEndpointKafka, DataFlowEndpointKafkaArgs

    Tls Pulumi.AzureNative.IoTOperations.Inputs.TlsProperties
    TLS configuration.
    Batching Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointKafkaBatching
    Batching configuration.
    Compression string | Pulumi.AzureNative.IoTOperations.DataFlowEndpointKafkaCompression
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    ConsumerGroupId string
    Consumer group ID.
    CopyMqttProperties string | Pulumi.AzureNative.IoTOperations.OperationalMode
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    Host string
    Kafka endpoint host.
    KafkaAcks string | Pulumi.AzureNative.IoTOperations.DataFlowEndpointKafkaAcks
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    PartitionStrategy string | Pulumi.AzureNative.IoTOperations.DataFlowEndpointKafkaPartitionStrategy
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    Tls TlsProperties
    TLS configuration.
    Batching DataFlowEndpointKafkaBatching
    Batching configuration.
    Compression string | DataFlowEndpointKafkaCompression
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    ConsumerGroupId string
    Consumer group ID.
    CopyMqttProperties string | OperationalMode
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    Host string
    Kafka endpoint host.
    KafkaAcks string | DataFlowEndpointKafkaAcks
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    PartitionStrategy string | DataFlowEndpointKafkaPartitionStrategy
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    tls TlsProperties
    TLS configuration.
    batching DataFlowEndpointKafkaBatching
    Batching configuration.
    compression String | DataFlowEndpointKafkaCompression
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    consumerGroupId String
    Consumer group ID.
    copyMqttProperties String | OperationalMode
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    host String
    Kafka endpoint host.
    kafkaAcks String | DataFlowEndpointKafkaAcks
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    partitionStrategy String | DataFlowEndpointKafkaPartitionStrategy
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    tls TlsProperties
    TLS configuration.
    batching DataFlowEndpointKafkaBatching
    Batching configuration.
    compression string | DataFlowEndpointKafkaCompression
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    consumerGroupId string
    Consumer group ID.
    copyMqttProperties string | OperationalMode
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    host string
    Kafka endpoint host.
    kafkaAcks string | DataFlowEndpointKafkaAcks
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    partitionStrategy string | DataFlowEndpointKafkaPartitionStrategy
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    tls TlsProperties
    TLS configuration.
    batching DataFlowEndpointKafkaBatching
    Batching configuration.
    compression str | DataFlowEndpointKafkaCompression
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    consumer_group_id str
    Consumer group ID.
    copy_mqtt_properties str | OperationalMode
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    host str
    Kafka endpoint host.
    kafka_acks str | DataFlowEndpointKafkaAcks
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    partition_strategy str | DataFlowEndpointKafkaPartitionStrategy
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    tls Property Map
    TLS configuration.
    batching Property Map
    Batching configuration.
    compression String | "None" | "Gzip" | "Snappy" | "Lz4"
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    consumerGroupId String
    Consumer group ID.
    copyMqttProperties String | "Enabled" | "Disabled"
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    host String
    Kafka endpoint host.
    kafkaAcks String | "Zero" | "One" | "All"
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    partitionStrategy String | "Default" | "Static" | "Topic" | "Property"
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.

    DataFlowEndpointKafkaAcks, DataFlowEndpointKafkaAcksArgs

    Zero
    ZeroZERO Option
    One
    OneONE Option
    All
    AllALL Option
    DataFlowEndpointKafkaAcksZero
    ZeroZERO Option
    DataFlowEndpointKafkaAcksOne
    OneONE Option
    DataFlowEndpointKafkaAcksAll
    AllALL Option
    Zero
    ZeroZERO Option
    One
    OneONE Option
    All
    AllALL Option
    Zero
    ZeroZERO Option
    One
    OneONE Option
    All
    AllALL Option
    ZERO
    ZeroZERO Option
    ONE
    OneONE Option
    ALL
    AllALL Option
    "Zero"
    ZeroZERO Option
    "One"
    OneONE Option
    "All"
    AllALL Option

    DataFlowEndpointKafkaBatching, DataFlowEndpointKafkaBatchingArgs

    LatencyMs int
    Batching latency in milliseconds.
    MaxBytes int
    Maximum number of bytes in a batch.
    MaxMessages int
    Maximum number of messages in a batch.
    Mode string | Pulumi.AzureNative.IoTOperations.OperationalMode
    Mode for batching.
    LatencyMs int
    Batching latency in milliseconds.
    MaxBytes int
    Maximum number of bytes in a batch.
    MaxMessages int
    Maximum number of messages in a batch.
    Mode string | OperationalMode
    Mode for batching.
    latencyMs Integer
    Batching latency in milliseconds.
    maxBytes Integer
    Maximum number of bytes in a batch.
    maxMessages Integer
    Maximum number of messages in a batch.
    mode String | OperationalMode
    Mode for batching.
    latencyMs number
    Batching latency in milliseconds.
    maxBytes number
    Maximum number of bytes in a batch.
    maxMessages number
    Maximum number of messages in a batch.
    mode string | OperationalMode
    Mode for batching.
    latency_ms int
    Batching latency in milliseconds.
    max_bytes int
    Maximum number of bytes in a batch.
    max_messages int
    Maximum number of messages in a batch.
    mode str | OperationalMode
    Mode for batching.
    latencyMs Number
    Batching latency in milliseconds.
    maxBytes Number
    Maximum number of bytes in a batch.
    maxMessages Number
    Maximum number of messages in a batch.
    mode String | "Enabled" | "Disabled"
    Mode for batching.

    DataFlowEndpointKafkaBatchingResponse, DataFlowEndpointKafkaBatchingResponseArgs

    LatencyMs int
    Batching latency in milliseconds.
    MaxBytes int
    Maximum number of bytes in a batch.
    MaxMessages int
    Maximum number of messages in a batch.
    Mode string
    Mode for batching.
    LatencyMs int
    Batching latency in milliseconds.
    MaxBytes int
    Maximum number of bytes in a batch.
    MaxMessages int
    Maximum number of messages in a batch.
    Mode string
    Mode for batching.
    latencyMs Integer
    Batching latency in milliseconds.
    maxBytes Integer
    Maximum number of bytes in a batch.
    maxMessages Integer
    Maximum number of messages in a batch.
    mode String
    Mode for batching.
    latencyMs number
    Batching latency in milliseconds.
    maxBytes number
    Maximum number of bytes in a batch.
    maxMessages number
    Maximum number of messages in a batch.
    mode string
    Mode for batching.
    latency_ms int
    Batching latency in milliseconds.
    max_bytes int
    Maximum number of bytes in a batch.
    max_messages int
    Maximum number of messages in a batch.
    mode str
    Mode for batching.
    latencyMs Number
    Batching latency in milliseconds.
    maxBytes Number
    Maximum number of bytes in a batch.
    maxMessages Number
    Maximum number of messages in a batch.
    mode String
    Mode for batching.

    DataFlowEndpointKafkaCompression, DataFlowEndpointKafkaCompressionArgs

    None
    NoneNONE Option
    Gzip
    GzipGzip Option
    Snappy
    SnappySNAPPY Option
    Lz4
    Lz4LZ4 Option
    DataFlowEndpointKafkaCompressionNone
    NoneNONE Option
    DataFlowEndpointKafkaCompressionGzip
    GzipGzip Option
    DataFlowEndpointKafkaCompressionSnappy
    SnappySNAPPY Option
    DataFlowEndpointKafkaCompressionLz4
    Lz4LZ4 Option
    None
    NoneNONE Option
    Gzip
    GzipGzip Option
    Snappy
    SnappySNAPPY Option
    Lz4
    Lz4LZ4 Option
    None
    NoneNONE Option
    Gzip
    GzipGzip Option
    Snappy
    SnappySNAPPY Option
    Lz4
    Lz4LZ4 Option
    NONE
    NoneNONE Option
    GZIP
    GzipGzip Option
    SNAPPY
    SnappySNAPPY Option
    LZ4
    Lz4LZ4 Option
    "None"
    NoneNONE Option
    "Gzip"
    GzipGzip Option
    "Snappy"
    SnappySNAPPY Option
    "Lz4"
    Lz4LZ4 Option

    DataFlowEndpointKafkaPartitionStrategy, DataFlowEndpointKafkaPartitionStrategyArgs

    Default
    DefaultDefault: Assigns messages to random partitions, using a round-robin algorithm.
    Static
    StaticStatic: Assigns messages to a fixed partition number that's derived from the instance ID of the dataflow.
    Topic
    TopicTOPIC Option
    Property
    PropertyPROPERTY Option
    DataFlowEndpointKafkaPartitionStrategyDefault
    DefaultDefault: Assigns messages to random partitions, using a round-robin algorithm.
    DataFlowEndpointKafkaPartitionStrategyStatic
    StaticStatic: Assigns messages to a fixed partition number that's derived from the instance ID of the dataflow.
    DataFlowEndpointKafkaPartitionStrategyTopic
    TopicTOPIC Option
    DataFlowEndpointKafkaPartitionStrategyProperty
    PropertyPROPERTY Option
    Default
    DefaultDefault: Assigns messages to random partitions, using a round-robin algorithm.
    Static
    StaticStatic: Assigns messages to a fixed partition number that's derived from the instance ID of the dataflow.
    Topic
    TopicTOPIC Option
    Property
    PropertyPROPERTY Option
    Default
    DefaultDefault: Assigns messages to random partitions, using a round-robin algorithm.
    Static
    StaticStatic: Assigns messages to a fixed partition number that's derived from the instance ID of the dataflow.
    Topic
    TopicTOPIC Option
    Property
    PropertyPROPERTY Option
    DEFAULT
    DefaultDefault: Assigns messages to random partitions, using a round-robin algorithm.
    STATIC
    StaticStatic: Assigns messages to a fixed partition number that's derived from the instance ID of the dataflow.
    TOPIC
    TopicTOPIC Option
    PROPERTY
    PropertyPROPERTY Option
    "Default"
    DefaultDefault: Assigns messages to random partitions, using a round-robin algorithm.
    "Static"
    StaticStatic: Assigns messages to a fixed partition number that's derived from the instance ID of the dataflow.
    "Topic"
    TopicTOPIC Option
    "Property"
    PropertyPROPERTY Option

    DataFlowEndpointKafkaResponse, DataFlowEndpointKafkaResponseArgs

    Tls Pulumi.AzureNative.IoTOperations.Inputs.TlsPropertiesResponse
    TLS configuration.
    Batching Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointKafkaBatchingResponse
    Batching configuration.
    Compression string
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    ConsumerGroupId string
    Consumer group ID.
    CopyMqttProperties string
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    Host string
    Kafka endpoint host.
    KafkaAcks string
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    PartitionStrategy string
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    Tls TlsPropertiesResponse
    TLS configuration.
    Batching DataFlowEndpointKafkaBatchingResponse
    Batching configuration.
    Compression string
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    ConsumerGroupId string
    Consumer group ID.
    CopyMqttProperties string
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    Host string
    Kafka endpoint host.
    KafkaAcks string
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    PartitionStrategy string
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    tls TlsPropertiesResponse
    TLS configuration.
    batching DataFlowEndpointKafkaBatchingResponse
    Batching configuration.
    compression String
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    consumerGroupId String
    Consumer group ID.
    copyMqttProperties String
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    host String
    Kafka endpoint host.
    kafkaAcks String
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    partitionStrategy String
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    tls TlsPropertiesResponse
    TLS configuration.
    batching DataFlowEndpointKafkaBatchingResponse
    Batching configuration.
    compression string
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    consumerGroupId string
    Consumer group ID.
    copyMqttProperties string
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    host string
    Kafka endpoint host.
    kafkaAcks string
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    partitionStrategy string
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    tls TlsPropertiesResponse
    TLS configuration.
    batching DataFlowEndpointKafkaBatchingResponse
    Batching configuration.
    compression str
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    consumer_group_id str
    Consumer group ID.
    copy_mqtt_properties str
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    host str
    Kafka endpoint host.
    kafka_acks str
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    partition_strategy str
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
    tls Property Map
    TLS configuration.
    batching Property Map
    Batching configuration.
    compression String
    Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
    consumerGroupId String
    Consumer group ID.
    copyMqttProperties String
    Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
    host String
    Kafka endpoint host.
    kafkaAcks String
    Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
    partitionStrategy String
    Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.

    DataFlowEndpointLocalStorage, DataFlowEndpointLocalStorageArgs

    PersistentVolumeClaimRef string
    Persistent volume claim name.
    PersistentVolumeClaimRef string
    Persistent volume claim name.
    persistentVolumeClaimRef String
    Persistent volume claim name.
    persistentVolumeClaimRef string
    Persistent volume claim name.
    persistent_volume_claim_ref str
    Persistent volume claim name.
    persistentVolumeClaimRef String
    Persistent volume claim name.

    DataFlowEndpointLocalStorageResponse, DataFlowEndpointLocalStorageResponseArgs

    PersistentVolumeClaimRef string
    Persistent volume claim name.
    PersistentVolumeClaimRef string
    Persistent volume claim name.
    persistentVolumeClaimRef String
    Persistent volume claim name.
    persistentVolumeClaimRef string
    Persistent volume claim name.
    persistent_volume_claim_ref str
    Persistent volume claim name.
    persistentVolumeClaimRef String
    Persistent volume claim name.

    DataFlowEndpointMqtt, DataFlowEndpointMqttArgs

    ClientIdPrefix string
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    Host string
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    KeepAliveSeconds int
    Broker KeepAlive for connection in seconds.
    MaxInflightMessages int
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    Protocol string | Pulumi.AzureNative.IoTOperations.BrokerProtocolType
    Enable or disable websockets.
    Qos int
    Qos for Broker connection.
    Retain string | Pulumi.AzureNative.IoTOperations.MqttRetainType
    Whether or not to keep the retain setting.
    SessionExpirySeconds int
    Session expiry in seconds.
    Tls Pulumi.AzureNative.IoTOperations.Inputs.TlsProperties
    TLS configuration.
    ClientIdPrefix string
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    Host string
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    KeepAliveSeconds int
    Broker KeepAlive for connection in seconds.
    MaxInflightMessages int
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    Protocol string | BrokerProtocolType
    Enable or disable websockets.
    Qos int
    Qos for Broker connection.
    Retain string | MqttRetainType
    Whether or not to keep the retain setting.
    SessionExpirySeconds int
    Session expiry in seconds.
    Tls TlsProperties
    TLS configuration.
    clientIdPrefix String
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    host String
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    keepAliveSeconds Integer
    Broker KeepAlive for connection in seconds.
    maxInflightMessages Integer
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    protocol String | BrokerProtocolType
    Enable or disable websockets.
    qos Integer
    Qos for Broker connection.
    retain String | MqttRetainType
    Whether or not to keep the retain setting.
    sessionExpirySeconds Integer
    Session expiry in seconds.
    tls TlsProperties
    TLS configuration.
    clientIdPrefix string
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    host string
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    keepAliveSeconds number
    Broker KeepAlive for connection in seconds.
    maxInflightMessages number
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    protocol string | BrokerProtocolType
    Enable or disable websockets.
    qos number
    Qos for Broker connection.
    retain string | MqttRetainType
    Whether or not to keep the retain setting.
    sessionExpirySeconds number
    Session expiry in seconds.
    tls TlsProperties
    TLS configuration.
    client_id_prefix str
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    host str
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    keep_alive_seconds int
    Broker KeepAlive for connection in seconds.
    max_inflight_messages int
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    protocol str | BrokerProtocolType
    Enable or disable websockets.
    qos int
    Qos for Broker connection.
    retain str | MqttRetainType
    Whether or not to keep the retain setting.
    session_expiry_seconds int
    Session expiry in seconds.
    tls TlsProperties
    TLS configuration.
    clientIdPrefix String
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    host String
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    keepAliveSeconds Number
    Broker KeepAlive for connection in seconds.
    maxInflightMessages Number
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    protocol String | "Mqtt" | "WebSockets"
    Enable or disable websockets.
    qos Number
    Qos for Broker connection.
    retain String | "Keep" | "Never"
    Whether or not to keep the retain setting.
    sessionExpirySeconds Number
    Session expiry in seconds.
    tls Property Map
    TLS configuration.

    DataFlowEndpointMqttResponse, DataFlowEndpointMqttResponseArgs

    ClientIdPrefix string
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    Host string
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    KeepAliveSeconds int
    Broker KeepAlive for connection in seconds.
    MaxInflightMessages int
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    Protocol string
    Enable or disable websockets.
    Qos int
    Qos for Broker connection.
    Retain string
    Whether or not to keep the retain setting.
    SessionExpirySeconds int
    Session expiry in seconds.
    Tls Pulumi.AzureNative.IoTOperations.Inputs.TlsPropertiesResponse
    TLS configuration.
    ClientIdPrefix string
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    Host string
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    KeepAliveSeconds int
    Broker KeepAlive for connection in seconds.
    MaxInflightMessages int
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    Protocol string
    Enable or disable websockets.
    Qos int
    Qos for Broker connection.
    Retain string
    Whether or not to keep the retain setting.
    SessionExpirySeconds int
    Session expiry in seconds.
    Tls TlsPropertiesResponse
    TLS configuration.
    clientIdPrefix String
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    host String
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    keepAliveSeconds Integer
    Broker KeepAlive for connection in seconds.
    maxInflightMessages Integer
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    protocol String
    Enable or disable websockets.
    qos Integer
    Qos for Broker connection.
    retain String
    Whether or not to keep the retain setting.
    sessionExpirySeconds Integer
    Session expiry in seconds.
    tls TlsPropertiesResponse
    TLS configuration.
    clientIdPrefix string
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    host string
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    keepAliveSeconds number
    Broker KeepAlive for connection in seconds.
    maxInflightMessages number
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    protocol string
    Enable or disable websockets.
    qos number
    Qos for Broker connection.
    retain string
    Whether or not to keep the retain setting.
    sessionExpirySeconds number
    Session expiry in seconds.
    tls TlsPropertiesResponse
    TLS configuration.
    client_id_prefix str
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    host str
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    keep_alive_seconds int
    Broker KeepAlive for connection in seconds.
    max_inflight_messages int
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    protocol str
    Enable or disable websockets.
    qos int
    Qos for Broker connection.
    retain str
    Whether or not to keep the retain setting.
    session_expiry_seconds int
    Session expiry in seconds.
    tls TlsPropertiesResponse
    TLS configuration.
    clientIdPrefix String
    Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
    host String
    Host of the Broker in the form of :. Optional; connects to Broker if omitted.
    keepAliveSeconds Number
    Broker KeepAlive for connection in seconds.
    maxInflightMessages Number
    The max number of messages to keep in flight. For subscribe, this is the receive maximum. For publish, this is the maximum number of messages to send before waiting for an ack.
    protocol String
    Enable or disable websockets.
    qos Number
    Qos for Broker connection.
    retain String
    Whether or not to keep the retain setting.
    sessionExpirySeconds Number
    Session expiry in seconds.
    tls Property Map
    TLS configuration.

    DataFlowEndpointProperties, DataFlowEndpointPropertiesArgs

    Authentication Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthentication
    Authentication configuration.
    EndpointType string | Pulumi.AzureNative.IoTOperations.EndpointType
    Endpoint Type.
    DataExplorerSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointDataExplorer
    Azure Data Explorer endpoint.
    DataLakeStorageSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointDataLakeStorage
    Azure Data Lake endpoint.
    FabricOneLakeSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointFabricOneLake
    Microsoft Fabric endpoint.
    KafkaSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointKafka
    Kafka endpoint.
    LocalStorageSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointLocalStorage
    Local persistent volume endpoint.
    MqttSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointMqtt
    Broker endpoint.

    DataFlowEndpointPropertiesResponse, DataFlowEndpointPropertiesResponseArgs

    Authentication Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointAuthenticationResponse
    Authentication configuration.
    EndpointType string
    Endpoint Type.
    ProvisioningState string
    The status of the last operation.
    DataExplorerSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointDataExplorerResponse
    Azure Data Explorer endpoint.
    DataLakeStorageSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointDataLakeStorageResponse
    Azure Data Lake endpoint.
    FabricOneLakeSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointFabricOneLakeResponse
    Microsoft Fabric endpoint.
    KafkaSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointKafkaResponse
    Kafka endpoint.
    LocalStorageSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointLocalStorageResponse
    Local persistent volume endpoint.
    MqttSettings Pulumi.AzureNative.IoTOperations.Inputs.DataFlowEndpointMqttResponse
    Broker endpoint.
    authentication Property Map
    Authentication configuration.
    endpointType String
    Endpoint Type.
    provisioningState String
    The status of the last operation.
    dataExplorerSettings Property Map
    Azure Data Explorer endpoint.
    dataLakeStorageSettings Property Map
    Azure Data Lake endpoint.
    fabricOneLakeSettings Property Map
    Microsoft Fabric endpoint.
    kafkaSettings Property Map
    Kafka endpoint.
    localStorageSettings Property Map
    Local persistent volume endpoint.
    mqttSettings Property Map
    Broker endpoint.

    EndpointType, EndpointTypeArgs

    DataExplorer
    DataExplorerAzure Data Explorer Type
    DataLakeStorage
    DataLakeStorageAzure Data Lake Type
    FabricOneLake
    FabricOneLakeMicrosoft Fabric Type
    Kafka
    KafkaKafka Type
    LocalStorage
    LocalStorageLocal Storage Type
    Mqtt
    MqttBroker Type
    EndpointTypeDataExplorer
    DataExplorerAzure Data Explorer Type
    EndpointTypeDataLakeStorage
    DataLakeStorageAzure Data Lake Type
    EndpointTypeFabricOneLake
    FabricOneLakeMicrosoft Fabric Type
    EndpointTypeKafka
    KafkaKafka Type
    EndpointTypeLocalStorage
    LocalStorageLocal Storage Type
    EndpointTypeMqtt
    MqttBroker Type
    DataExplorer
    DataExplorerAzure Data Explorer Type
    DataLakeStorage
    DataLakeStorageAzure Data Lake Type
    FabricOneLake
    FabricOneLakeMicrosoft Fabric Type
    Kafka
    KafkaKafka Type
    LocalStorage
    LocalStorageLocal Storage Type
    Mqtt
    MqttBroker Type
    DataExplorer
    DataExplorerAzure Data Explorer Type
    DataLakeStorage
    DataLakeStorageAzure Data Lake Type
    FabricOneLake
    FabricOneLakeMicrosoft Fabric Type
    Kafka
    KafkaKafka Type
    LocalStorage
    LocalStorageLocal Storage Type
    Mqtt
    MqttBroker Type
    DATA_EXPLORER
    DataExplorerAzure Data Explorer Type
    DATA_LAKE_STORAGE
    DataLakeStorageAzure Data Lake Type
    FABRIC_ONE_LAKE
    FabricOneLakeMicrosoft Fabric Type
    KAFKA
    KafkaKafka Type
    LOCAL_STORAGE
    LocalStorageLocal Storage Type
    MQTT
    MqttBroker Type
    "DataExplorer"
    DataExplorerAzure Data Explorer Type
    "DataLakeStorage"
    DataLakeStorageAzure Data Lake Type
    "FabricOneLake"
    FabricOneLakeMicrosoft Fabric Type
    "Kafka"
    KafkaKafka Type
    "LocalStorage"
    LocalStorageLocal Storage Type
    "Mqtt"
    MqttBroker Type

    ExtendedLocation, ExtendedLocationArgs

    Name string
    The name of the extended location.
    Type string | Pulumi.AzureNative.IoTOperations.ExtendedLocationType
    Type of ExtendedLocation.
    Name string
    The name of the extended location.
    Type string | ExtendedLocationType
    Type of ExtendedLocation.
    name String
    The name of the extended location.
    type String | ExtendedLocationType
    Type of ExtendedLocation.
    name string
    The name of the extended location.
    type string | ExtendedLocationType
    Type of ExtendedLocation.
    name str
    The name of the extended location.
    type str | ExtendedLocationType
    Type of ExtendedLocation.
    name String
    The name of the extended location.
    type String | "CustomLocation"
    Type of ExtendedLocation.

    ExtendedLocationResponse, ExtendedLocationResponseArgs

    Name string
    The name of the extended location.
    Type string
    Type of ExtendedLocation.
    Name string
    The name of the extended location.
    Type string
    Type of ExtendedLocation.
    name String
    The name of the extended location.
    type String
    Type of ExtendedLocation.
    name string
    The name of the extended location.
    type string
    Type of ExtendedLocation.
    name str
    The name of the extended location.
    type str
    Type of ExtendedLocation.
    name String
    The name of the extended location.
    type String
    Type of ExtendedLocation.

    ExtendedLocationType, ExtendedLocationTypeArgs

    CustomLocation
    CustomLocationCustomLocation type
    ExtendedLocationTypeCustomLocation
    CustomLocationCustomLocation type
    CustomLocation
    CustomLocationCustomLocation type
    CustomLocation
    CustomLocationCustomLocation type
    CUSTOM_LOCATION
    CustomLocationCustomLocation type
    "CustomLocation"
    CustomLocationCustomLocation type

    MqttRetainType, MqttRetainTypeArgs

    Keep
    KeepRetain the messages.
    Never
    NeverNever retain messages.
    MqttRetainTypeKeep
    KeepRetain the messages.
    MqttRetainTypeNever
    NeverNever retain messages.
    Keep
    KeepRetain the messages.
    Never
    NeverNever retain messages.
    Keep
    KeepRetain the messages.
    Never
    NeverNever retain messages.
    KEEP
    KeepRetain the messages.
    NEVER
    NeverNever retain messages.
    "Keep"
    KeepRetain the messages.
    "Never"
    NeverNever retain messages.

    OperationalMode, OperationalModeArgs

    Enabled
    EnabledEnabled is equivalent to True
    Disabled
    DisabledDisabled is equivalent to False.
    OperationalModeEnabled
    EnabledEnabled is equivalent to True
    OperationalModeDisabled
    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.

    SystemDataResponse, SystemDataResponseArgs

    CreatedAt string
    The timestamp of resource creation (UTC).
    CreatedBy string
    The identity that created the resource.
    CreatedByType string
    The type of identity that created the resource.
    LastModifiedAt string
    The timestamp of resource last modification (UTC)
    LastModifiedBy string
    The identity that last modified the resource.
    LastModifiedByType string
    The type of identity that last modified the resource.
    CreatedAt string
    The timestamp of resource creation (UTC).
    CreatedBy string
    The identity that created the resource.
    CreatedByType string
    The type of identity that created the resource.
    LastModifiedAt string
    The timestamp of resource last modification (UTC)
    LastModifiedBy string
    The identity that last modified the resource.
    LastModifiedByType string
    The type of identity that last modified the resource.
    createdAt String
    The timestamp of resource creation (UTC).
    createdBy String
    The identity that created the resource.
    createdByType String
    The type of identity that created the resource.
    lastModifiedAt String
    The timestamp of resource last modification (UTC)
    lastModifiedBy String
    The identity that last modified the resource.
    lastModifiedByType String
    The type of identity that last modified the resource.
    createdAt string
    The timestamp of resource creation (UTC).
    createdBy string
    The identity that created the resource.
    createdByType string
    The type of identity that created the resource.
    lastModifiedAt string
    The timestamp of resource last modification (UTC)
    lastModifiedBy string
    The identity that last modified the resource.
    lastModifiedByType string
    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_type str
    The type of identity that created the resource.
    last_modified_at str
    The timestamp of resource last modification (UTC)
    last_modified_by str
    The identity that last modified the resource.
    last_modified_by_type str
    The type of identity that last modified the resource.
    createdAt String
    The timestamp of resource creation (UTC).
    createdBy String
    The identity that created the resource.
    createdByType String
    The type of identity that created the resource.
    lastModifiedAt String
    The timestamp of resource last modification (UTC)
    lastModifiedBy String
    The identity that last modified the resource.
    lastModifiedByType String
    The type of identity that last modified the resource.

    TlsProperties, TlsPropertiesArgs

    Mode string | Pulumi.AzureNative.IoTOperations.OperationalMode
    Mode for TLS.
    TrustedCaCertificateConfigMapRef string
    Trusted CA certificate config map.
    Mode string | OperationalMode
    Mode for TLS.
    TrustedCaCertificateConfigMapRef string
    Trusted CA certificate config map.
    mode String | OperationalMode
    Mode for TLS.
    trustedCaCertificateConfigMapRef String
    Trusted CA certificate config map.
    mode string | OperationalMode
    Mode for TLS.
    trustedCaCertificateConfigMapRef string
    Trusted CA certificate config map.
    mode str | OperationalMode
    Mode for TLS.
    trusted_ca_certificate_config_map_ref str
    Trusted CA certificate config map.
    mode String | "Enabled" | "Disabled"
    Mode for TLS.
    trustedCaCertificateConfigMapRef String
    Trusted CA certificate config map.

    TlsPropertiesResponse, TlsPropertiesResponseArgs

    Mode string
    Mode for TLS.
    TrustedCaCertificateConfigMapRef string
    Trusted CA certificate config map.
    Mode string
    Mode for TLS.
    TrustedCaCertificateConfigMapRef string
    Trusted CA certificate config map.
    mode String
    Mode for TLS.
    trustedCaCertificateConfigMapRef String
    Trusted CA certificate config map.
    mode string
    Mode for TLS.
    trustedCaCertificateConfigMapRef string
    Trusted CA certificate config map.
    mode str
    Mode for TLS.
    trusted_ca_certificate_config_map_ref str
    Trusted CA certificate config map.
    mode String
    Mode for TLS.
    trustedCaCertificateConfigMapRef String
    Trusted CA certificate config map.

    Import

    An existing resource can be imported using its type token, name, and identifier, e.g.

    $ pulumi import azure-native:iotoperations:DataFlowEndpoint kvyqxmrwwvxxvrlwyxfkxoebrapxbj /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperations/instances/{instanceName}/dataflowEndpoints/{dataflowEndpointName} 
    

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    Azure Native pulumi/pulumi-azure-native
    License
    Apache-2.0
    azure-native logo
    This is the latest version of Azure Native. Use the Azure Native v1 docs if using the v1 version of this package.
    Azure Native v2.73.0 published on Wednesday, Nov 20, 2024 by Pulumi