Docs Home
This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
Azure Native v3.2.0 published on Monday, Apr 14, 2025 by Pulumi
azure-native.iotoperations.DataflowEndpoint
Explore with Pulumi AI
This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
Azure Native v3.2.0 published on Monday, Apr 14, 2025 by Pulumi
Instance dataflowEndpoint resource
Uses Azure REST API version 2024-11-01.
Other available API versions: 2024-08-15-preview, 2024-09-15-preview, 2025-04-01. These can be accessed by generating a local SDK package using the CLI command pulumi package add azure-native iotoperations [ApiVersion]. See the version guide for details.
Example Usage
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 = "resource-name123",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
DataExplorerSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataExplorerArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataExplorerAuthenticationArgs
{
Method = "SystemAssignedManagedIdentity",
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "psxomrfbhoflycm",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
Scope = "zop",
TenantId = "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
{
LatencySeconds = 9312,
MaxMessages = 9028,
},
Database = "yqcdpjsifm",
Host = "<cluster>.<region>.kusto.windows.net",
},
DataLakeStorageSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataLakeStorageArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataLakeStorageAuthenticationArgs
{
AccessTokenSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationAccessTokenArgs
{
SecretRef = "sevriyphcvnlrnfudqzejecwa",
},
Method = AzureNative.IoTOperations.DataLakeStorageAuthMethod.SystemAssignedManagedIdentity,
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "psxomrfbhoflycm",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
Scope = "zop",
TenantId = "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
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
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointFabricOneLakeAuthenticationArgs
{
Method = "SystemAssignedManagedIdentity",
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "psxomrfbhoflycm",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
Scope = "zop",
TenantId = "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
{
LatencySeconds = 9312,
MaxMessages = 9028,
},
Host = "https://<host>.fabric.microsoft.com",
Names = new AzureNative.IoTOperations.Inputs.DataflowEndpointFabricOneLakeNamesArgs
{
LakehouseName = "wpeathi",
WorkspaceName = "nwgmitkbljztgms",
},
OneLakePathType = AzureNative.IoTOperations.DataflowEndpointFabricPathType.Files,
},
KafkaSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaAuthenticationArgs
{
Method = AzureNative.IoTOperations.KafkaAuthMethod.SystemAssignedManagedIdentity,
SaslSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSaslArgs
{
SaslType = AzureNative.IoTOperations.DataflowEndpointAuthenticationSaslType.Plain,
SecretRef = "visyxoztqnylvbyokhtmpdkwes",
},
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "psxomrfbhoflycm",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
Scope = "zop",
TenantId = "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
X509CertificateSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationX509Args
{
SecretRef = "afwizrystfslkfqd",
},
},
Batching = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaBatchingArgs
{
LatencyMs = 3679,
MaxBytes = 8887,
MaxMessages = 2174,
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
},
CloudEventAttributes = "PassThrough",
Compression = AzureNative.IoTOperations.DataflowEndpointKafkaCompression.None,
ConsumerGroupId = "ukkzcjiyenhxokat",
CopyMqttProperties = AzureNative.IoTOperations.OperationalMode.Enabled,
Host = "pwcqfiqclcgneolpewnyavoulbip",
KafkaAcks = AzureNative.IoTOperations.DataflowEndpointKafkaAcks.Zero,
PartitionStrategy = AzureNative.IoTOperations.DataflowEndpointKafkaPartitionStrategy.Default,
Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
TrustedCaCertificateConfigMapRef = "tectjjvukvelsreihwadh",
},
},
LocalStorageSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointLocalStorageArgs
{
PersistentVolumeClaimRef = "jjwqwvd",
},
MqttSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttAuthenticationArgs
{
Method = AzureNative.IoTOperations.MqttAuthMethod.SystemAssignedManagedIdentity,
ServiceAccountTokenSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationServiceAccountTokenArgs
{
Audience = "ejbklrbxgjaqleoycgpje",
},
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "psxomrfbhoflycm",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
Scope = "zop",
TenantId = "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
X509CertificateSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationX509Args
{
SecretRef = "afwizrystfslkfqd",
},
},
ClientIdPrefix = "kkljsdxdirfhwxtkavldekeqhv",
CloudEventAttributes = "PassThrough",
Host = "nyhnxqnbspstctl",
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 = "tectjjvukvelsreihwadh",
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("resource-name123"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
DataExplorerSettings: &iotoperations.DataflowEndpointDataExplorerArgs{
Authentication: &iotoperations.DataflowEndpointDataExplorerAuthenticationArgs{
Method: pulumi.Any("SystemAssignedManagedIdentity"),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("psxomrfbhoflycm"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("fb90f267-8872-431a-a76a-a1cec5d3c4d2"),
Scope: pulumi.String("zop"),
TenantId: pulumi.String("ed060aa2-71ff-4d3f-99c4-a9138356fdec"),
},
},
Batching: &iotoperations.BatchingConfigurationArgs{
LatencySeconds: pulumi.Int(9312),
MaxMessages: pulumi.Int(9028),
},
Database: pulumi.String("yqcdpjsifm"),
Host: pulumi.String("<cluster>.<region>.kusto.windows.net"),
},
DataLakeStorageSettings: &iotoperations.DataflowEndpointDataLakeStorageArgs{
Authentication: &iotoperations.DataflowEndpointDataLakeStorageAuthenticationArgs{
AccessTokenSettings: &iotoperations.DataflowEndpointAuthenticationAccessTokenArgs{
SecretRef: pulumi.String("sevriyphcvnlrnfudqzejecwa"),
},
Method: pulumi.String(iotoperations.DataLakeStorageAuthMethodSystemAssignedManagedIdentity),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("psxomrfbhoflycm"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("fb90f267-8872-431a-a76a-a1cec5d3c4d2"),
Scope: pulumi.String("zop"),
TenantId: pulumi.String("ed060aa2-71ff-4d3f-99c4-a9138356fdec"),
},
},
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{
Authentication: &iotoperations.DataflowEndpointFabricOneLakeAuthenticationArgs{
Method: pulumi.Any("SystemAssignedManagedIdentity"),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("psxomrfbhoflycm"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("fb90f267-8872-431a-a76a-a1cec5d3c4d2"),
Scope: pulumi.String("zop"),
TenantId: pulumi.String("ed060aa2-71ff-4d3f-99c4-a9138356fdec"),
},
},
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("wpeathi"),
WorkspaceName: pulumi.String("nwgmitkbljztgms"),
},
OneLakePathType: pulumi.String(iotoperations.DataflowEndpointFabricPathTypeFiles),
},
KafkaSettings: &iotoperations.DataflowEndpointKafkaArgs{
Authentication: &iotoperations.DataflowEndpointKafkaAuthenticationArgs{
Method: pulumi.String(iotoperations.KafkaAuthMethodSystemAssignedManagedIdentity),
SaslSettings: &iotoperations.DataflowEndpointAuthenticationSaslArgs{
SaslType: pulumi.String(iotoperations.DataflowEndpointAuthenticationSaslTypePlain),
SecretRef: pulumi.String("visyxoztqnylvbyokhtmpdkwes"),
},
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("psxomrfbhoflycm"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("fb90f267-8872-431a-a76a-a1cec5d3c4d2"),
Scope: pulumi.String("zop"),
TenantId: pulumi.String("ed060aa2-71ff-4d3f-99c4-a9138356fdec"),
},
X509CertificateSettings: &iotoperations.DataflowEndpointAuthenticationX509Args{
SecretRef: pulumi.String("afwizrystfslkfqd"),
},
},
Batching: &iotoperations.DataflowEndpointKafkaBatchingArgs{
LatencyMs: pulumi.Int(3679),
MaxBytes: pulumi.Int(8887),
MaxMessages: pulumi.Int(2174),
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
},
CloudEventAttributes: pulumi.String("PassThrough"),
Compression: pulumi.String(iotoperations.DataflowEndpointKafkaCompressionNone),
ConsumerGroupId: pulumi.String("ukkzcjiyenhxokat"),
CopyMqttProperties: pulumi.String(iotoperations.OperationalModeEnabled),
Host: pulumi.String("pwcqfiqclcgneolpewnyavoulbip"),
KafkaAcks: pulumi.String(iotoperations.DataflowEndpointKafkaAcksZero),
PartitionStrategy: pulumi.String(iotoperations.DataflowEndpointKafkaPartitionStrategyDefault),
Tls: &iotoperations.TlsPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
TrustedCaCertificateConfigMapRef: pulumi.String("tectjjvukvelsreihwadh"),
},
},
LocalStorageSettings: &iotoperations.DataflowEndpointLocalStorageArgs{
PersistentVolumeClaimRef: pulumi.String("jjwqwvd"),
},
MqttSettings: &iotoperations.DataflowEndpointMqttArgs{
Authentication: &iotoperations.DataflowEndpointMqttAuthenticationArgs{
Method: pulumi.String(iotoperations.MqttAuthMethodSystemAssignedManagedIdentity),
ServiceAccountTokenSettings: &iotoperations.DataflowEndpointAuthenticationServiceAccountTokenArgs{
Audience: pulumi.String("ejbklrbxgjaqleoycgpje"),
},
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("psxomrfbhoflycm"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("fb90f267-8872-431a-a76a-a1cec5d3c4d2"),
Scope: pulumi.String("zop"),
TenantId: pulumi.String("ed060aa2-71ff-4d3f-99c4-a9138356fdec"),
},
X509CertificateSettings: &iotoperations.DataflowEndpointAuthenticationX509Args{
SecretRef: pulumi.String("afwizrystfslkfqd"),
},
},
ClientIdPrefix: pulumi.String("kkljsdxdirfhwxtkavldekeqhv"),
CloudEventAttributes: pulumi.String("PassThrough"),
Host: pulumi.String("nyhnxqnbspstctl"),
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("tectjjvukvelsreihwadh"),
},
},
},
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.DataflowEndpointDataExplorerArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointDataExplorerAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs;
import com.pulumi.azurenative.iotoperations.inputs.BatchingConfigurationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointDataLakeStorageArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointDataLakeStorageAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationAccessTokenArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointFabricOneLakeArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointFabricOneLakeAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointFabricOneLakeNamesArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointKafkaArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointKafkaAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationSaslArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationX509Args;
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 com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointMqttAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationServiceAccountTokenArgs;
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("resource-name123")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.dataExplorerSettings(DataflowEndpointDataExplorerArgs.builder()
.authentication(DataflowEndpointDataExplorerAuthenticationArgs.builder()
.method("SystemAssignedManagedIdentity")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("psxomrfbhoflycm")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("fb90f267-8872-431a-a76a-a1cec5d3c4d2")
.scope("zop")
.tenantId("ed060aa2-71ff-4d3f-99c4-a9138356fdec")
.build())
.build())
.batching(BatchingConfigurationArgs.builder()
.latencySeconds(9312)
.maxMessages(9028)
.build())
.database("yqcdpjsifm")
.host("<cluster>.<region>.kusto.windows.net")
.build())
.dataLakeStorageSettings(DataflowEndpointDataLakeStorageArgs.builder()
.authentication(DataflowEndpointDataLakeStorageAuthenticationArgs.builder()
.accessTokenSettings(DataflowEndpointAuthenticationAccessTokenArgs.builder()
.secretRef("sevriyphcvnlrnfudqzejecwa")
.build())
.method("SystemAssignedManagedIdentity")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("psxomrfbhoflycm")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("fb90f267-8872-431a-a76a-a1cec5d3c4d2")
.scope("zop")
.tenantId("ed060aa2-71ff-4d3f-99c4-a9138356fdec")
.build())
.build())
.batching(BatchingConfigurationArgs.builder()
.latencySeconds(9312)
.maxMessages(9028)
.build())
.host("<account>.blob.core.windows.net")
.build())
.endpointType("DataExplorer")
.fabricOneLakeSettings(DataflowEndpointFabricOneLakeArgs.builder()
.authentication(DataflowEndpointFabricOneLakeAuthenticationArgs.builder()
.method("SystemAssignedManagedIdentity")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("psxomrfbhoflycm")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("fb90f267-8872-431a-a76a-a1cec5d3c4d2")
.scope("zop")
.tenantId("ed060aa2-71ff-4d3f-99c4-a9138356fdec")
.build())
.build())
.batching(BatchingConfigurationArgs.builder()
.latencySeconds(9312)
.maxMessages(9028)
.build())
.host("https://<host>.fabric.microsoft.com")
.names(DataflowEndpointFabricOneLakeNamesArgs.builder()
.lakehouseName("wpeathi")
.workspaceName("nwgmitkbljztgms")
.build())
.oneLakePathType("Files")
.build())
.kafkaSettings(DataflowEndpointKafkaArgs.builder()
.authentication(DataflowEndpointKafkaAuthenticationArgs.builder()
.method("SystemAssignedManagedIdentity")
.saslSettings(DataflowEndpointAuthenticationSaslArgs.builder()
.saslType("Plain")
.secretRef("visyxoztqnylvbyokhtmpdkwes")
.build())
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("psxomrfbhoflycm")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("fb90f267-8872-431a-a76a-a1cec5d3c4d2")
.scope("zop")
.tenantId("ed060aa2-71ff-4d3f-99c4-a9138356fdec")
.build())
.x509CertificateSettings(DataflowEndpointAuthenticationX509Args.builder()
.secretRef("afwizrystfslkfqd")
.build())
.build())
.batching(DataflowEndpointKafkaBatchingArgs.builder()
.latencyMs(3679)
.maxBytes(8887)
.maxMessages(2174)
.mode("Enabled")
.build())
.cloudEventAttributes("PassThrough")
.compression("None")
.consumerGroupId("ukkzcjiyenhxokat")
.copyMqttProperties("Enabled")
.host("pwcqfiqclcgneolpewnyavoulbip")
.kafkaAcks("Zero")
.partitionStrategy("Default")
.tls(TlsPropertiesArgs.builder()
.mode("Enabled")
.trustedCaCertificateConfigMapRef("tectjjvukvelsreihwadh")
.build())
.build())
.localStorageSettings(DataflowEndpointLocalStorageArgs.builder()
.persistentVolumeClaimRef("jjwqwvd")
.build())
.mqttSettings(DataflowEndpointMqttArgs.builder()
.authentication(DataflowEndpointMqttAuthenticationArgs.builder()
.method("SystemAssignedManagedIdentity")
.serviceAccountTokenSettings(DataflowEndpointAuthenticationServiceAccountTokenArgs.builder()
.audience("ejbklrbxgjaqleoycgpje")
.build())
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("psxomrfbhoflycm")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("fb90f267-8872-431a-a76a-a1cec5d3c4d2")
.scope("zop")
.tenantId("ed060aa2-71ff-4d3f-99c4-a9138356fdec")
.build())
.x509CertificateSettings(DataflowEndpointAuthenticationX509Args.builder()
.secretRef("afwizrystfslkfqd")
.build())
.build())
.clientIdPrefix("kkljsdxdirfhwxtkavldekeqhv")
.cloudEventAttributes("PassThrough")
.host("nyhnxqnbspstctl")
.keepAliveSeconds(0)
.maxInflightMessages(0)
.protocol("Mqtt")
.qos(1)
.retain("Keep")
.sessionExpirySeconds(0)
.tls(TlsPropertiesArgs.builder()
.mode("Enabled")
.trustedCaCertificateConfigMapRef("tectjjvukvelsreihwadh")
.build())
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "resource-name123",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
dataExplorerSettings: {
authentication: {
method: "SystemAssignedManagedIdentity",
systemAssignedManagedIdentitySettings: {
audience: "psxomrfbhoflycm",
},
userAssignedManagedIdentitySettings: {
clientId: "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
scope: "zop",
tenantId: "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
batching: {
latencySeconds: 9312,
maxMessages: 9028,
},
database: "yqcdpjsifm",
host: "<cluster>.<region>.kusto.windows.net",
},
dataLakeStorageSettings: {
authentication: {
accessTokenSettings: {
secretRef: "sevriyphcvnlrnfudqzejecwa",
},
method: azure_native.iotoperations.DataLakeStorageAuthMethod.SystemAssignedManagedIdentity,
systemAssignedManagedIdentitySettings: {
audience: "psxomrfbhoflycm",
},
userAssignedManagedIdentitySettings: {
clientId: "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
scope: "zop",
tenantId: "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
batching: {
latencySeconds: 9312,
maxMessages: 9028,
},
host: "<account>.blob.core.windows.net",
},
endpointType: azure_native.iotoperations.EndpointType.DataExplorer,
fabricOneLakeSettings: {
authentication: {
method: "SystemAssignedManagedIdentity",
systemAssignedManagedIdentitySettings: {
audience: "psxomrfbhoflycm",
},
userAssignedManagedIdentitySettings: {
clientId: "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
scope: "zop",
tenantId: "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
batching: {
latencySeconds: 9312,
maxMessages: 9028,
},
host: "https://<host>.fabric.microsoft.com",
names: {
lakehouseName: "wpeathi",
workspaceName: "nwgmitkbljztgms",
},
oneLakePathType: azure_native.iotoperations.DataflowEndpointFabricPathType.Files,
},
kafkaSettings: {
authentication: {
method: azure_native.iotoperations.KafkaAuthMethod.SystemAssignedManagedIdentity,
saslSettings: {
saslType: azure_native.iotoperations.DataflowEndpointAuthenticationSaslType.Plain,
secretRef: "visyxoztqnylvbyokhtmpdkwes",
},
systemAssignedManagedIdentitySettings: {
audience: "psxomrfbhoflycm",
},
userAssignedManagedIdentitySettings: {
clientId: "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
scope: "zop",
tenantId: "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
x509CertificateSettings: {
secretRef: "afwizrystfslkfqd",
},
},
batching: {
latencyMs: 3679,
maxBytes: 8887,
maxMessages: 2174,
mode: azure_native.iotoperations.OperationalMode.Enabled,
},
cloudEventAttributes: "PassThrough",
compression: azure_native.iotoperations.DataflowEndpointKafkaCompression.None,
consumerGroupId: "ukkzcjiyenhxokat",
copyMqttProperties: azure_native.iotoperations.OperationalMode.Enabled,
host: "pwcqfiqclcgneolpewnyavoulbip",
kafkaAcks: azure_native.iotoperations.DataflowEndpointKafkaAcks.Zero,
partitionStrategy: azure_native.iotoperations.DataflowEndpointKafkaPartitionStrategy.Default,
tls: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
trustedCaCertificateConfigMapRef: "tectjjvukvelsreihwadh",
},
},
localStorageSettings: {
persistentVolumeClaimRef: "jjwqwvd",
},
mqttSettings: {
authentication: {
method: azure_native.iotoperations.MqttAuthMethod.SystemAssignedManagedIdentity,
serviceAccountTokenSettings: {
audience: "ejbklrbxgjaqleoycgpje",
},
systemAssignedManagedIdentitySettings: {
audience: "psxomrfbhoflycm",
},
userAssignedManagedIdentitySettings: {
clientId: "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
scope: "zop",
tenantId: "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
x509CertificateSettings: {
secretRef: "afwizrystfslkfqd",
},
},
clientIdPrefix: "kkljsdxdirfhwxtkavldekeqhv",
cloudEventAttributes: "PassThrough",
host: "nyhnxqnbspstctl",
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: "tectjjvukvelsreihwadh",
},
},
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="resource-name123",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"data_explorer_settings": {
"authentication": {
"method": "SystemAssignedManagedIdentity",
"system_assigned_managed_identity_settings": {
"audience": "psxomrfbhoflycm",
},
"user_assigned_managed_identity_settings": {
"client_id": "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
"scope": "zop",
"tenant_id": "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
"batching": {
"latency_seconds": 9312,
"max_messages": 9028,
},
"database": "yqcdpjsifm",
"host": "<cluster>.<region>.kusto.windows.net",
},
"data_lake_storage_settings": {
"authentication": {
"access_token_settings": {
"secret_ref": "sevriyphcvnlrnfudqzejecwa",
},
"method": azure_native.iotoperations.DataLakeStorageAuthMethod.SYSTEM_ASSIGNED_MANAGED_IDENTITY,
"system_assigned_managed_identity_settings": {
"audience": "psxomrfbhoflycm",
},
"user_assigned_managed_identity_settings": {
"client_id": "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
"scope": "zop",
"tenant_id": "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
"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": {
"authentication": {
"method": "SystemAssignedManagedIdentity",
"system_assigned_managed_identity_settings": {
"audience": "psxomrfbhoflycm",
},
"user_assigned_managed_identity_settings": {
"client_id": "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
"scope": "zop",
"tenant_id": "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
},
"batching": {
"latency_seconds": 9312,
"max_messages": 9028,
},
"host": "https://<host>.fabric.microsoft.com",
"names": {
"lakehouse_name": "wpeathi",
"workspace_name": "nwgmitkbljztgms",
},
"one_lake_path_type": azure_native.iotoperations.DataflowEndpointFabricPathType.FILES,
},
"kafka_settings": {
"authentication": {
"method": azure_native.iotoperations.KafkaAuthMethod.SYSTEM_ASSIGNED_MANAGED_IDENTITY,
"sasl_settings": {
"sasl_type": azure_native.iotoperations.DataflowEndpointAuthenticationSaslType.PLAIN,
"secret_ref": "visyxoztqnylvbyokhtmpdkwes",
},
"system_assigned_managed_identity_settings": {
"audience": "psxomrfbhoflycm",
},
"user_assigned_managed_identity_settings": {
"client_id": "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
"scope": "zop",
"tenant_id": "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
"x509_certificate_settings": {
"secret_ref": "afwizrystfslkfqd",
},
},
"batching": {
"latency_ms": 3679,
"max_bytes": 8887,
"max_messages": 2174,
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
},
"cloud_event_attributes": "PassThrough",
"compression": azure_native.iotoperations.DataflowEndpointKafkaCompression.NONE,
"consumer_group_id": "ukkzcjiyenhxokat",
"copy_mqtt_properties": azure_native.iotoperations.OperationalMode.ENABLED,
"host": "pwcqfiqclcgneolpewnyavoulbip",
"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": "tectjjvukvelsreihwadh",
},
},
"local_storage_settings": {
"persistent_volume_claim_ref": "jjwqwvd",
},
"mqtt_settings": {
"authentication": {
"method": azure_native.iotoperations.MqttAuthMethod.SYSTEM_ASSIGNED_MANAGED_IDENTITY,
"service_account_token_settings": {
"audience": "ejbklrbxgjaqleoycgpje",
},
"system_assigned_managed_identity_settings": {
"audience": "psxomrfbhoflycm",
},
"user_assigned_managed_identity_settings": {
"client_id": "fb90f267-8872-431a-a76a-a1cec5d3c4d2",
"scope": "zop",
"tenant_id": "ed060aa2-71ff-4d3f-99c4-a9138356fdec",
},
"x509_certificate_settings": {
"secret_ref": "afwizrystfslkfqd",
},
},
"client_id_prefix": "kkljsdxdirfhwxtkavldekeqhv",
"cloud_event_attributes": "PassThrough",
"host": "nyhnxqnbspstctl",
"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": "tectjjvukvelsreihwadh",
},
},
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: resource-name123
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
dataExplorerSettings:
authentication:
method: SystemAssignedManagedIdentity
systemAssignedManagedIdentitySettings:
audience: psxomrfbhoflycm
userAssignedManagedIdentitySettings:
clientId: fb90f267-8872-431a-a76a-a1cec5d3c4d2
scope: zop
tenantId: ed060aa2-71ff-4d3f-99c4-a9138356fdec
batching:
latencySeconds: 9312
maxMessages: 9028
database: yqcdpjsifm
host: <cluster>.<region>.kusto.windows.net
dataLakeStorageSettings:
authentication:
accessTokenSettings:
secretRef: sevriyphcvnlrnfudqzejecwa
method: SystemAssignedManagedIdentity
systemAssignedManagedIdentitySettings:
audience: psxomrfbhoflycm
userAssignedManagedIdentitySettings:
clientId: fb90f267-8872-431a-a76a-a1cec5d3c4d2
scope: zop
tenantId: ed060aa2-71ff-4d3f-99c4-a9138356fdec
batching:
latencySeconds: 9312
maxMessages: 9028
host: <account>.blob.core.windows.net
endpointType: DataExplorer
fabricOneLakeSettings:
authentication:
method: SystemAssignedManagedIdentity
systemAssignedManagedIdentitySettings:
audience: psxomrfbhoflycm
userAssignedManagedIdentitySettings:
clientId: fb90f267-8872-431a-a76a-a1cec5d3c4d2
scope: zop
tenantId: ed060aa2-71ff-4d3f-99c4-a9138356fdec
batching:
latencySeconds: 9312
maxMessages: 9028
host: https://<host>.fabric.microsoft.com
names:
lakehouseName: wpeathi
workspaceName: nwgmitkbljztgms
oneLakePathType: Files
kafkaSettings:
authentication:
method: SystemAssignedManagedIdentity
saslSettings:
saslType: Plain
secretRef: visyxoztqnylvbyokhtmpdkwes
systemAssignedManagedIdentitySettings:
audience: psxomrfbhoflycm
userAssignedManagedIdentitySettings:
clientId: fb90f267-8872-431a-a76a-a1cec5d3c4d2
scope: zop
tenantId: ed060aa2-71ff-4d3f-99c4-a9138356fdec
x509CertificateSettings:
secretRef: afwizrystfslkfqd
batching:
latencyMs: 3679
maxBytes: 8887
maxMessages: 2174
mode: Enabled
cloudEventAttributes: PassThrough
compression: None
consumerGroupId: ukkzcjiyenhxokat
copyMqttProperties: Enabled
host: pwcqfiqclcgneolpewnyavoulbip
kafkaAcks: Zero
partitionStrategy: Default
tls:
mode: Enabled
trustedCaCertificateConfigMapRef: tectjjvukvelsreihwadh
localStorageSettings:
persistentVolumeClaimRef: jjwqwvd
mqttSettings:
authentication:
method: SystemAssignedManagedIdentity
serviceAccountTokenSettings:
audience: ejbklrbxgjaqleoycgpje
systemAssignedManagedIdentitySettings:
audience: psxomrfbhoflycm
userAssignedManagedIdentitySettings:
clientId: fb90f267-8872-431a-a76a-a1cec5d3c4d2
scope: zop
tenantId: ed060aa2-71ff-4d3f-99c4-a9138356fdec
x509CertificateSettings:
secretRef: afwizrystfslkfqd
clientIdPrefix: kkljsdxdirfhwxtkavldekeqhv
cloudEventAttributes: PassThrough
host: nyhnxqnbspstctl
keepAliveSeconds: 0
maxInflightMessages: 0
protocol: Mqtt
qos: 1
retain: Keep
sessionExpirySeconds: 0
tls:
mode: Enabled
trustedCaCertificateConfigMapRef: tectjjvukvelsreihwadh
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_ADLSv2
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 = "adlsv2-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
DataLakeStorageSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataLakeStorageArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataLakeStorageAuthenticationArgs
{
AccessTokenSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationAccessTokenArgs
{
SecretRef = "my-secret",
},
Method = AzureNative.IoTOperations.DataLakeStorageAuthMethod.AccessToken,
},
Host = "example.blob.core.windows.net",
},
EndpointType = AzureNative.IoTOperations.EndpointType.DataLakeStorage,
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("adlsv2-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
DataLakeStorageSettings: &iotoperations.DataflowEndpointDataLakeStorageArgs{
Authentication: &iotoperations.DataflowEndpointDataLakeStorageAuthenticationArgs{
AccessTokenSettings: &iotoperations.DataflowEndpointAuthenticationAccessTokenArgs{
SecretRef: pulumi.String("my-secret"),
},
Method: pulumi.String(iotoperations.DataLakeStorageAuthMethodAccessToken),
},
Host: pulumi.String("example.blob.core.windows.net"),
},
EndpointType: pulumi.String(iotoperations.EndpointTypeDataLakeStorage),
},
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.DataflowEndpointDataLakeStorageArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointDataLakeStorageAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationAccessTokenArgs;
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("adlsv2-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.dataLakeStorageSettings(DataflowEndpointDataLakeStorageArgs.builder()
.authentication(DataflowEndpointDataLakeStorageAuthenticationArgs.builder()
.accessTokenSettings(DataflowEndpointAuthenticationAccessTokenArgs.builder()
.secretRef("my-secret")
.build())
.method("AccessToken")
.build())
.host("example.blob.core.windows.net")
.build())
.endpointType("DataLakeStorage")
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "adlsv2-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
dataLakeStorageSettings: {
authentication: {
accessTokenSettings: {
secretRef: "my-secret",
},
method: azure_native.iotoperations.DataLakeStorageAuthMethod.AccessToken,
},
host: "example.blob.core.windows.net",
},
endpointType: azure_native.iotoperations.EndpointType.DataLakeStorage,
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="adlsv2-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"data_lake_storage_settings": {
"authentication": {
"access_token_settings": {
"secret_ref": "my-secret",
},
"method": azure_native.iotoperations.DataLakeStorageAuthMethod.ACCESS_TOKEN,
},
"host": "example.blob.core.windows.net",
},
"endpoint_type": azure_native.iotoperations.EndpointType.DATA_LAKE_STORAGE,
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: adlsv2-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
dataLakeStorageSettings:
authentication:
accessTokenSettings:
secretRef: my-secret
method: AccessToken
host: example.blob.core.windows.net
endpointType: DataLakeStorage
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_ADX
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 = "adx-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
DataExplorerSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataExplorerArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataExplorerAuthenticationArgs
{
Method = "SystemAssignedManagedIdentity",
SystemAssignedManagedIdentitySettings = null,
},
Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
{
LatencySeconds = 9312,
MaxMessages = 9028,
},
Database = "example-database",
Host = "example.westeurope.kusto.windows.net",
},
EndpointType = AzureNative.IoTOperations.EndpointType.DataExplorer,
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("adx-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
DataExplorerSettings: &iotoperations.DataflowEndpointDataExplorerArgs{
Authentication: &iotoperations.DataflowEndpointDataExplorerAuthenticationArgs{
Method: pulumi.Any("SystemAssignedManagedIdentity"),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{},
},
Batching: &iotoperations.BatchingConfigurationArgs{
LatencySeconds: pulumi.Int(9312),
MaxMessages: pulumi.Int(9028),
},
Database: pulumi.String("example-database"),
Host: pulumi.String("example.westeurope.kusto.windows.net"),
},
EndpointType: pulumi.String(iotoperations.EndpointTypeDataExplorer),
},
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.DataflowEndpointDataExplorerArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointDataExplorerAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs;
import com.pulumi.azurenative.iotoperations.inputs.BatchingConfigurationArgs;
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("adx-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.dataExplorerSettings(DataflowEndpointDataExplorerArgs.builder()
.authentication(DataflowEndpointDataExplorerAuthenticationArgs.builder()
.method("SystemAssignedManagedIdentity")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.build())
.build())
.batching(BatchingConfigurationArgs.builder()
.latencySeconds(9312)
.maxMessages(9028)
.build())
.database("example-database")
.host("example.westeurope.kusto.windows.net")
.build())
.endpointType("DataExplorer")
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "adx-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
dataExplorerSettings: {
authentication: {
method: "SystemAssignedManagedIdentity",
systemAssignedManagedIdentitySettings: {},
},
batching: {
latencySeconds: 9312,
maxMessages: 9028,
},
database: "example-database",
host: "example.westeurope.kusto.windows.net",
},
endpointType: azure_native.iotoperations.EndpointType.DataExplorer,
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="adx-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"data_explorer_settings": {
"authentication": {
"method": "SystemAssignedManagedIdentity",
"system_assigned_managed_identity_settings": {},
},
"batching": {
"latency_seconds": 9312,
"max_messages": 9028,
},
"database": "example-database",
"host": "example.westeurope.kusto.windows.net",
},
"endpoint_type": azure_native.iotoperations.EndpointType.DATA_EXPLORER,
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: adx-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
dataExplorerSettings:
authentication:
method: SystemAssignedManagedIdentity
systemAssignedManagedIdentitySettings: {}
batching:
latencySeconds: 9312
maxMessages: 9028
database: example-database
host: example.westeurope.kusto.windows.net
endpointType: DataExplorer
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_AIO
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-builtin-broker-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
EndpointType = AzureNative.IoTOperations.EndpointType.Mqtt,
MqttSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttAuthenticationArgs
{
Method = "Kubernetes",
ServiceAccountTokenSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationServiceAccountTokenArgs
{
Audience = "aio-internal",
},
},
Host = "aio-broker:18883",
Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
TrustedCaCertificateConfigMapRef = "aio-ca-trust-bundle-test-only",
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("aio-builtin-broker-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
EndpointType: pulumi.String(iotoperations.EndpointTypeMqtt),
MqttSettings: &iotoperations.DataflowEndpointMqttArgs{
Authentication: &iotoperations.DataflowEndpointMqttAuthenticationArgs{
Method: pulumi.String("Kubernetes"),
ServiceAccountTokenSettings: &iotoperations.DataflowEndpointAuthenticationServiceAccountTokenArgs{
Audience: pulumi.String("aio-internal"),
},
},
Host: pulumi.String("aio-broker:18883"),
Tls: &iotoperations.TlsPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
TrustedCaCertificateConfigMapRef: pulumi.String("aio-ca-trust-bundle-test-only"),
},
},
},
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.DataflowEndpointMqttArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointMqttAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationServiceAccountTokenArgs;
import com.pulumi.azurenative.iotoperations.inputs.TlsPropertiesArgs;
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-builtin-broker-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.endpointType("Mqtt")
.mqttSettings(DataflowEndpointMqttArgs.builder()
.authentication(DataflowEndpointMqttAuthenticationArgs.builder()
.method("Kubernetes")
.serviceAccountTokenSettings(DataflowEndpointAuthenticationServiceAccountTokenArgs.builder()
.audience("aio-internal")
.build())
.build())
.host("aio-broker:18883")
.tls(TlsPropertiesArgs.builder()
.mode("Enabled")
.trustedCaCertificateConfigMapRef("aio-ca-trust-bundle-test-only")
.build())
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "aio-builtin-broker-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
endpointType: azure_native.iotoperations.EndpointType.Mqtt,
mqttSettings: {
authentication: {
method: "Kubernetes",
serviceAccountTokenSettings: {
audience: "aio-internal",
},
},
host: "aio-broker:18883",
tls: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
trustedCaCertificateConfigMapRef: "aio-ca-trust-bundle-test-only",
},
},
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="aio-builtin-broker-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"endpoint_type": azure_native.iotoperations.EndpointType.MQTT,
"mqtt_settings": {
"authentication": {
"method": "Kubernetes",
"service_account_token_settings": {
"audience": "aio-internal",
},
},
"host": "aio-broker:18883",
"tls": {
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
"trusted_ca_certificate_config_map_ref": "aio-ca-trust-bundle-test-only",
},
},
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: aio-builtin-broker-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
endpointType: Mqtt
mqttSettings:
authentication:
method: Kubernetes
serviceAccountTokenSettings:
audience: aio-internal
host: aio-broker:18883
tls:
mode: Enabled
trustedCaCertificateConfigMapRef: aio-ca-trust-bundle-test-only
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_EventGrid
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 = "event-grid-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
EndpointType = AzureNative.IoTOperations.EndpointType.Mqtt,
MqttSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttAuthenticationArgs
{
Method = AzureNative.IoTOperations.MqttAuthMethod.SystemAssignedManagedIdentity,
SystemAssignedManagedIdentitySettings = null,
},
Host = "example.westeurope-1.ts.eventgrid.azure.net:8883",
Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("event-grid-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
EndpointType: pulumi.String(iotoperations.EndpointTypeMqtt),
MqttSettings: &iotoperations.DataflowEndpointMqttArgs{
Authentication: &iotoperations.DataflowEndpointMqttAuthenticationArgs{
Method: pulumi.String(iotoperations.MqttAuthMethodSystemAssignedManagedIdentity),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{},
},
Host: pulumi.String("example.westeurope-1.ts.eventgrid.azure.net:8883"),
Tls: &iotoperations.TlsPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
},
},
},
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.DataflowEndpointMqttArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointMqttAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs;
import com.pulumi.azurenative.iotoperations.inputs.TlsPropertiesArgs;
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("event-grid-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.endpointType("Mqtt")
.mqttSettings(DataflowEndpointMqttArgs.builder()
.authentication(DataflowEndpointMqttAuthenticationArgs.builder()
.method("SystemAssignedManagedIdentity")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.build())
.build())
.host("example.westeurope-1.ts.eventgrid.azure.net:8883")
.tls(TlsPropertiesArgs.builder()
.mode("Enabled")
.build())
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "event-grid-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
endpointType: azure_native.iotoperations.EndpointType.Mqtt,
mqttSettings: {
authentication: {
method: azure_native.iotoperations.MqttAuthMethod.SystemAssignedManagedIdentity,
systemAssignedManagedIdentitySettings: {},
},
host: "example.westeurope-1.ts.eventgrid.azure.net:8883",
tls: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
},
},
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="event-grid-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"endpoint_type": azure_native.iotoperations.EndpointType.MQTT,
"mqtt_settings": {
"authentication": {
"method": azure_native.iotoperations.MqttAuthMethod.SYSTEM_ASSIGNED_MANAGED_IDENTITY,
"system_assigned_managed_identity_settings": {},
},
"host": "example.westeurope-1.ts.eventgrid.azure.net:8883",
"tls": {
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
},
},
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: event-grid-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
endpointType: Mqtt
mqttSettings:
authentication:
method: SystemAssignedManagedIdentity
systemAssignedManagedIdentitySettings: {}
host: example.westeurope-1.ts.eventgrid.azure.net:8883
tls:
mode: Enabled
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_EventHub
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 = "event-hub-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
EndpointType = AzureNative.IoTOperations.EndpointType.Kafka,
KafkaSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaAuthenticationArgs
{
Method = AzureNative.IoTOperations.KafkaAuthMethod.SystemAssignedManagedIdentity,
SystemAssignedManagedIdentitySettings = null,
},
ConsumerGroupId = "aiodataflows",
Host = "example.servicebus.windows.net:9093",
Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("event-hub-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
EndpointType: pulumi.String(iotoperations.EndpointTypeKafka),
KafkaSettings: &iotoperations.DataflowEndpointKafkaArgs{
Authentication: &iotoperations.DataflowEndpointKafkaAuthenticationArgs{
Method: pulumi.String(iotoperations.KafkaAuthMethodSystemAssignedManagedIdentity),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{},
},
ConsumerGroupId: pulumi.String("aiodataflows"),
Host: pulumi.String("example.servicebus.windows.net:9093"),
Tls: &iotoperations.TlsPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
},
},
},
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.DataflowEndpointKafkaArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointKafkaAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs;
import com.pulumi.azurenative.iotoperations.inputs.TlsPropertiesArgs;
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("event-hub-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.endpointType("Kafka")
.kafkaSettings(DataflowEndpointKafkaArgs.builder()
.authentication(DataflowEndpointKafkaAuthenticationArgs.builder()
.method("SystemAssignedManagedIdentity")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.build())
.build())
.consumerGroupId("aiodataflows")
.host("example.servicebus.windows.net:9093")
.tls(TlsPropertiesArgs.builder()
.mode("Enabled")
.build())
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "event-hub-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
endpointType: azure_native.iotoperations.EndpointType.Kafka,
kafkaSettings: {
authentication: {
method: azure_native.iotoperations.KafkaAuthMethod.SystemAssignedManagedIdentity,
systemAssignedManagedIdentitySettings: {},
},
consumerGroupId: "aiodataflows",
host: "example.servicebus.windows.net:9093",
tls: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
},
},
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="event-hub-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"endpoint_type": azure_native.iotoperations.EndpointType.KAFKA,
"kafka_settings": {
"authentication": {
"method": azure_native.iotoperations.KafkaAuthMethod.SYSTEM_ASSIGNED_MANAGED_IDENTITY,
"system_assigned_managed_identity_settings": {},
},
"consumer_group_id": "aiodataflows",
"host": "example.servicebus.windows.net:9093",
"tls": {
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
},
},
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: event-hub-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
endpointType: Kafka
kafkaSettings:
authentication:
method: SystemAssignedManagedIdentity
systemAssignedManagedIdentitySettings: {}
consumerGroupId: aiodataflows
host: example.servicebus.windows.net:9093
tls:
mode: Enabled
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_Fabric
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 = "fabric-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
EndpointType = AzureNative.IoTOperations.EndpointType.FabricOneLake,
FabricOneLakeSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointFabricOneLakeArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointFabricOneLakeAuthenticationArgs
{
Method = "SystemAssignedManagedIdentity",
SystemAssignedManagedIdentitySettings = null,
},
Host = "onelake.dfs.fabric.microsoft.com",
Names = new AzureNative.IoTOperations.Inputs.DataflowEndpointFabricOneLakeNamesArgs
{
LakehouseName = "example-lakehouse",
WorkspaceName = "example-workspace",
},
OneLakePathType = AzureNative.IoTOperations.DataflowEndpointFabricPathType.Tables,
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("fabric-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
EndpointType: pulumi.String(iotoperations.EndpointTypeFabricOneLake),
FabricOneLakeSettings: &iotoperations.DataflowEndpointFabricOneLakeArgs{
Authentication: &iotoperations.DataflowEndpointFabricOneLakeAuthenticationArgs{
Method: pulumi.Any("SystemAssignedManagedIdentity"),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{},
},
Host: pulumi.String("onelake.dfs.fabric.microsoft.com"),
Names: &iotoperations.DataflowEndpointFabricOneLakeNamesArgs{
LakehouseName: pulumi.String("example-lakehouse"),
WorkspaceName: pulumi.String("example-workspace"),
},
OneLakePathType: pulumi.String(iotoperations.DataflowEndpointFabricPathTypeTables),
},
},
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.DataflowEndpointFabricOneLakeArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointFabricOneLakeAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointFabricOneLakeNamesArgs;
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("fabric-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.endpointType("FabricOneLake")
.fabricOneLakeSettings(DataflowEndpointFabricOneLakeArgs.builder()
.authentication(DataflowEndpointFabricOneLakeAuthenticationArgs.builder()
.method("SystemAssignedManagedIdentity")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.build())
.build())
.host("onelake.dfs.fabric.microsoft.com")
.names(DataflowEndpointFabricOneLakeNamesArgs.builder()
.lakehouseName("example-lakehouse")
.workspaceName("example-workspace")
.build())
.oneLakePathType("Tables")
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "fabric-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
endpointType: azure_native.iotoperations.EndpointType.FabricOneLake,
fabricOneLakeSettings: {
authentication: {
method: "SystemAssignedManagedIdentity",
systemAssignedManagedIdentitySettings: {},
},
host: "onelake.dfs.fabric.microsoft.com",
names: {
lakehouseName: "example-lakehouse",
workspaceName: "example-workspace",
},
oneLakePathType: azure_native.iotoperations.DataflowEndpointFabricPathType.Tables,
},
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="fabric-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"endpoint_type": azure_native.iotoperations.EndpointType.FABRIC_ONE_LAKE,
"fabric_one_lake_settings": {
"authentication": {
"method": "SystemAssignedManagedIdentity",
"system_assigned_managed_identity_settings": {},
},
"host": "onelake.dfs.fabric.microsoft.com",
"names": {
"lakehouse_name": "example-lakehouse",
"workspace_name": "example-workspace",
},
"one_lake_path_type": azure_native.iotoperations.DataflowEndpointFabricPathType.TABLES,
},
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: fabric-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
endpointType: FabricOneLake
fabricOneLakeSettings:
authentication:
method: SystemAssignedManagedIdentity
systemAssignedManagedIdentitySettings: {}
host: onelake.dfs.fabric.microsoft.com
names:
lakehouseName: example-lakehouse
workspaceName: example-workspace
oneLakePathType: Tables
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_Kafka
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 = "generic-kafka-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
EndpointType = AzureNative.IoTOperations.EndpointType.Kafka,
KafkaSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaAuthenticationArgs
{
Method = AzureNative.IoTOperations.KafkaAuthMethod.Sasl,
SaslSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSaslArgs
{
SaslType = AzureNative.IoTOperations.DataflowEndpointAuthenticationSaslType.Plain,
SecretRef = "my-secret",
},
},
Batching = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaBatchingArgs
{
LatencyMs = 5,
MaxBytes = 1000000,
MaxMessages = 100000,
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
},
CloudEventAttributes = AzureNative.IoTOperations.CloudEventAttributeType.Propagate,
Compression = AzureNative.IoTOperations.DataflowEndpointKafkaCompression.Gzip,
ConsumerGroupId = "dataflows",
CopyMqttProperties = AzureNative.IoTOperations.OperationalMode.Enabled,
Host = "example.kafka.local:9093",
KafkaAcks = AzureNative.IoTOperations.DataflowEndpointKafkaAcks.All,
PartitionStrategy = AzureNative.IoTOperations.DataflowEndpointKafkaPartitionStrategy.Default,
Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Enabled,
TrustedCaCertificateConfigMapRef = "ca-certificates",
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("generic-kafka-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
EndpointType: pulumi.String(iotoperations.EndpointTypeKafka),
KafkaSettings: &iotoperations.DataflowEndpointKafkaArgs{
Authentication: &iotoperations.DataflowEndpointKafkaAuthenticationArgs{
Method: pulumi.String(iotoperations.KafkaAuthMethodSasl),
SaslSettings: &iotoperations.DataflowEndpointAuthenticationSaslArgs{
SaslType: pulumi.String(iotoperations.DataflowEndpointAuthenticationSaslTypePlain),
SecretRef: pulumi.String("my-secret"),
},
},
Batching: &iotoperations.DataflowEndpointKafkaBatchingArgs{
LatencyMs: pulumi.Int(5),
MaxBytes: pulumi.Int(1000000),
MaxMessages: pulumi.Int(100000),
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
},
CloudEventAttributes: pulumi.String(iotoperations.CloudEventAttributeTypePropagate),
Compression: pulumi.String(iotoperations.DataflowEndpointKafkaCompressionGzip),
ConsumerGroupId: pulumi.String("dataflows"),
CopyMqttProperties: pulumi.String(iotoperations.OperationalModeEnabled),
Host: pulumi.String("example.kafka.local:9093"),
KafkaAcks: pulumi.String(iotoperations.DataflowEndpointKafkaAcksAll),
PartitionStrategy: pulumi.String(iotoperations.DataflowEndpointKafkaPartitionStrategyDefault),
Tls: &iotoperations.TlsPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeEnabled),
TrustedCaCertificateConfigMapRef: pulumi.String("ca-certificates"),
},
},
},
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.DataflowEndpointKafkaArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointKafkaAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationSaslArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointKafkaBatchingArgs;
import com.pulumi.azurenative.iotoperations.inputs.TlsPropertiesArgs;
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("generic-kafka-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.endpointType("Kafka")
.kafkaSettings(DataflowEndpointKafkaArgs.builder()
.authentication(DataflowEndpointKafkaAuthenticationArgs.builder()
.method("Sasl")
.saslSettings(DataflowEndpointAuthenticationSaslArgs.builder()
.saslType("Plain")
.secretRef("my-secret")
.build())
.build())
.batching(DataflowEndpointKafkaBatchingArgs.builder()
.latencyMs(5)
.maxBytes(1000000)
.maxMessages(100000)
.mode("Enabled")
.build())
.cloudEventAttributes("Propagate")
.compression("Gzip")
.consumerGroupId("dataflows")
.copyMqttProperties("Enabled")
.host("example.kafka.local:9093")
.kafkaAcks("All")
.partitionStrategy("Default")
.tls(TlsPropertiesArgs.builder()
.mode("Enabled")
.trustedCaCertificateConfigMapRef("ca-certificates")
.build())
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "generic-kafka-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
endpointType: azure_native.iotoperations.EndpointType.Kafka,
kafkaSettings: {
authentication: {
method: azure_native.iotoperations.KafkaAuthMethod.Sasl,
saslSettings: {
saslType: azure_native.iotoperations.DataflowEndpointAuthenticationSaslType.Plain,
secretRef: "my-secret",
},
},
batching: {
latencyMs: 5,
maxBytes: 1000000,
maxMessages: 100000,
mode: azure_native.iotoperations.OperationalMode.Enabled,
},
cloudEventAttributes: azure_native.iotoperations.CloudEventAttributeType.Propagate,
compression: azure_native.iotoperations.DataflowEndpointKafkaCompression.Gzip,
consumerGroupId: "dataflows",
copyMqttProperties: azure_native.iotoperations.OperationalMode.Enabled,
host: "example.kafka.local:9093",
kafkaAcks: azure_native.iotoperations.DataflowEndpointKafkaAcks.All,
partitionStrategy: azure_native.iotoperations.DataflowEndpointKafkaPartitionStrategy.Default,
tls: {
mode: azure_native.iotoperations.OperationalMode.Enabled,
trustedCaCertificateConfigMapRef: "ca-certificates",
},
},
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="generic-kafka-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"endpoint_type": azure_native.iotoperations.EndpointType.KAFKA,
"kafka_settings": {
"authentication": {
"method": azure_native.iotoperations.KafkaAuthMethod.SASL,
"sasl_settings": {
"sasl_type": azure_native.iotoperations.DataflowEndpointAuthenticationSaslType.PLAIN,
"secret_ref": "my-secret",
},
},
"batching": {
"latency_ms": 5,
"max_bytes": 1000000,
"max_messages": 100000,
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
},
"cloud_event_attributes": azure_native.iotoperations.CloudEventAttributeType.PROPAGATE,
"compression": azure_native.iotoperations.DataflowEndpointKafkaCompression.GZIP,
"consumer_group_id": "dataflows",
"copy_mqtt_properties": azure_native.iotoperations.OperationalMode.ENABLED,
"host": "example.kafka.local:9093",
"kafka_acks": azure_native.iotoperations.DataflowEndpointKafkaAcks.ALL,
"partition_strategy": azure_native.iotoperations.DataflowEndpointKafkaPartitionStrategy.DEFAULT,
"tls": {
"mode": azure_native.iotoperations.OperationalMode.ENABLED,
"trusted_ca_certificate_config_map_ref": "ca-certificates",
},
},
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: generic-kafka-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
endpointType: Kafka
kafkaSettings:
authentication:
method: Sasl
saslSettings:
saslType: Plain
secretRef: my-secret
batching:
latencyMs: 5
maxBytes: 1e+06
maxMessages: 100000
mode: Enabled
cloudEventAttributes: Propagate
compression: Gzip
consumerGroupId: dataflows
copyMqttProperties: Enabled
host: example.kafka.local:9093
kafkaAcks: All
partitionStrategy: Default
tls:
mode: Enabled
trustedCaCertificateConfigMapRef: ca-certificates
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_LocalStorage
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 = "local-storage-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
EndpointType = AzureNative.IoTOperations.EndpointType.LocalStorage,
LocalStorageSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointLocalStorageArgs
{
PersistentVolumeClaimRef = "example-pvc",
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("local-storage-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
EndpointType: pulumi.String(iotoperations.EndpointTypeLocalStorage),
LocalStorageSettings: &iotoperations.DataflowEndpointLocalStorageArgs{
PersistentVolumeClaimRef: pulumi.String("example-pvc"),
},
},
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.DataflowEndpointLocalStorageArgs;
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("local-storage-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.endpointType("LocalStorage")
.localStorageSettings(DataflowEndpointLocalStorageArgs.builder()
.persistentVolumeClaimRef("example-pvc")
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "local-storage-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
endpointType: azure_native.iotoperations.EndpointType.LocalStorage,
localStorageSettings: {
persistentVolumeClaimRef: "example-pvc",
},
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="local-storage-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"endpoint_type": azure_native.iotoperations.EndpointType.LOCAL_STORAGE,
"local_storage_settings": {
"persistent_volume_claim_ref": "example-pvc",
},
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: local-storage-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
endpointType: LocalStorage
localStorageSettings:
persistentVolumeClaimRef: example-pvc
resourceGroupName: rgiotoperations
DataflowEndpoint_CreateOrUpdate_MQTT
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 = "generic-mqtt-broker-endpoint",
ExtendedLocation = new AzureNative.IoTOperations.Inputs.ExtendedLocationArgs
{
Name = "qmbrfwcpwwhggszhrdjv",
Type = AzureNative.IoTOperations.ExtendedLocationType.CustomLocation,
},
InstanceName = "resource-name123",
Properties = new AzureNative.IoTOperations.Inputs.DataflowEndpointPropertiesArgs
{
EndpointType = AzureNative.IoTOperations.EndpointType.Mqtt,
MqttSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttAuthenticationArgs
{
Method = AzureNative.IoTOperations.MqttAuthMethod.X509Certificate,
X509CertificateSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationX509Args
{
SecretRef = "example-secret",
},
},
ClientIdPrefix = "factory-gateway",
Host = "example.broker.local:1883",
KeepAliveSeconds = 60,
MaxInflightMessages = 100,
Protocol = AzureNative.IoTOperations.BrokerProtocolType.WebSockets,
Qos = 1,
Retain = AzureNative.IoTOperations.MqttRetainType.Keep,
SessionExpirySeconds = 3600,
Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
{
Mode = AzureNative.IoTOperations.OperationalMode.Disabled,
},
},
},
ResourceGroupName = "rgiotoperations",
});
});
package main
import (
iotoperations "github.com/pulumi/pulumi-azure-native-sdk/iotoperations/v3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperations.NewDataflowEndpoint(ctx, "dataflowEndpoint", &iotoperations.DataflowEndpointArgs{
DataflowEndpointName: pulumi.String("generic-mqtt-broker-endpoint"),
ExtendedLocation: &iotoperations.ExtendedLocationArgs{
Name: pulumi.String("qmbrfwcpwwhggszhrdjv"),
Type: pulumi.String(iotoperations.ExtendedLocationTypeCustomLocation),
},
InstanceName: pulumi.String("resource-name123"),
Properties: &iotoperations.DataflowEndpointPropertiesArgs{
EndpointType: pulumi.String(iotoperations.EndpointTypeMqtt),
MqttSettings: &iotoperations.DataflowEndpointMqttArgs{
Authentication: &iotoperations.DataflowEndpointMqttAuthenticationArgs{
Method: pulumi.String(iotoperations.MqttAuthMethodX509Certificate),
X509CertificateSettings: &iotoperations.DataflowEndpointAuthenticationX509Args{
SecretRef: pulumi.String("example-secret"),
},
},
ClientIdPrefix: pulumi.String("factory-gateway"),
Host: pulumi.String("example.broker.local:1883"),
KeepAliveSeconds: pulumi.Int(60),
MaxInflightMessages: pulumi.Int(100),
Protocol: pulumi.String(iotoperations.BrokerProtocolTypeWebSockets),
Qos: pulumi.Int(1),
Retain: pulumi.String(iotoperations.MqttRetainTypeKeep),
SessionExpirySeconds: pulumi.Int(3600),
Tls: &iotoperations.TlsPropertiesArgs{
Mode: pulumi.String(iotoperations.OperationalModeDisabled),
},
},
},
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.DataflowEndpointMqttArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointMqttAuthenticationArgs;
import com.pulumi.azurenative.iotoperations.inputs.DataflowEndpointAuthenticationX509Args;
import com.pulumi.azurenative.iotoperations.inputs.TlsPropertiesArgs;
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("generic-mqtt-broker-endpoint")
.extendedLocation(ExtendedLocationArgs.builder()
.name("qmbrfwcpwwhggszhrdjv")
.type("CustomLocation")
.build())
.instanceName("resource-name123")
.properties(DataflowEndpointPropertiesArgs.builder()
.endpointType("Mqtt")
.mqttSettings(DataflowEndpointMqttArgs.builder()
.authentication(DataflowEndpointMqttAuthenticationArgs.builder()
.method("X509Certificate")
.x509CertificateSettings(DataflowEndpointAuthenticationX509Args.builder()
.secretRef("example-secret")
.build())
.build())
.clientIdPrefix("factory-gateway")
.host("example.broker.local:1883")
.keepAliveSeconds(60)
.maxInflightMessages(100)
.protocol("WebSockets")
.qos(1)
.retain("Keep")
.sessionExpirySeconds(3600)
.tls(TlsPropertiesArgs.builder()
.mode("Disabled")
.build())
.build())
.build())
.resourceGroupName("rgiotoperations")
.build());
}
}
import * as pulumi from "@pulumi/pulumi";
import * as azure_native from "@pulumi/azure-native";
const dataflowEndpoint = new azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint", {
dataflowEndpointName: "generic-mqtt-broker-endpoint",
extendedLocation: {
name: "qmbrfwcpwwhggszhrdjv",
type: azure_native.iotoperations.ExtendedLocationType.CustomLocation,
},
instanceName: "resource-name123",
properties: {
endpointType: azure_native.iotoperations.EndpointType.Mqtt,
mqttSettings: {
authentication: {
method: azure_native.iotoperations.MqttAuthMethod.X509Certificate,
x509CertificateSettings: {
secretRef: "example-secret",
},
},
clientIdPrefix: "factory-gateway",
host: "example.broker.local:1883",
keepAliveSeconds: 60,
maxInflightMessages: 100,
protocol: azure_native.iotoperations.BrokerProtocolType.WebSockets,
qos: 1,
retain: azure_native.iotoperations.MqttRetainType.Keep,
sessionExpirySeconds: 3600,
tls: {
mode: azure_native.iotoperations.OperationalMode.Disabled,
},
},
},
resourceGroupName: "rgiotoperations",
});
import pulumi
import pulumi_azure_native as azure_native
dataflow_endpoint = azure_native.iotoperations.DataflowEndpoint("dataflowEndpoint",
dataflow_endpoint_name="generic-mqtt-broker-endpoint",
extended_location={
"name": "qmbrfwcpwwhggszhrdjv",
"type": azure_native.iotoperations.ExtendedLocationType.CUSTOM_LOCATION,
},
instance_name="resource-name123",
properties={
"endpoint_type": azure_native.iotoperations.EndpointType.MQTT,
"mqtt_settings": {
"authentication": {
"method": azure_native.iotoperations.MqttAuthMethod.X509_CERTIFICATE,
"x509_certificate_settings": {
"secret_ref": "example-secret",
},
},
"client_id_prefix": "factory-gateway",
"host": "example.broker.local:1883",
"keep_alive_seconds": 60,
"max_inflight_messages": 100,
"protocol": azure_native.iotoperations.BrokerProtocolType.WEB_SOCKETS,
"qos": 1,
"retain": azure_native.iotoperations.MqttRetainType.KEEP,
"session_expiry_seconds": 3600,
"tls": {
"mode": azure_native.iotoperations.OperationalMode.DISABLED,
},
},
},
resource_group_name="rgiotoperations")
resources:
dataflowEndpoint:
type: azure-native:iotoperations:DataflowEndpoint
properties:
dataflowEndpointName: generic-mqtt-broker-endpoint
extendedLocation:
name: qmbrfwcpwwhggszhrdjv
type: CustomLocation
instanceName: resource-name123
properties:
endpointType: Mqtt
mqttSettings:
authentication:
method: X509Certificate
x509CertificateSettings:
secretRef: example-secret
clientIdPrefix: factory-gateway
host: example.broker.local:1883
keepAliveSeconds: 60
maxInflightMessages: 100
protocol: WebSockets
qos: 1
retain: Keep
sessionExpirySeconds: 3600
tls:
mode: Disabled
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
{
EndpointType = "string",
DataExplorerSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataExplorerArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataExplorerAuthenticationArgs
{
Method = "any",
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "string",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "string",
TenantId = "string",
Scope = "string",
},
},
Database = "string",
Host = "string",
Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
{
LatencySeconds = 0,
MaxMessages = 0,
},
},
DataLakeStorageSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataLakeStorageArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointDataLakeStorageAuthenticationArgs
{
Method = "string",
AccessTokenSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationAccessTokenArgs
{
SecretRef = "string",
},
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "string",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "string",
TenantId = "string",
Scope = "string",
},
},
Host = "string",
Batching = new AzureNative.IoTOperations.Inputs.BatchingConfigurationArgs
{
LatencySeconds = 0,
MaxMessages = 0,
},
},
FabricOneLakeSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointFabricOneLakeArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointFabricOneLakeAuthenticationArgs
{
Method = "any",
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "string",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "string",
TenantId = "string",
Scope = "string",
},
},
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
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaAuthenticationArgs
{
Method = "string",
SaslSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSaslArgs
{
SaslType = "string",
SecretRef = "string",
},
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "string",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "string",
TenantId = "string",
Scope = "string",
},
X509CertificateSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationX509Args
{
SecretRef = "string",
},
},
Host = "string",
Batching = new AzureNative.IoTOperations.Inputs.DataflowEndpointKafkaBatchingArgs
{
LatencyMs = 0,
MaxBytes = 0,
MaxMessages = 0,
Mode = "string",
},
CloudEventAttributes = "string",
Compression = "string",
ConsumerGroupId = "string",
CopyMqttProperties = "string",
KafkaAcks = "string",
PartitionStrategy = "string",
Tls = new AzureNative.IoTOperations.Inputs.TlsPropertiesArgs
{
Mode = "string",
TrustedCaCertificateConfigMapRef = "string",
},
},
LocalStorageSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointLocalStorageArgs
{
PersistentVolumeClaimRef = "string",
},
MqttSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttArgs
{
Authentication = new AzureNative.IoTOperations.Inputs.DataflowEndpointMqttAuthenticationArgs
{
Method = "string",
ServiceAccountTokenSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationServiceAccountTokenArgs
{
Audience = "string",
},
SystemAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs
{
Audience = "string",
},
UserAssignedManagedIdentitySettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs
{
ClientId = "string",
TenantId = "string",
Scope = "string",
},
X509CertificateSettings = new AzureNative.IoTOperations.Inputs.DataflowEndpointAuthenticationX509Args
{
SecretRef = "string",
},
},
ClientIdPrefix = "string",
CloudEventAttributes = "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{
EndpointType: pulumi.String("string"),
DataExplorerSettings: &iotoperations.DataflowEndpointDataExplorerArgs{
Authentication: &iotoperations.DataflowEndpointDataExplorerAuthenticationArgs{
Method: pulumi.Any("any"),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("string"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("string"),
TenantId: pulumi.String("string"),
Scope: pulumi.String("string"),
},
},
Database: pulumi.String("string"),
Host: pulumi.String("string"),
Batching: &iotoperations.BatchingConfigurationArgs{
LatencySeconds: pulumi.Int(0),
MaxMessages: pulumi.Int(0),
},
},
DataLakeStorageSettings: &iotoperations.DataflowEndpointDataLakeStorageArgs{
Authentication: &iotoperations.DataflowEndpointDataLakeStorageAuthenticationArgs{
Method: pulumi.String("string"),
AccessTokenSettings: &iotoperations.DataflowEndpointAuthenticationAccessTokenArgs{
SecretRef: pulumi.String("string"),
},
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("string"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("string"),
TenantId: pulumi.String("string"),
Scope: pulumi.String("string"),
},
},
Host: pulumi.String("string"),
Batching: &iotoperations.BatchingConfigurationArgs{
LatencySeconds: pulumi.Int(0),
MaxMessages: pulumi.Int(0),
},
},
FabricOneLakeSettings: &iotoperations.DataflowEndpointFabricOneLakeArgs{
Authentication: &iotoperations.DataflowEndpointFabricOneLakeAuthenticationArgs{
Method: pulumi.Any("any"),
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("string"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("string"),
TenantId: pulumi.String("string"),
Scope: pulumi.String("string"),
},
},
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{
Authentication: &iotoperations.DataflowEndpointKafkaAuthenticationArgs{
Method: pulumi.String("string"),
SaslSettings: &iotoperations.DataflowEndpointAuthenticationSaslArgs{
SaslType: pulumi.String("string"),
SecretRef: pulumi.String("string"),
},
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("string"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("string"),
TenantId: pulumi.String("string"),
Scope: pulumi.String("string"),
},
X509CertificateSettings: &iotoperations.DataflowEndpointAuthenticationX509Args{
SecretRef: pulumi.String("string"),
},
},
Host: pulumi.String("string"),
Batching: &iotoperations.DataflowEndpointKafkaBatchingArgs{
LatencyMs: pulumi.Int(0),
MaxBytes: pulumi.Int(0),
MaxMessages: pulumi.Int(0),
Mode: pulumi.String("string"),
},
CloudEventAttributes: pulumi.String("string"),
Compression: pulumi.String("string"),
ConsumerGroupId: pulumi.String("string"),
CopyMqttProperties: pulumi.String("string"),
KafkaAcks: pulumi.String("string"),
PartitionStrategy: pulumi.String("string"),
Tls: &iotoperations.TlsPropertiesArgs{
Mode: pulumi.String("string"),
TrustedCaCertificateConfigMapRef: pulumi.String("string"),
},
},
LocalStorageSettings: &iotoperations.DataflowEndpointLocalStorageArgs{
PersistentVolumeClaimRef: pulumi.String("string"),
},
MqttSettings: &iotoperations.DataflowEndpointMqttArgs{
Authentication: &iotoperations.DataflowEndpointMqttAuthenticationArgs{
Method: pulumi.String("string"),
ServiceAccountTokenSettings: &iotoperations.DataflowEndpointAuthenticationServiceAccountTokenArgs{
Audience: pulumi.String("string"),
},
SystemAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs{
Audience: pulumi.String("string"),
},
UserAssignedManagedIdentitySettings: &iotoperations.DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs{
ClientId: pulumi.String("string"),
TenantId: pulumi.String("string"),
Scope: pulumi.String("string"),
},
X509CertificateSettings: &iotoperations.DataflowEndpointAuthenticationX509Args{
SecretRef: pulumi.String("string"),
},
},
ClientIdPrefix: pulumi.String("string"),
CloudEventAttributes: 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()
.endpointType("string")
.dataExplorerSettings(DataflowEndpointDataExplorerArgs.builder()
.authentication(DataflowEndpointDataExplorerAuthenticationArgs.builder()
.method("any")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("string")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("string")
.tenantId("string")
.scope("string")
.build())
.build())
.database("string")
.host("string")
.batching(BatchingConfigurationArgs.builder()
.latencySeconds(0)
.maxMessages(0)
.build())
.build())
.dataLakeStorageSettings(DataflowEndpointDataLakeStorageArgs.builder()
.authentication(DataflowEndpointDataLakeStorageAuthenticationArgs.builder()
.method("string")
.accessTokenSettings(DataflowEndpointAuthenticationAccessTokenArgs.builder()
.secretRef("string")
.build())
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("string")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("string")
.tenantId("string")
.scope("string")
.build())
.build())
.host("string")
.batching(BatchingConfigurationArgs.builder()
.latencySeconds(0)
.maxMessages(0)
.build())
.build())
.fabricOneLakeSettings(DataflowEndpointFabricOneLakeArgs.builder()
.authentication(DataflowEndpointFabricOneLakeAuthenticationArgs.builder()
.method("any")
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("string")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("string")
.tenantId("string")
.scope("string")
.build())
.build())
.host("string")
.names(DataflowEndpointFabricOneLakeNamesArgs.builder()
.lakehouseName("string")
.workspaceName("string")
.build())
.oneLakePathType("string")
.batching(BatchingConfigurationArgs.builder()
.latencySeconds(0)
.maxMessages(0)
.build())
.build())
.kafkaSettings(DataflowEndpointKafkaArgs.builder()
.authentication(DataflowEndpointKafkaAuthenticationArgs.builder()
.method("string")
.saslSettings(DataflowEndpointAuthenticationSaslArgs.builder()
.saslType("string")
.secretRef("string")
.build())
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("string")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("string")
.tenantId("string")
.scope("string")
.build())
.x509CertificateSettings(DataflowEndpointAuthenticationX509Args.builder()
.secretRef("string")
.build())
.build())
.host("string")
.batching(DataflowEndpointKafkaBatchingArgs.builder()
.latencyMs(0)
.maxBytes(0)
.maxMessages(0)
.mode("string")
.build())
.cloudEventAttributes("string")
.compression("string")
.consumerGroupId("string")
.copyMqttProperties("string")
.kafkaAcks("string")
.partitionStrategy("string")
.tls(TlsPropertiesArgs.builder()
.mode("string")
.trustedCaCertificateConfigMapRef("string")
.build())
.build())
.localStorageSettings(DataflowEndpointLocalStorageArgs.builder()
.persistentVolumeClaimRef("string")
.build())
.mqttSettings(DataflowEndpointMqttArgs.builder()
.authentication(DataflowEndpointMqttAuthenticationArgs.builder()
.method("string")
.serviceAccountTokenSettings(DataflowEndpointAuthenticationServiceAccountTokenArgs.builder()
.audience("string")
.build())
.systemAssignedManagedIdentitySettings(DataflowEndpointAuthenticationSystemAssignedManagedIdentityArgs.builder()
.audience("string")
.build())
.userAssignedManagedIdentitySettings(DataflowEndpointAuthenticationUserAssignedManagedIdentityArgs.builder()
.clientId("string")
.tenantId("string")
.scope("string")
.build())
.x509CertificateSettings(DataflowEndpointAuthenticationX509Args.builder()
.secretRef("string")
.build())
.build())
.clientIdPrefix("string")
.cloudEventAttributes("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());
dataflow_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={
"endpoint_type": "string",
"data_explorer_settings": {
"authentication": {
"method": "any",
"system_assigned_managed_identity_settings": {
"audience": "string",
},
"user_assigned_managed_identity_settings": {
"client_id": "string",
"tenant_id": "string",
"scope": "string",
},
},
"database": "string",
"host": "string",
"batching": {
"latency_seconds": 0,
"max_messages": 0,
},
},
"data_lake_storage_settings": {
"authentication": {
"method": "string",
"access_token_settings": {
"secret_ref": "string",
},
"system_assigned_managed_identity_settings": {
"audience": "string",
},
"user_assigned_managed_identity_settings": {
"client_id": "string",
"tenant_id": "string",
"scope": "string",
},
},
"host": "string",
"batching": {
"latency_seconds": 0,
"max_messages": 0,
},
},
"fabric_one_lake_settings": {
"authentication": {
"method": "any",
"system_assigned_managed_identity_settings": {
"audience": "string",
},
"user_assigned_managed_identity_settings": {
"client_id": "string",
"tenant_id": "string",
"scope": "string",
},
},
"host": "string",
"names": {
"lakehouse_name": "string",
"workspace_name": "string",
},
"one_lake_path_type": "string",
"batching": {
"latency_seconds": 0,
"max_messages": 0,
},
},
"kafka_settings": {
"authentication": {
"method": "string",
"sasl_settings": {
"sasl_type": "string",
"secret_ref": "string",
},
"system_assigned_managed_identity_settings": {
"audience": "string",
},
"user_assigned_managed_identity_settings": {
"client_id": "string",
"tenant_id": "string",
"scope": "string",
},
"x509_certificate_settings": {
"secret_ref": "string",
},
},
"host": "string",
"batching": {
"latency_ms": 0,
"max_bytes": 0,
"max_messages": 0,
"mode": "string",
},
"cloud_event_attributes": "string",
"compression": "string",
"consumer_group_id": "string",
"copy_mqtt_properties": "string",
"kafka_acks": "string",
"partition_strategy": "string",
"tls": {
"mode": "string",
"trusted_ca_certificate_config_map_ref": "string",
},
},
"local_storage_settings": {
"persistent_volume_claim_ref": "string",
},
"mqtt_settings": {
"authentication": {
"method": "string",
"service_account_token_settings": {
"audience": "string",
},
"system_assigned_managed_identity_settings": {
"audience": "string",
},
"user_assigned_managed_identity_settings": {
"client_id": "string",
"tenant_id": "string",
"scope": "string",
},
"x509_certificate_settings": {
"secret_ref": "string",
},
},
"client_id_prefix": "string",
"cloud_event_attributes": "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: {
endpointType: "string",
dataExplorerSettings: {
authentication: {
method: "any",
systemAssignedManagedIdentitySettings: {
audience: "string",
},
userAssignedManagedIdentitySettings: {
clientId: "string",
tenantId: "string",
scope: "string",
},
},
database: "string",
host: "string",
batching: {
latencySeconds: 0,
maxMessages: 0,
},
},
dataLakeStorageSettings: {
authentication: {
method: "string",
accessTokenSettings: {
secretRef: "string",
},
systemAssignedManagedIdentitySettings: {
audience: "string",
},
userAssignedManagedIdentitySettings: {
clientId: "string",
tenantId: "string",
scope: "string",
},
},
host: "string",
batching: {
latencySeconds: 0,
maxMessages: 0,
},
},
fabricOneLakeSettings: {
authentication: {
method: "any",
systemAssignedManagedIdentitySettings: {
audience: "string",
},
userAssignedManagedIdentitySettings: {
clientId: "string",
tenantId: "string",
scope: "string",
},
},
host: "string",
names: {
lakehouseName: "string",
workspaceName: "string",
},
oneLakePathType: "string",
batching: {
latencySeconds: 0,
maxMessages: 0,
},
},
kafkaSettings: {
authentication: {
method: "string",
saslSettings: {
saslType: "string",
secretRef: "string",
},
systemAssignedManagedIdentitySettings: {
audience: "string",
},
userAssignedManagedIdentitySettings: {
clientId: "string",
tenantId: "string",
scope: "string",
},
x509CertificateSettings: {
secretRef: "string",
},
},
host: "string",
batching: {
latencyMs: 0,
maxBytes: 0,
maxMessages: 0,
mode: "string",
},
cloudEventAttributes: "string",
compression: "string",
consumerGroupId: "string",
copyMqttProperties: "string",
kafkaAcks: "string",
partitionStrategy: "string",
tls: {
mode: "string",
trustedCaCertificateConfigMapRef: "string",
},
},
localStorageSettings: {
persistentVolumeClaimRef: "string",
},
mqttSettings: {
authentication: {
method: "string",
serviceAccountTokenSettings: {
audience: "string",
},
systemAssignedManagedIdentitySettings: {
audience: "string",
},
userAssignedManagedIdentitySettings: {
clientId: "string",
tenantId: "string",
scope: "string",
},
x509CertificateSettings: {
secretRef: "string",
},
},
clientIdPrefix: "string",
cloudEventAttributes: "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:
dataExplorerSettings:
authentication:
method: any
systemAssignedManagedIdentitySettings:
audience: string
userAssignedManagedIdentitySettings:
clientId: string
scope: string
tenantId: string
batching:
latencySeconds: 0
maxMessages: 0
database: string
host: string
dataLakeStorageSettings:
authentication:
accessTokenSettings:
secretRef: string
method: string
systemAssignedManagedIdentitySettings:
audience: string
userAssignedManagedIdentitySettings:
clientId: string
scope: string
tenantId: string
batching:
latencySeconds: 0
maxMessages: 0
host: string
endpointType: string
fabricOneLakeSettings:
authentication:
method: any
systemAssignedManagedIdentitySettings:
audience: string
userAssignedManagedIdentitySettings:
clientId: string
scope: string
tenantId: string
batching:
latencySeconds: 0
maxMessages: 0
host: string
names:
lakehouseName: string
workspaceName: string
oneLakePathType: string
kafkaSettings:
authentication:
method: string
saslSettings:
saslType: string
secretRef: string
systemAssignedManagedIdentitySettings:
audience: string
userAssignedManagedIdentitySettings:
clientId: string
scope: string
tenantId: string
x509CertificateSettings:
secretRef: string
batching:
latencyMs: 0
maxBytes: 0
maxMessages: 0
mode: string
cloudEventAttributes: string
compression: string
consumerGroupId: string
copyMqttProperties: string
host: string
kafkaAcks: string
partitionStrategy: string
tls:
mode: string
trustedCaCertificateConfigMapRef: string
localStorageSettings:
persistentVolumeClaimRef: string
mqttSettings:
authentication:
method: string
serviceAccountTokenSettings:
audience: string
systemAssignedManagedIdentitySettings:
audience: string
userAssignedManagedIdentitySettings:
clientId: string
scope: string
tenantId: string
x509CertificateSettings:
secretRef: string
clientIdPrefix: string
cloudEventAttributes: 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:
- Extended
Location Pulumi.Azure Native. Io TOperations. Inputs. Extended Location - Edge location of the resource.
- Instance
Name string - Name of instance.
- Resource
Group stringName - The name of the resource group. The name is case insensitive.
- Dataflow
Endpoint stringName - Name of Instance dataflowEndpoint resource
- Properties
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Properties - The resource-specific properties for this resource.
- Extended
Location ExtendedLocation Args - Edge location of the resource.
- Instance
Name string - Name of instance.
- Resource
Group stringName - The name of the resource group. The name is case insensitive.
- Dataflow
Endpoint stringName - Name of Instance dataflowEndpoint resource
- Properties
Dataflow
Endpoint Properties Args - The resource-specific properties for this resource.
- extended
Location ExtendedLocation - Edge location of the resource.
- instance
Name String - Name of instance.
- resource
Group StringName - The name of the resource group. The name is case insensitive.
- dataflow
Endpoint StringName - Name of Instance dataflowEndpoint resource
- properties
Dataflow
Endpoint Properties - The resource-specific properties for this resource.
- extended
Location ExtendedLocation - Edge location of the resource.
- instance
Name string - Name of instance.
- resource
Group stringName - The name of the resource group. The name is case insensitive.
- dataflow
Endpoint stringName - Name of Instance dataflowEndpoint resource
- properties
Dataflow
Endpoint Properties - The resource-specific properties for this resource.
- extended_
location ExtendedLocation Args - Edge location of the resource.
- instance_
name str - Name of instance.
- resource_
group_ strname - The name of the resource group. The name is case insensitive.
- dataflow_
endpoint_ strname - Name of Instance dataflowEndpoint resource
- properties
Dataflow
Endpoint Properties Args - The resource-specific properties for this resource.
- extended
Location Property Map - Edge location of the resource.
- instance
Name String - Name of instance.
- resource
Group StringName - The name of the resource group. The name is case insensitive.
- dataflow
Endpoint StringName - 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:
- Azure
Api stringVersion - The Azure API version of the resource.
- Id string
- The provider-assigned unique ID for this managed resource.
- Name string
- The name of the resource
- System
Data Pulumi.Azure Native. Io TOperations. Outputs. System Data Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- Type string
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- Azure
Api stringVersion - The Azure API version of the resource.
- Id string
- The provider-assigned unique ID for this managed resource.
- Name string
- The name of the resource
- System
Data SystemData Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- Type string
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- azure
Api StringVersion - The Azure API version of the resource.
- id String
- The provider-assigned unique ID for this managed resource.
- name String
- The name of the resource
- system
Data SystemData Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- type String
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- azure
Api stringVersion - The Azure API version of the resource.
- id string
- The provider-assigned unique ID for this managed resource.
- name string
- The name of the resource
- system
Data SystemData Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- type string
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- azure_
api_ strversion - The Azure API version of the resource.
- id str
- The provider-assigned unique ID for this managed resource.
- name str
- The name of the resource
- system_
data SystemData Response - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- type str
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
- azure
Api StringVersion - The Azure API version of the resource.
- id String
- The provider-assigned unique ID for this managed resource.
- name String
- The name of the resource
- system
Data Property Map - Azure Resource Manager metadata containing createdBy and modifiedBy information.
- type String
- The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"
Supporting Types
BatchingConfiguration, BatchingConfigurationArgs
- Latency
Seconds int - Batching latency in seconds.
- Max
Messages int - Maximum number of messages in a batch.
- Latency
Seconds int - Batching latency in seconds.
- Max
Messages int - Maximum number of messages in a batch.
- latency
Seconds Integer - Batching latency in seconds.
- max
Messages Integer - Maximum number of messages in a batch.
- latency
Seconds number - Batching latency in seconds.
- max
Messages 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.
- latency
Seconds Number - Batching latency in seconds.
- max
Messages Number - Maximum number of messages in a batch.
BatchingConfigurationResponse, BatchingConfigurationResponseArgs
- Latency
Seconds int - Batching latency in seconds.
- Max
Messages int - Maximum number of messages in a batch.
- Latency
Seconds int - Batching latency in seconds.
- Max
Messages int - Maximum number of messages in a batch.
- latency
Seconds Integer - Batching latency in seconds.
- max
Messages Integer - Maximum number of messages in a batch.
- latency
Seconds number - Batching latency in seconds.
- max
Messages 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.
- latency
Seconds Number - Batching latency in seconds.
- max
Messages Number - Maximum number of messages in a batch.
BrokerProtocolType, BrokerProtocolTypeArgs
- Mqtt
- Mqttprotocol broker
- Web
Sockets - WebSocketsprotocol websocket
- Broker
Protocol Type Mqtt - Mqttprotocol broker
- Broker
Protocol Type Web Sockets - WebSocketsprotocol websocket
- Mqtt
- Mqttprotocol broker
- Web
Sockets - WebSocketsprotocol websocket
- Mqtt
- Mqttprotocol broker
- Web
Sockets - WebSocketsprotocol websocket
- MQTT
- Mqttprotocol broker
- WEB_SOCKETS
- WebSocketsprotocol websocket
- "Mqtt"
- Mqttprotocol broker
- "Web
Sockets" - WebSocketsprotocol websocket
CloudEventAttributeType, CloudEventAttributeTypeArgs
- Propagate
- PropagatePropagate type
- Create
Or Remap - CreateOrRemapCreateOrRemap type
- Cloud
Event Attribute Type Propagate - PropagatePropagate type
- Cloud
Event Attribute Type Create Or Remap - CreateOrRemapCreateOrRemap type
- Propagate
- PropagatePropagate type
- Create
Or Remap - CreateOrRemapCreateOrRemap type
- Propagate
- PropagatePropagate type
- Create
Or Remap - CreateOrRemapCreateOrRemap type
- PROPAGATE
- PropagatePropagate type
- CREATE_OR_REMAP
- CreateOrRemapCreateOrRemap type
- "Propagate"
- PropagatePropagate type
- "Create
Or Remap" - CreateOrRemapCreateOrRemap type
DataLakeStorageAuthMethod, DataLakeStorageAuthMethodArgs
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Access
Token - AccessTokenAccessToken Option
- Data
Lake Storage Auth Method System Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- Data
Lake Storage Auth Method User Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Data
Lake Storage Auth Method Access Token - AccessTokenAccessToken Option
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Access
Token - AccessTokenAccessToken Option
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Access
Token - AccessTokenAccessToken Option
- SYSTEM_ASSIGNED_MANAGED_IDENTITY
- SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- USER_ASSIGNED_MANAGED_IDENTITY
- UserAssignedManagedIdentityUserAssignedManagedIdentity type
- ACCESS_TOKEN
- AccessTokenAccessToken Option
- "System
Assigned Managed Identity" - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- "User
Assigned Managed Identity" - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- "Access
Token" - AccessTokenAccessToken Option
DataflowEndpointAuthenticationAccessToken, DataflowEndpointAuthenticationAccessTokenArgs
- Secret
Ref string - Token secret name.
- Secret
Ref string - Token secret name.
- secret
Ref String - Token secret name.
- secret
Ref string - Token secret name.
- secret_
ref str - Token secret name.
- secret
Ref String - Token secret name.
DataflowEndpointAuthenticationAccessTokenResponse, DataflowEndpointAuthenticationAccessTokenResponseArgs
- Secret
Ref string - Token secret name.
- Secret
Ref string - Token secret name.
- secret
Ref String - Token secret name.
- secret
Ref string - Token secret name.
- secret_
ref str - Token secret name.
- secret
Ref String - Token secret name.
DataflowEndpointAuthenticationSasl, DataflowEndpointAuthenticationSaslArgs
- Sasl
Type string | Pulumi.Azure Native. Io TOperations. Dataflow Endpoint Authentication Sasl Type - Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
- Secret
Ref string - Token secret name.
- Sasl
Type string | DataflowEndpoint Authentication Sasl Type - Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
- Secret
Ref string - Token secret name.
- sasl
Type String | DataflowEndpoint Authentication Sasl Type - Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
- secret
Ref String - Token secret name.
- sasl
Type string | DataflowEndpoint Authentication Sasl Type - Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
- secret
Ref string - Token secret name.
- sasl_
type str | DataflowEndpoint Authentication Sasl Type - Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
- secret_
ref str - Token secret name.
- sasl
Type String | "Plain" | "ScramSha256" | "Scram Sha512" - Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
- secret
Ref String - Token secret name.
DataflowEndpointAuthenticationSaslResponse, DataflowEndpointAuthenticationSaslResponseArgs
- sasl_
type str - Type of SASL authentication. Can be PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512.
- secret_
ref str - Token secret name.
DataflowEndpointAuthenticationSaslType, DataflowEndpointAuthenticationSaslTypeArgs
- Plain
- PlainPLAIN Type
- Scram
Sha256 - ScramSha256SCRAM_SHA_256 Type
- Scram
Sha512 - ScramSha512SCRAM_SHA_512 Type
- Dataflow
Endpoint Authentication Sasl Type Plain - PlainPLAIN Type
- Dataflow
Endpoint Authentication Sasl Type Scram Sha256 - ScramSha256SCRAM_SHA_256 Type
- Dataflow
Endpoint Authentication Sasl Type Scram Sha512 - ScramSha512SCRAM_SHA_512 Type
- Plain
- PlainPLAIN Type
- Scram
Sha256 - ScramSha256SCRAM_SHA_256 Type
- Scram
Sha512 - ScramSha512SCRAM_SHA_512 Type
- Plain
- PlainPLAIN Type
- Scram
Sha256 - ScramSha256SCRAM_SHA_256 Type
- Scram
Sha512 - ScramSha512SCRAM_SHA_512 Type
- PLAIN
- PlainPLAIN Type
- SCRAM_SHA256
- ScramSha256SCRAM_SHA_256 Type
- SCRAM_SHA512
- ScramSha512SCRAM_SHA_512 Type
- "Plain"
- PlainPLAIN Type
- "Scram
Sha256" - ScramSha256SCRAM_SHA_256 Type
- "Scram
Sha512" - 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
DataflowEndpointAuthenticationUserAssignedManagedIdentityResponse, DataflowEndpointAuthenticationUserAssignedManagedIdentityResponseArgs
DataflowEndpointAuthenticationX509, DataflowEndpointAuthenticationX509Args
- Secret
Ref string - Secret reference of the X.509 certificate.
- Secret
Ref string - Secret reference of the X.509 certificate.
- secret
Ref String - Secret reference of the X.509 certificate.
- secret
Ref string - Secret reference of the X.509 certificate.
- secret_
ref str - Secret reference of the X.509 certificate.
- secret
Ref String - Secret reference of the X.509 certificate.
DataflowEndpointAuthenticationX509Response, DataflowEndpointAuthenticationX509ResponseArgs
- Secret
Ref string - Secret reference of the X.509 certificate.
- Secret
Ref string - Secret reference of the X.509 certificate.
- secret
Ref String - Secret reference of the X.509 certificate.
- secret
Ref string - Secret reference of the X.509 certificate.
- secret_
ref str - Secret reference of the X.509 certificate.
- secret
Ref String - Secret reference of the X.509 certificate.
DataflowEndpointDataExplorer, DataflowEndpointDataExplorerArgs
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Data Explorer Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Database string
- Database name.
- Host string
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- Batching
Pulumi.
Azure Native. Io TOperations. Inputs. Batching Configuration - Azure Data Explorer endpoint batching configuration.
- Authentication
Dataflow
Endpoint Data Explorer Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Database string
- Database name.
- Host string
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- Batching
Batching
Configuration - Azure Data Explorer endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Explorer Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- database String
- Database name.
- host String
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- batching
Batching
Configuration - Azure Data Explorer endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Explorer Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- database string
- Database name.
- host string
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- batching
Batching
Configuration - Azure Data Explorer endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Explorer Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- database str
- Database name.
- host str
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- batching
Batching
Configuration - Azure Data Explorer endpoint batching configuration.
- authentication Property Map
- Authentication configuration. NOTE - only authentication property is allowed per entry.
- 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.
DataflowEndpointDataExplorerAuthentication, DataflowEndpointDataExplorerAuthenticationArgs
- Method object
- Mode of Authentication.
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- Method interface{}
- Mode of Authentication.
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method Object
- Mode of Authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method any
- Mode of Authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method Any
- Mode of Authentication.
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method Any
- Mode of Authentication.
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
DataflowEndpointDataExplorerAuthenticationResponse, DataflowEndpointDataExplorerAuthenticationResponseArgs
- Method object
- Mode of Authentication.
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- Method interface{}
- Mode of Authentication.
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method Object
- Mode of Authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method any
- Mode of Authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method Any
- Mode of Authentication.
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method Any
- Mode of Authentication.
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
DataflowEndpointDataExplorerResponse, DataflowEndpointDataExplorerResponseArgs
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Data Explorer Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Database string
- Database name.
- Host string
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- Batching
Pulumi.
Azure Native. Io TOperations. Inputs. Batching Configuration Response - Azure Data Explorer endpoint batching configuration.
- Authentication
Dataflow
Endpoint Data Explorer Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Database string
- Database name.
- Host string
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- Batching
Batching
Configuration Response - Azure Data Explorer endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Explorer Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- database String
- Database name.
- host String
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- batching
Batching
Configuration Response - Azure Data Explorer endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Explorer Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- database string
- Database name.
- host string
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- batching
Batching
Configuration Response - Azure Data Explorer endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Explorer Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- database str
- Database name.
- host str
- Host of the Azure Data Explorer in the form of ..kusto.windows.net .
- batching
Batching
Configuration Response - Azure Data Explorer endpoint batching configuration.
- authentication Property Map
- Authentication configuration. NOTE - only authentication property is allowed per entry.
- 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
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Data Lake Storage Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Host string
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- Batching
Pulumi.
Azure Native. Io TOperations. Inputs. Batching Configuration - Azure Data Lake endpoint batching configuration.
- Authentication
Dataflow
Endpoint Data Lake Storage Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Host string
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- Batching
Batching
Configuration - Azure Data Lake endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Lake Storage Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host String
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- batching
Batching
Configuration - Azure Data Lake endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Lake Storage Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host string
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- batching
Batching
Configuration - Azure Data Lake endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Lake Storage Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host str
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- batching
Batching
Configuration - Azure Data Lake endpoint batching configuration.
- authentication Property Map
- Authentication configuration. NOTE - only authentication property is allowed per entry.
- 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.
DataflowEndpointDataLakeStorageAuthentication, DataflowEndpointDataLakeStorageAuthenticationArgs
- Method
string | Pulumi.
Azure Native. Io TOperations. Data Lake Storage Auth Method - Mode of Authentication.
- Access
Token Pulumi.Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication Access Token - SAS token authentication.
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- Method
string | Data
Lake Storage Auth Method - Mode of Authentication.
- Access
Token DataflowSettings Endpoint Authentication Access Token - SAS token authentication.
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method
String | Data
Lake Storage Auth Method - Mode of Authentication.
- access
Token DataflowSettings Endpoint Authentication Access Token - SAS token authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method
string | Data
Lake Storage Auth Method - Mode of Authentication.
- access
Token DataflowSettings Endpoint Authentication Access Token - SAS token authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method
str | Data
Lake Storage Auth Method - Mode of Authentication.
- access_
token_ Dataflowsettings Endpoint Authentication Access Token - SAS token authentication.
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method
String | "System
Assigned Managed Identity" | "User Assigned Managed Identity" | "Access Token" - Mode of Authentication.
- access
Token Property MapSettings - SAS token authentication.
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
DataflowEndpointDataLakeStorageAuthenticationResponse, DataflowEndpointDataLakeStorageAuthenticationResponseArgs
- Method string
- Mode of Authentication.
- Access
Token Pulumi.Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication Access Token Response - SAS token authentication.
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- Method string
- Mode of Authentication.
- Access
Token DataflowSettings Endpoint Authentication Access Token Response - SAS token authentication.
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method String
- Mode of Authentication.
- access
Token DataflowSettings Endpoint Authentication Access Token Response - SAS token authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method string
- Mode of Authentication.
- access
Token DataflowSettings Endpoint Authentication Access Token Response - SAS token authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method str
- Mode of Authentication.
- access_
token_ Dataflowsettings Endpoint Authentication Access Token Response - SAS token authentication.
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method String
- Mode of Authentication.
- access
Token Property MapSettings - SAS token authentication.
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
DataflowEndpointDataLakeStorageResponse, DataflowEndpointDataLakeStorageResponseArgs
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Data Lake Storage Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Host string
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- Batching
Pulumi.
Azure Native. Io TOperations. Inputs. Batching Configuration Response - Azure Data Lake endpoint batching configuration.
- Authentication
Dataflow
Endpoint Data Lake Storage Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Host string
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- Batching
Batching
Configuration Response - Azure Data Lake endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Lake Storage Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host String
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- batching
Batching
Configuration Response - Azure Data Lake endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Lake Storage Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host string
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- batching
Batching
Configuration Response - Azure Data Lake endpoint batching configuration.
- authentication
Dataflow
Endpoint Data Lake Storage Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host str
- Host of the Azure Data Lake in the form of .blob.core.windows.net .
- batching
Batching
Configuration Response - Azure Data Lake endpoint batching configuration.
- authentication Property Map
- Authentication configuration. NOTE - only authentication property is allowed per entry.
- 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
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Fabric One Lake Authentication - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- Host string
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- Names
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Fabric One Lake Names - Names of the workspace and lakehouse.
- One
Lake string | Pulumi.Path Type Azure Native. Io TOperations. Dataflow Endpoint Fabric Path Type - Type of location of the data in the workspace. Can be either tables or files.
- Batching
Pulumi.
Azure Native. Io TOperations. Inputs. Batching Configuration - Batching configuration.
- Authentication
Dataflow
Endpoint Fabric One Lake Authentication - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- Host string
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- Names
Dataflow
Endpoint Fabric One Lake Names - Names of the workspace and lakehouse.
- One
Lake string | DataflowPath Type Endpoint Fabric Path Type - Type of location of the data in the workspace. Can be either tables or files.
- Batching
Batching
Configuration - Batching configuration.
- authentication
Dataflow
Endpoint Fabric One Lake Authentication - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- host String
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- names
Dataflow
Endpoint Fabric One Lake Names - Names of the workspace and lakehouse.
- one
Lake String | DataflowPath Type Endpoint Fabric Path Type - Type of location of the data in the workspace. Can be either tables or files.
- batching
Batching
Configuration - Batching configuration.
- authentication
Dataflow
Endpoint Fabric One Lake Authentication - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- host string
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- names
Dataflow
Endpoint Fabric One Lake Names - Names of the workspace and lakehouse.
- one
Lake string | DataflowPath Type Endpoint Fabric Path Type - Type of location of the data in the workspace. Can be either tables or files.
- batching
Batching
Configuration - Batching configuration.
- authentication
Dataflow
Endpoint Fabric One Lake Authentication - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- host str
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- names
Dataflow
Endpoint Fabric One Lake Names - Names of the workspace and lakehouse.
- one_
lake_ str | Dataflowpath_ type Endpoint Fabric Path Type - Type of location of the data in the workspace. Can be either tables or files.
- batching
Batching
Configuration - Batching configuration.
- authentication Property Map
- Authentication configuration. NOTE - only one authentication property is allowed per entry.
- host String
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- names Property Map
- Names of the workspace and lakehouse.
- one
Lake String | "Files" | "Tables"Path Type - Type of location of the data in the workspace. Can be either tables or files.
- batching Property Map
- Batching configuration.
DataflowEndpointFabricOneLakeAuthentication, DataflowEndpointFabricOneLakeAuthenticationArgs
- Method object
- Mode of Authentication.
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- Method interface{}
- Mode of Authentication.
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method Object
- Mode of Authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method any
- Mode of Authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method Any
- Mode of Authentication.
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- method Any
- Mode of Authentication.
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
DataflowEndpointFabricOneLakeAuthenticationResponse, DataflowEndpointFabricOneLakeAuthenticationResponseArgs
- Method object
- Mode of Authentication.
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- Method interface{}
- Mode of Authentication.
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method Object
- Mode of Authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method any
- Mode of Authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method Any
- Mode of Authentication.
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- method Any
- Mode of Authentication.
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
DataflowEndpointFabricOneLakeNames, DataflowEndpointFabricOneLakeNamesArgs
- Lakehouse
Name string - Lakehouse name.
- Workspace
Name string - Workspace name.
- Lakehouse
Name string - Lakehouse name.
- Workspace
Name string - Workspace name.
- lakehouse
Name String - Lakehouse name.
- workspace
Name String - Workspace name.
- lakehouse
Name string - Lakehouse name.
- workspace
Name string - Workspace name.
- lakehouse_
name str - Lakehouse name.
- workspace_
name str - Workspace name.
- lakehouse
Name String - Lakehouse name.
- workspace
Name String - Workspace name.
DataflowEndpointFabricOneLakeNamesResponse, DataflowEndpointFabricOneLakeNamesResponseArgs
- Lakehouse
Name string - Lakehouse name.
- Workspace
Name string - Workspace name.
- Lakehouse
Name string - Lakehouse name.
- Workspace
Name string - Workspace name.
- lakehouse
Name String - Lakehouse name.
- workspace
Name String - Workspace name.
- lakehouse
Name string - Lakehouse name.
- workspace
Name string - Workspace name.
- lakehouse_
name str - Lakehouse name.
- workspace_
name str - Workspace name.
- lakehouse
Name String - Lakehouse name.
- workspace
Name String - Workspace name.
DataflowEndpointFabricOneLakeResponse, DataflowEndpointFabricOneLakeResponseArgs
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Fabric One Lake Authentication Response - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- Host string
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- Names
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Fabric One Lake Names Response - Names of the workspace and lakehouse.
- One
Lake stringPath Type - Type of location of the data in the workspace. Can be either tables or files.
- Batching
Pulumi.
Azure Native. Io TOperations. Inputs. Batching Configuration Response - Batching configuration.
- Authentication
Dataflow
Endpoint Fabric One Lake Authentication Response - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- Host string
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- Names
Dataflow
Endpoint Fabric One Lake Names Response - Names of the workspace and lakehouse.
- One
Lake stringPath Type - Type of location of the data in the workspace. Can be either tables or files.
- Batching
Batching
Configuration Response - Batching configuration.
- authentication
Dataflow
Endpoint Fabric One Lake Authentication Response - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- host String
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- names
Dataflow
Endpoint Fabric One Lake Names Response - Names of the workspace and lakehouse.
- one
Lake StringPath Type - Type of location of the data in the workspace. Can be either tables or files.
- batching
Batching
Configuration Response - Batching configuration.
- authentication
Dataflow
Endpoint Fabric One Lake Authentication Response - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- host string
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- names
Dataflow
Endpoint Fabric One Lake Names Response - Names of the workspace and lakehouse.
- one
Lake stringPath Type - Type of location of the data in the workspace. Can be either tables or files.
- batching
Batching
Configuration Response - Batching configuration.
- authentication
Dataflow
Endpoint Fabric One Lake Authentication Response - Authentication configuration. NOTE - only one authentication property is allowed per entry.
- host str
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- names
Dataflow
Endpoint Fabric One Lake Names Response - Names of the workspace and lakehouse.
- one_
lake_ strpath_ type - Type of location of the data in the workspace. Can be either tables or files.
- batching
Batching
Configuration Response - Batching configuration.
- authentication Property Map
- Authentication configuration. NOTE - only one authentication property is allowed per entry.
- host String
- Host of the Microsoft Fabric in the form of https://.fabric.microsoft.com.
- names Property Map
- Names of the workspace and lakehouse.
- one
Lake StringPath Type - 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
- Dataflow
Endpoint Fabric Path Type Files - FilesFILES Type
- Dataflow
Endpoint Fabric Path Type Tables - 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
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Kafka Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Host string
- Kafka endpoint host.
- Batching
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Kafka Batching - Batching configuration.
- Cloud
Event string | Pulumi.Attributes Azure Native. Io TOperations. Cloud Event Attribute Type - Cloud event mapping config.
- Compression
string | Pulumi.
Azure Native. Io TOperations. Dataflow Endpoint Kafka Compression - Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- Consumer
Group stringId - Consumer group ID.
- Copy
Mqtt string | Pulumi.Properties Azure Native. Io TOperations. Operational Mode - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- Kafka
Acks string | Pulumi.Azure Native. Io TOperations. Dataflow Endpoint Kafka Acks - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- Partition
Strategy string | Pulumi.Azure Native. Io TOperations. Dataflow Endpoint Kafka Partition Strategy - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- Tls
Pulumi.
Azure Native. Io TOperations. Inputs. Tls Properties - TLS configuration.
- Authentication
Dataflow
Endpoint Kafka Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Host string
- Kafka endpoint host.
- Batching
Dataflow
Endpoint Kafka Batching - Batching configuration.
- Cloud
Event string | CloudAttributes Event Attribute Type - Cloud event mapping config.
- Compression
string | Dataflow
Endpoint Kafka Compression - Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- Consumer
Group stringId - Consumer group ID.
- Copy
Mqtt string | OperationalProperties Mode - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- Kafka
Acks string | DataflowEndpoint Kafka Acks - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- Partition
Strategy string | DataflowEndpoint Kafka Partition Strategy - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- Tls
Tls
Properties - TLS configuration.
- authentication
Dataflow
Endpoint Kafka Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host String
- Kafka endpoint host.
- batching
Dataflow
Endpoint Kafka Batching - Batching configuration.
- cloud
Event String | CloudAttributes Event Attribute Type - Cloud event mapping config.
- compression
String | Dataflow
Endpoint Kafka Compression - Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- consumer
Group StringId - Consumer group ID.
- copy
Mqtt String | OperationalProperties Mode - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- kafka
Acks String | DataflowEndpoint Kafka Acks - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- partition
Strategy String | DataflowEndpoint Kafka Partition Strategy - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- tls
Tls
Properties - TLS configuration.
- authentication
Dataflow
Endpoint Kafka Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host string
- Kafka endpoint host.
- batching
Dataflow
Endpoint Kafka Batching - Batching configuration.
- cloud
Event string | CloudAttributes Event Attribute Type - Cloud event mapping config.
- compression
string | Dataflow
Endpoint Kafka Compression - Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- consumer
Group stringId - Consumer group ID.
- copy
Mqtt string | OperationalProperties Mode - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- kafka
Acks string | DataflowEndpoint Kafka Acks - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- partition
Strategy string | DataflowEndpoint Kafka Partition Strategy - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- tls
Tls
Properties - TLS configuration.
- authentication
Dataflow
Endpoint Kafka Authentication - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host str
- Kafka endpoint host.
- batching
Dataflow
Endpoint Kafka Batching - Batching configuration.
- cloud_
event_ str | Cloudattributes Event Attribute Type - Cloud event mapping config.
- compression
str | Dataflow
Endpoint Kafka Compression - Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- consumer_
group_ strid - Consumer group ID.
- copy_
mqtt_ str | Operationalproperties Mode - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- kafka_
acks str | DataflowEndpoint Kafka Acks - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- partition_
strategy str | DataflowEndpoint Kafka Partition Strategy - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- tls
Tls
Properties - TLS configuration.
- authentication Property Map
- Authentication configuration. NOTE - only authentication property is allowed per entry.
- host String
- Kafka endpoint host.
- batching Property Map
- Batching configuration.
- cloud
Event String | "Propagate" | "CreateAttributes Or Remap" - Cloud event mapping config.
- compression String | "None" | "Gzip" | "Snappy" | "Lz4"
- Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- consumer
Group StringId - Consumer group ID.
- copy
Mqtt String | "Enabled" | "Disabled"Properties - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- kafka
Acks String | "Zero" | "One" | "All" - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- partition
Strategy String | "Default" | "Static" | "Topic" | "Property" - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- tls Property Map
- TLS configuration.
DataflowEndpointKafkaAcks, DataflowEndpointKafkaAcksArgs
- Zero
- ZeroZERO Option
- One
- OneONE Option
- All
- AllALL Option
- Dataflow
Endpoint Kafka Acks Zero - ZeroZERO Option
- Dataflow
Endpoint Kafka Acks One - OneONE Option
- Dataflow
Endpoint Kafka Acks 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
- "Zero"
- ZeroZERO Option
- "One"
- OneONE Option
- "All"
- AllALL Option
DataflowEndpointKafkaAuthentication, DataflowEndpointKafkaAuthenticationArgs
- Method
string | Pulumi.
Azure Native. Io TOperations. Kafka Auth Method - Mode of Authentication.
- Sasl
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication Sasl - SASL authentication.
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- X509Certificate
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication X509 - X.509 certificate authentication.
- Method
string | Kafka
Auth Method - Mode of Authentication.
- Sasl
Settings DataflowEndpoint Authentication Sasl - SASL authentication.
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- X509Certificate
Settings DataflowEndpoint Authentication X509 - X.509 certificate authentication.
- method
String | Kafka
Auth Method - Mode of Authentication.
- sasl
Settings DataflowEndpoint Authentication Sasl - SASL authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- x509Certificate
Settings DataflowEndpoint Authentication X509 - X.509 certificate authentication.
- method
string | Kafka
Auth Method - Mode of Authentication.
- sasl
Settings DataflowEndpoint Authentication Sasl - SASL authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- x509Certificate
Settings DataflowEndpoint Authentication X509 - X.509 certificate authentication.
- method
str | Kafka
Auth Method - Mode of Authentication.
- sasl_
settings DataflowEndpoint Authentication Sasl - SASL authentication.
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- x509_
certificate_ Dataflowsettings Endpoint Authentication X509 - X.509 certificate authentication.
- method
String | "System
Assigned Managed Identity" | "User Assigned Managed Identity" | "Sasl" | "X509Certificate" | "Anonymous" - Mode of Authentication.
- sasl
Settings Property Map - SASL authentication.
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
- x509Certificate
Settings Property Map - X.509 certificate authentication.
DataflowEndpointKafkaAuthenticationResponse, DataflowEndpointKafkaAuthenticationResponseArgs
- Method string
- Mode of Authentication.
- Sasl
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication Sasl Response - SASL authentication.
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- X509Certificate
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication X509Response - X.509 certificate authentication.
- Method string
- Mode of Authentication.
- Sasl
Settings DataflowEndpoint Authentication Sasl Response - SASL authentication.
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- X509Certificate
Settings DataflowEndpoint Authentication X509Response - X.509 certificate authentication.
- method String
- Mode of Authentication.
- sasl
Settings DataflowEndpoint Authentication Sasl Response - SASL authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- x509Certificate
Settings DataflowEndpoint Authentication X509Response - X.509 certificate authentication.
- method string
- Mode of Authentication.
- sasl
Settings DataflowEndpoint Authentication Sasl Response - SASL authentication.
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- x509Certificate
Settings DataflowEndpoint Authentication X509Response - X.509 certificate authentication.
- method str
- Mode of Authentication.
- sasl_
settings DataflowEndpoint Authentication Sasl Response - SASL authentication.
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- x509_
certificate_ Dataflowsettings Endpoint Authentication X509Response - X.509 certificate authentication.
- method String
- Mode of Authentication.
- sasl
Settings Property Map - SASL authentication.
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
- x509Certificate
Settings Property Map - X.509 certificate authentication.
DataflowEndpointKafkaBatching, DataflowEndpointKafkaBatchingArgs
- 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
string | Pulumi.
Azure Native. Io TOperations. Operational Mode - 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
string | Operational
Mode - Mode for batching.
- latency
Ms Integer - Batching latency in milliseconds.
- max
Bytes Integer - Maximum number of bytes in a batch.
- max
Messages Integer - Maximum number of messages in a batch.
- mode
String | Operational
Mode - Mode for batching.
- latency
Ms number - Batching latency in milliseconds.
- max
Bytes number - Maximum number of bytes in a batch.
- max
Messages number - Maximum number of messages in a batch.
- mode
string | Operational
Mode - 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 | Operational
Mode - Mode for batching.
- latency
Ms Number - Batching latency in milliseconds.
- max
Bytes Number - Maximum number of bytes in a batch.
- max
Messages Number - Maximum number of messages in a batch.
- mode String | "Enabled" | "Disabled"
- Mode for batching.
DataflowEndpointKafkaBatchingResponse, DataflowEndpointKafkaBatchingResponseArgs
- 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 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 string
- Mode for batching.
- latency
Ms Integer - Batching latency in milliseconds.
- max
Bytes Integer - Maximum number of bytes in a batch.
- max
Messages Integer - Maximum number of messages in a batch.
- mode String
- Mode for batching.
- latency
Ms number - Batching latency in milliseconds.
- max
Bytes number - Maximum number of bytes in a batch.
- max
Messages 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.
- latency
Ms Number - Batching latency in milliseconds.
- max
Bytes Number - Maximum number of bytes in a batch.
- max
Messages 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
- Dataflow
Endpoint Kafka Compression None - NoneNONE Option
- Dataflow
Endpoint Kafka Compression Gzip - GzipGzip Option
- Dataflow
Endpoint Kafka Compression Snappy - SnappySNAPPY Option
- Dataflow
Endpoint Kafka Compression 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
- "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
- Dataflow
Endpoint Kafka Partition Strategy Default - DefaultDefault: Assigns messages to random partitions, using a round-robin algorithm.
- Dataflow
Endpoint Kafka Partition Strategy Static - StaticStatic: Assigns messages to a fixed partition number that's derived from the instance ID of the dataflow.
- Dataflow
Endpoint Kafka Partition Strategy Topic - TopicTOPIC Option
- Dataflow
Endpoint Kafka Partition Strategy 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
- "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
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Kafka Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Host string
- Kafka endpoint host.
- Batching
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Kafka Batching Response - Batching configuration.
- Cloud
Event stringAttributes - Cloud event mapping config.
- Compression string
- Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- Consumer
Group stringId - Consumer group ID.
- Copy
Mqtt stringProperties - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- Kafka
Acks string - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- Partition
Strategy string - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- Tls
Pulumi.
Azure Native. Io TOperations. Inputs. Tls Properties Response - TLS configuration.
- Authentication
Dataflow
Endpoint Kafka Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- Host string
- Kafka endpoint host.
- Batching
Dataflow
Endpoint Kafka Batching Response - Batching configuration.
- Cloud
Event stringAttributes - Cloud event mapping config.
- Compression string
- Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- Consumer
Group stringId - Consumer group ID.
- Copy
Mqtt stringProperties - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- Kafka
Acks string - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- Partition
Strategy string - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- Tls
Tls
Properties Response - TLS configuration.
- authentication
Dataflow
Endpoint Kafka Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host String
- Kafka endpoint host.
- batching
Dataflow
Endpoint Kafka Batching Response - Batching configuration.
- cloud
Event StringAttributes - Cloud event mapping config.
- compression String
- Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- consumer
Group StringId - Consumer group ID.
- copy
Mqtt StringProperties - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- kafka
Acks String - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- partition
Strategy String - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- tls
Tls
Properties Response - TLS configuration.
- authentication
Dataflow
Endpoint Kafka Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host string
- Kafka endpoint host.
- batching
Dataflow
Endpoint Kafka Batching Response - Batching configuration.
- cloud
Event stringAttributes - Cloud event mapping config.
- compression string
- Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- consumer
Group stringId - Consumer group ID.
- copy
Mqtt stringProperties - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- kafka
Acks string - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- partition
Strategy string - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- tls
Tls
Properties Response - TLS configuration.
- authentication
Dataflow
Endpoint Kafka Authentication Response - Authentication configuration. NOTE - only authentication property is allowed per entry.
- host str
- Kafka endpoint host.
- batching
Dataflow
Endpoint Kafka Batching Response - Batching configuration.
- cloud_
event_ strattributes - Cloud event mapping config.
- compression str
- Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- consumer_
group_ strid - Consumer group ID.
- copy_
mqtt_ strproperties - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- 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
Tls
Properties Response - TLS configuration.
- authentication Property Map
- Authentication configuration. NOTE - only authentication property is allowed per entry.
- host String
- Kafka endpoint host.
- batching Property Map
- Batching configuration.
- cloud
Event StringAttributes - Cloud event mapping config.
- compression String
- Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.
- consumer
Group StringId - Consumer group ID.
- copy
Mqtt StringProperties - Copy Broker properties. No effect if the endpoint is used as a source or if the dataflow doesn't have an Broker source.
- kafka
Acks String - Kafka acks. Can be all, one, or zero. No effect if the endpoint is used as a source.
- partition
Strategy String - Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.
- tls Property Map
- TLS configuration.
DataflowEndpointLocalStorage, DataflowEndpointLocalStorageArgs
- Persistent
Volume stringClaim Ref - Persistent volume claim name.
- Persistent
Volume stringClaim Ref - Persistent volume claim name.
- persistent
Volume StringClaim Ref - Persistent volume claim name.
- persistent
Volume stringClaim Ref - Persistent volume claim name.
- persistent_
volume_ strclaim_ ref - Persistent volume claim name.
- persistent
Volume StringClaim Ref - Persistent volume claim name.
DataflowEndpointLocalStorageResponse, DataflowEndpointLocalStorageResponseArgs
- Persistent
Volume stringClaim Ref - Persistent volume claim name.
- Persistent
Volume stringClaim Ref - Persistent volume claim name.
- persistent
Volume StringClaim Ref - Persistent volume claim name.
- persistent
Volume stringClaim Ref - Persistent volume claim name.
- persistent_
volume_ strclaim_ ref - Persistent volume claim name.
- persistent
Volume StringClaim Ref - Persistent volume claim name.
DataflowEndpointMqtt, DataflowEndpointMqttArgs
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Mqtt Authentication - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- Client
Id stringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- Cloud
Event string | Pulumi.Attributes Azure Native. Io TOperations. Cloud Event Attribute Type - Cloud event mapping config.
- Host string
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- Keep
Alive intSeconds - Broker KeepAlive for connection in seconds.
- Max
Inflight intMessages - 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.
Azure Native. Io TOperations. Broker Protocol Type - Enable or disable websockets.
- Qos int
- Qos for Broker connection.
- Retain
string | Pulumi.
Azure Native. Io TOperations. Mqtt Retain Type - Whether or not to keep the retain setting.
- Session
Expiry intSeconds - Session expiry in seconds.
- Tls
Pulumi.
Azure Native. Io TOperations. Inputs. Tls Properties - TLS configuration.
- Authentication
Dataflow
Endpoint Mqtt Authentication - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- Client
Id stringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- Cloud
Event string | CloudAttributes Event Attribute Type - Cloud event mapping config.
- Host string
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- Keep
Alive intSeconds - Broker KeepAlive for connection in seconds.
- Max
Inflight intMessages - 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 | Broker
Protocol Type - Enable or disable websockets.
- Qos int
- Qos for Broker connection.
- Retain
string | Mqtt
Retain Type - Whether or not to keep the retain setting.
- Session
Expiry intSeconds - Session expiry in seconds.
- Tls
Tls
Properties - TLS configuration.
- authentication
Dataflow
Endpoint Mqtt Authentication - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- client
Id StringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- cloud
Event String | CloudAttributes Event Attribute Type - Cloud event mapping config.
- host String
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- keep
Alive IntegerSeconds - Broker KeepAlive for connection in seconds.
- max
Inflight IntegerMessages - 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 | Broker
Protocol Type - Enable or disable websockets.
- qos Integer
- Qos for Broker connection.
- retain
String | Mqtt
Retain Type - Whether or not to keep the retain setting.
- session
Expiry IntegerSeconds - Session expiry in seconds.
- tls
Tls
Properties - TLS configuration.
- authentication
Dataflow
Endpoint Mqtt Authentication - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- client
Id stringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- cloud
Event string | CloudAttributes Event Attribute Type - Cloud event mapping config.
- host string
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- keep
Alive numberSeconds - Broker KeepAlive for connection in seconds.
- max
Inflight numberMessages - 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 | Broker
Protocol Type - Enable or disable websockets.
- qos number
- Qos for Broker connection.
- retain
string | Mqtt
Retain Type - Whether or not to keep the retain setting.
- session
Expiry numberSeconds - Session expiry in seconds.
- tls
Tls
Properties - TLS configuration.
- authentication
Dataflow
Endpoint Mqtt Authentication - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- client_
id_ strprefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- cloud_
event_ str | Cloudattributes Event Attribute Type - Cloud event mapping config.
- host str
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- keep_
alive_ intseconds - Broker KeepAlive for connection in seconds.
- max_
inflight_ intmessages - 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 | Broker
Protocol Type - Enable or disable websockets.
- qos int
- Qos for Broker connection.
- retain
str | Mqtt
Retain Type - Whether or not to keep the retain setting.
- session_
expiry_ intseconds - Session expiry in seconds.
- tls
Tls
Properties - TLS configuration.
- authentication Property Map
- authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- client
Id StringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- cloud
Event String | "Propagate" | "CreateAttributes Or Remap" - Cloud event mapping config.
- host String
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- keep
Alive NumberSeconds - Broker KeepAlive for connection in seconds.
- max
Inflight NumberMessages - 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" | "Web
Sockets" - Enable or disable websockets.
- qos Number
- Qos for Broker connection.
- retain String | "Keep" | "Never"
- Whether or not to keep the retain setting.
- session
Expiry NumberSeconds - Session expiry in seconds.
- tls Property Map
- TLS configuration.
DataflowEndpointMqttAuthentication, DataflowEndpointMqttAuthenticationArgs
- Method
string | Pulumi.
Azure Native. Io TOperations. Mqtt Auth Method - Mode of Authentication.
- Service
Account Pulumi.Token Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication Service Account Token - Kubernetes service account token authentication. Default audience if not set is aio-internal
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- X509Certificate
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication X509 - X.509 certificate authentication.
- Method
string | Mqtt
Auth Method - Mode of Authentication.
- Service
Account DataflowToken Settings Endpoint Authentication Service Account Token - Kubernetes service account token authentication. Default audience if not set is aio-internal
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- X509Certificate
Settings DataflowEndpoint Authentication X509 - X.509 certificate authentication.
- method
String | Mqtt
Auth Method - Mode of Authentication.
- service
Account DataflowToken Settings Endpoint Authentication Service Account Token - Kubernetes service account token authentication. Default audience if not set is aio-internal
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- x509Certificate
Settings DataflowEndpoint Authentication X509 - X.509 certificate authentication.
- method
string | Mqtt
Auth Method - Mode of Authentication.
- service
Account DataflowToken Settings Endpoint Authentication Service Account Token - Kubernetes service account token authentication. Default audience if not set is aio-internal
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- x509Certificate
Settings DataflowEndpoint Authentication X509 - X.509 certificate authentication.
- method
str | Mqtt
Auth Method - Mode of Authentication.
- service_
account_ Dataflowtoken_ settings Endpoint Authentication Service Account Token - Kubernetes service account token authentication. Default audience if not set is aio-internal
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity - User-assigned managed identity authentication.
- x509_
certificate_ Dataflowsettings Endpoint Authentication X509 - X.509 certificate authentication.
- method
String | "System
Assigned Managed Identity" | "User Assigned Managed Identity" | "Service Account Token" | "X509Certificate" | "Anonymous" - Mode of Authentication.
- service
Account Property MapToken Settings - Kubernetes service account token authentication. Default audience if not set is aio-internal
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
- x509Certificate
Settings Property Map - X.509 certificate authentication.
DataflowEndpointMqttAuthenticationResponse, DataflowEndpointMqttAuthenticationResponseArgs
- Method string
- Mode of Authentication.
- Service
Account Pulumi.Token Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication Service Account Token Response - Kubernetes service account token authentication. Default audience if not set is aio-internal
- System
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned Pulumi.Managed Identity Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- X509Certificate
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Authentication X509Response - X.509 certificate authentication.
- Method string
- Mode of Authentication.
- Service
Account DataflowToken Settings Endpoint Authentication Service Account Token Response - Kubernetes service account token authentication. Default audience if not set is aio-internal
- System
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- User
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- X509Certificate
Settings DataflowEndpoint Authentication X509Response - X.509 certificate authentication.
- method String
- Mode of Authentication.
- service
Account DataflowToken Settings Endpoint Authentication Service Account Token Response - Kubernetes service account token authentication. Default audience if not set is aio-internal
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- x509Certificate
Settings DataflowEndpoint Authentication X509Response - X.509 certificate authentication.
- method string
- Mode of Authentication.
- service
Account DataflowToken Settings Endpoint Authentication Service Account Token Response - Kubernetes service account token authentication. Default audience if not set is aio-internal
- system
Assigned DataflowManaged Identity Settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user
Assigned DataflowManaged Identity Settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- x509Certificate
Settings DataflowEndpoint Authentication X509Response - X.509 certificate authentication.
- method str
- Mode of Authentication.
- service_
account_ Dataflowtoken_ settings Endpoint Authentication Service Account Token Response - Kubernetes service account token authentication. Default audience if not set is aio-internal
- system_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication System Assigned Managed Identity Response - System-assigned managed identity authentication.
- user_
assigned_ Dataflowmanaged_ identity_ settings Endpoint Authentication User Assigned Managed Identity Response - User-assigned managed identity authentication.
- x509_
certificate_ Dataflowsettings Endpoint Authentication X509Response - X.509 certificate authentication.
- method String
- Mode of Authentication.
- service
Account Property MapToken Settings - Kubernetes service account token authentication. Default audience if not set is aio-internal
- system
Assigned Property MapManaged Identity Settings - System-assigned managed identity authentication.
- user
Assigned Property MapManaged Identity Settings - User-assigned managed identity authentication.
- x509Certificate
Settings Property Map - X.509 certificate authentication.
DataflowEndpointMqttResponse, DataflowEndpointMqttResponseArgs
- Authentication
Pulumi.
Azure Native. Io TOperations. Inputs. Dataflow Endpoint Mqtt Authentication Response - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- Client
Id stringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- Cloud
Event stringAttributes - Cloud event mapping config.
- Host string
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- Keep
Alive intSeconds - Broker KeepAlive for connection in seconds.
- Max
Inflight intMessages - 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.
- Session
Expiry intSeconds - Session expiry in seconds.
- Tls
Pulumi.
Azure Native. Io TOperations. Inputs. Tls Properties Response - TLS configuration.
- Authentication
Dataflow
Endpoint Mqtt Authentication Response - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- Client
Id stringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- Cloud
Event stringAttributes - Cloud event mapping config.
- Host string
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- Keep
Alive intSeconds - Broker KeepAlive for connection in seconds.
- Max
Inflight intMessages - 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.
- Session
Expiry intSeconds - Session expiry in seconds.
- Tls
Tls
Properties Response - TLS configuration.
- authentication
Dataflow
Endpoint Mqtt Authentication Response - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- client
Id StringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- cloud
Event StringAttributes - Cloud event mapping config.
- host String
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- keep
Alive IntegerSeconds - Broker KeepAlive for connection in seconds.
- max
Inflight IntegerMessages - 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.
- session
Expiry IntegerSeconds - Session expiry in seconds.
- tls
Tls
Properties Response - TLS configuration.
- authentication
Dataflow
Endpoint Mqtt Authentication Response - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- client
Id stringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- cloud
Event stringAttributes - Cloud event mapping config.
- host string
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- keep
Alive numberSeconds - Broker KeepAlive for connection in seconds.
- max
Inflight numberMessages - 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.
- session
Expiry numberSeconds - Session expiry in seconds.
- tls
Tls
Properties Response - TLS configuration.
- authentication
Dataflow
Endpoint Mqtt Authentication Response - authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- client_
id_ strprefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- cloud_
event_ strattributes - Cloud event mapping config.
- host str
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- keep_
alive_ intseconds - Broker KeepAlive for connection in seconds.
- max_
inflight_ intmessages - 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_ intseconds - Session expiry in seconds.
- tls
Tls
Properties Response - TLS configuration.
- authentication Property Map
- authentication properties. DEFAULT: kubernetes.audience=aio-internal. NOTE - Enum field only property is allowed
- client
Id StringPrefix - Client ID prefix. Client ID generated by the dataflow is -TBD. Optional; no prefix if omitted.
- cloud
Event StringAttributes - Cloud event mapping config.
- host String
- Host of the Broker in the form of :. Optional; connects to Broker if omitted.
- keep
Alive NumberSeconds - Broker KeepAlive for connection in seconds.
- max
Inflight NumberMessages - 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.
- session
Expiry NumberSeconds - Session expiry in seconds.
- tls Property Map
- TLS configuration.
DataflowEndpointProperties, DataflowEndpointPropertiesArgs
- Endpoint
Type string | Pulumi.Azure Native. Io TOperations. Endpoint Type - Endpoint Type.
- Data
Explorer Pulumi.Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Data Explorer - Azure Data Explorer endpoint.
- Data
Lake Pulumi.Storage Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Data Lake Storage - Azure Data Lake endpoint.
- Fabric
One Pulumi.Lake Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Fabric One Lake - Microsoft Fabric endpoint.
- Kafka
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Kafka - Kafka endpoint.
- Local
Storage Pulumi.Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Local Storage - Local persistent volume endpoint.
- Mqtt
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Mqtt - Broker endpoint.
- Endpoint
Type string | EndpointType - Endpoint Type.
- Data
Explorer DataflowSettings Endpoint Data Explorer - Azure Data Explorer endpoint.
- Data
Lake DataflowStorage Settings Endpoint Data Lake Storage - Azure Data Lake endpoint.
- Fabric
One DataflowLake Settings Endpoint Fabric One Lake - Microsoft Fabric endpoint.
- Kafka
Settings DataflowEndpoint Kafka - Kafka endpoint.
- Local
Storage DataflowSettings Endpoint Local Storage - Local persistent volume endpoint.
- Mqtt
Settings DataflowEndpoint Mqtt - Broker endpoint.
- endpoint
Type String | EndpointType - Endpoint Type.
- data
Explorer DataflowSettings Endpoint Data Explorer - Azure Data Explorer endpoint.
- data
Lake DataflowStorage Settings Endpoint Data Lake Storage - Azure Data Lake endpoint.
- fabric
One DataflowLake Settings Endpoint Fabric One Lake - Microsoft Fabric endpoint.
- kafka
Settings DataflowEndpoint Kafka - Kafka endpoint.
- local
Storage DataflowSettings Endpoint Local Storage - Local persistent volume endpoint.
- mqtt
Settings DataflowEndpoint Mqtt - Broker endpoint.
- endpoint
Type string | EndpointType - Endpoint Type.
- data
Explorer DataflowSettings Endpoint Data Explorer - Azure Data Explorer endpoint.
- data
Lake DataflowStorage Settings Endpoint Data Lake Storage - Azure Data Lake endpoint.
- fabric
One DataflowLake Settings Endpoint Fabric One Lake - Microsoft Fabric endpoint.
- kafka
Settings DataflowEndpoint Kafka - Kafka endpoint.
- local
Storage DataflowSettings Endpoint Local Storage - Local persistent volume endpoint.
- mqtt
Settings DataflowEndpoint Mqtt - Broker endpoint.
- endpoint_
type str | EndpointType - Endpoint Type.
- data_
explorer_ Dataflowsettings Endpoint Data Explorer - Azure Data Explorer endpoint.
- data_
lake_ Dataflowstorage_ settings Endpoint Data Lake Storage - Azure Data Lake endpoint.
- fabric_
one_ Dataflowlake_ settings Endpoint Fabric One Lake - Microsoft Fabric endpoint.
- kafka_
settings DataflowEndpoint Kafka - Kafka endpoint.
- local_
storage_ Dataflowsettings Endpoint Local Storage - Local persistent volume endpoint.
- mqtt_
settings DataflowEndpoint Mqtt - Broker endpoint.
- endpoint
Type String | "DataExplorer" | "Data Lake Storage" | "Fabric One Lake" | "Kafka" | "Local Storage" | "Mqtt" - Endpoint Type.
- data
Explorer Property MapSettings - Azure Data Explorer endpoint.
- data
Lake Property MapStorage Settings - Azure Data Lake endpoint.
- fabric
One Property MapLake Settings - Microsoft Fabric endpoint.
- kafka
Settings Property Map - Kafka endpoint.
- local
Storage Property MapSettings - Local persistent volume endpoint.
- mqtt
Settings Property Map - Broker endpoint.
DataflowEndpointPropertiesResponse, DataflowEndpointPropertiesResponseArgs
- Endpoint
Type string - Endpoint Type.
- Provisioning
State string - The status of the last operation.
- Data
Explorer Pulumi.Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Data Explorer Response - Azure Data Explorer endpoint.
- Data
Lake Pulumi.Storage Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Data Lake Storage Response - Azure Data Lake endpoint.
- Fabric
One Pulumi.Lake Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Fabric One Lake Response - Microsoft Fabric endpoint.
- Kafka
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Kafka Response - Kafka endpoint.
- Local
Storage Pulumi.Settings Azure Native. Io TOperations. Inputs. Dataflow Endpoint Local Storage Response - Local persistent volume endpoint.
- Mqtt
Settings Pulumi.Azure Native. Io TOperations. Inputs. Dataflow Endpoint Mqtt Response - Broker endpoint.
- Endpoint
Type string - Endpoint Type.
- Provisioning
State string - The status of the last operation.
- Data
Explorer DataflowSettings Endpoint Data Explorer Response - Azure Data Explorer endpoint.
- Data
Lake DataflowStorage Settings Endpoint Data Lake Storage Response - Azure Data Lake endpoint.
- Fabric
One DataflowLake Settings Endpoint Fabric One Lake Response - Microsoft Fabric endpoint.
- Kafka
Settings DataflowEndpoint Kafka Response - Kafka endpoint.
- Local
Storage DataflowSettings Endpoint Local Storage Response - Local persistent volume endpoint.
- Mqtt
Settings DataflowEndpoint Mqtt Response - Broker endpoint.
- endpoint
Type String - Endpoint Type.
- provisioning
State String - The status of the last operation.
- data
Explorer DataflowSettings Endpoint Data Explorer Response - Azure Data Explorer endpoint.
- data
Lake DataflowStorage Settings Endpoint Data Lake Storage Response - Azure Data Lake endpoint.
- fabric
One DataflowLake Settings Endpoint Fabric One Lake Response - Microsoft Fabric endpoint.
- kafka
Settings DataflowEndpoint Kafka Response - Kafka endpoint.
- local
Storage DataflowSettings Endpoint Local Storage Response - Local persistent volume endpoint.
- mqtt
Settings DataflowEndpoint Mqtt Response - Broker endpoint.
- endpoint
Type string - Endpoint Type.
- provisioning
State string - The status of the last operation.
- data
Explorer DataflowSettings Endpoint Data Explorer Response - Azure Data Explorer endpoint.
- data
Lake DataflowStorage Settings Endpoint Data Lake Storage Response - Azure Data Lake endpoint.
- fabric
One DataflowLake Settings Endpoint Fabric One Lake Response - Microsoft Fabric endpoint.
- kafka
Settings DataflowEndpoint Kafka Response - Kafka endpoint.
- local
Storage DataflowSettings Endpoint Local Storage Response - Local persistent volume endpoint.
- mqtt
Settings DataflowEndpoint Mqtt Response - Broker endpoint.
- endpoint_
type str - Endpoint Type.
- provisioning_
state str - The status of the last operation.
- data_
explorer_ Dataflowsettings Endpoint Data Explorer Response - Azure Data Explorer endpoint.
- data_
lake_ Dataflowstorage_ settings Endpoint Data Lake Storage Response - Azure Data Lake endpoint.
- fabric_
one_ Dataflowlake_ settings Endpoint Fabric One Lake Response - Microsoft Fabric endpoint.
- kafka_
settings DataflowEndpoint Kafka Response - Kafka endpoint.
- local_
storage_ Dataflowsettings Endpoint Local Storage Response - Local persistent volume endpoint.
- mqtt_
settings DataflowEndpoint Mqtt Response - Broker endpoint.
- endpoint
Type String - Endpoint Type.
- provisioning
State String - The status of the last operation.
- data
Explorer Property MapSettings - Azure Data Explorer endpoint.
- data
Lake Property MapStorage Settings - Azure Data Lake endpoint.
- fabric
One Property MapLake Settings - Microsoft Fabric endpoint.
- kafka
Settings Property Map - Kafka endpoint.
- local
Storage Property MapSettings - Local persistent volume endpoint.
- mqtt
Settings Property Map - Broker endpoint.
EndpointType, EndpointTypeArgs
- 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
- Endpoint
Type Data Explorer - DataExplorerAzure Data Explorer Type
- Endpoint
Type Data Lake Storage - DataLakeStorageAzure Data Lake Type
- Endpoint
Type Fabric One Lake - FabricOneLakeMicrosoft Fabric Type
- Endpoint
Type Kafka - KafkaKafka Type
- Endpoint
Type Local Storage - LocalStorageLocal Storage Type
- Endpoint
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
- 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
- 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
- "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
ExtendedLocation, ExtendedLocationArgs
- Name string
- The name of the extended location.
- Type
string | Pulumi.
Azure Native. Io TOperations. Extended Location Type - Type of ExtendedLocation.
- Name string
- The name of the extended location.
- Type
string | Extended
Location Type - Type of ExtendedLocation.
- name String
- The name of the extended location.
- type
String | Extended
Location Type - Type of ExtendedLocation.
- name string
- The name of the extended location.
- type
string | Extended
Location Type - Type of ExtendedLocation.
- name str
- The name of the extended location.
- type
str | Extended
Location Type - Type of ExtendedLocation.
- name String
- The name of the extended location.
- type
String | "Custom
Location" - Type of ExtendedLocation.
ExtendedLocationResponse, ExtendedLocationResponseArgs
ExtendedLocationType, ExtendedLocationTypeArgs
- Custom
Location - CustomLocationCustomLocation type
- Extended
Location Type Custom Location - CustomLocationCustomLocation type
- Custom
Location - CustomLocationCustomLocation type
- Custom
Location - CustomLocationCustomLocation type
- CUSTOM_LOCATION
- CustomLocationCustomLocation type
- "Custom
Location" - CustomLocationCustomLocation type
KafkaAuthMethod, KafkaAuthMethodArgs
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Sasl
- SaslSasl Option
- X509Certificate
- X509Certificatex509Certificate Option
- Anonymous
- AnonymousAnonymous Option
- Kafka
Auth Method System Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- Kafka
Auth Method User Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Kafka
Auth Method Sasl - SaslSasl Option
- Kafka
Auth Method X509Certificate - X509Certificatex509Certificate Option
- Kafka
Auth Method Anonymous - AnonymousAnonymous Option
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Sasl
- SaslSasl Option
- X509Certificate
- X509Certificatex509Certificate Option
- Anonymous
- AnonymousAnonymous Option
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Sasl
- SaslSasl Option
- X509Certificate
- X509Certificatex509Certificate Option
- Anonymous
- AnonymousAnonymous Option
- SYSTEM_ASSIGNED_MANAGED_IDENTITY
- SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- USER_ASSIGNED_MANAGED_IDENTITY
- UserAssignedManagedIdentityUserAssignedManagedIdentity type
- SASL
- SaslSasl Option
- X509_CERTIFICATE
- X509Certificatex509Certificate Option
- ANONYMOUS
- AnonymousAnonymous Option
- "System
Assigned Managed Identity" - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- "User
Assigned Managed Identity" - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- "Sasl"
- SaslSasl Option
- "X509Certificate"
- X509Certificatex509Certificate Option
- "Anonymous"
- AnonymousAnonymous Option
MqttAuthMethod, MqttAuthMethodArgs
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Service
Account Token - ServiceAccountTokenServiceAccountToken Option
- X509Certificate
- X509Certificatex509Certificate Option
- Anonymous
- AnonymousAnonymous Option
- Mqtt
Auth Method System Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- Mqtt
Auth Method User Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Mqtt
Auth Method Service Account Token - ServiceAccountTokenServiceAccountToken Option
- Mqtt
Auth Method X509Certificate - X509Certificatex509Certificate Option
- Mqtt
Auth Method Anonymous - AnonymousAnonymous Option
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Service
Account Token - ServiceAccountTokenServiceAccountToken Option
- X509Certificate
- X509Certificatex509Certificate Option
- Anonymous
- AnonymousAnonymous Option
- System
Assigned Managed Identity - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- User
Assigned Managed Identity - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- Service
Account Token - ServiceAccountTokenServiceAccountToken Option
- X509Certificate
- X509Certificatex509Certificate Option
- Anonymous
- AnonymousAnonymous Option
- SYSTEM_ASSIGNED_MANAGED_IDENTITY
- SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- USER_ASSIGNED_MANAGED_IDENTITY
- UserAssignedManagedIdentityUserAssignedManagedIdentity type
- SERVICE_ACCOUNT_TOKEN
- ServiceAccountTokenServiceAccountToken Option
- X509_CERTIFICATE
- X509Certificatex509Certificate Option
- ANONYMOUS
- AnonymousAnonymous Option
- "System
Assigned Managed Identity" - SystemAssignedManagedIdentitySystemAssignedManagedIdentity type
- "User
Assigned Managed Identity" - UserAssignedManagedIdentityUserAssignedManagedIdentity type
- "Service
Account Token" - ServiceAccountTokenServiceAccountToken Option
- "X509Certificate"
- X509Certificatex509Certificate Option
- "Anonymous"
- AnonymousAnonymous Option
MqttRetainType, MqttRetainTypeArgs
- Keep
- KeepRetain the messages.
- Never
- NeverNever retain messages.
- Mqtt
Retain Type Keep - KeepRetain the messages.
- Mqtt
Retain Type 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.
- "Keep"
- KeepRetain the messages.
- "Never"
- NeverNever retain messages.
OperationalMode, OperationalModeArgs
- Enabled
- EnabledEnabled is equivalent to True
- Disabled
- DisabledDisabled is equivalent to False.
- Operational
Mode Enabled - EnabledEnabled is equivalent to True
- Operational
Mode Disabled - DisabledDisabled is equivalent to False.
- Enabled
- EnabledEnabled is equivalent to True
- Disabled
- DisabledDisabled is equivalent to False.
- Enabled
- EnabledEnabled is equivalent to True
- Disabled
- DisabledDisabled is equivalent to False.
- ENABLED
- EnabledEnabled is equivalent to True
- DISABLED
- DisabledDisabled is equivalent to False.
- "Enabled"
- EnabledEnabled is equivalent to True
- "Disabled"
- DisabledDisabled is equivalent to False.
SystemDataResponse, SystemDataResponseArgs
- Created
At string - The timestamp of resource creation (UTC).
- Created
By string - The identity that created the resource.
- Created
By stringType - The type of identity that created the resource.
- Last
Modified stringAt - The timestamp of resource last modification (UTC)
- Last
Modified stringBy - The identity that last modified the resource.
- Last
Modified stringBy Type - The type of identity that last modified the resource.
- Created
At string - The timestamp of resource creation (UTC).
- Created
By string - The identity that created the resource.
- Created
By stringType - The type of identity that created the resource.
- Last
Modified stringAt - The timestamp of resource last modification (UTC)
- Last
Modified stringBy - The identity that last modified the resource.
- Last
Modified stringBy Type - The type of identity that last modified the resource.
- created
At String - The timestamp of resource creation (UTC).
- created
By String - The identity that created the resource.
- created
By StringType - The type of identity that created the resource.
- last
Modified StringAt - The timestamp of resource last modification (UTC)
- last
Modified StringBy - The identity that last modified the resource.
- last
Modified StringBy Type - The type of identity that last modified the resource.
- created
At string - The timestamp of resource creation (UTC).
- created
By string - The identity that created the resource.
- created
By stringType - The type of identity that created the resource.
- last
Modified stringAt - The timestamp of resource last modification (UTC)
- last
Modified stringBy - The identity that last modified the resource.
- last
Modified stringBy Type - The type of identity that last modified the resource.
- created_
at str - The timestamp of resource creation (UTC).
- created_
by str - The identity that created the resource.
- created_
by_ strtype - The type of identity that created the resource.
- last_
modified_ strat - The timestamp of resource last modification (UTC)
- last_
modified_ strby - The identity that last modified the resource.
- last_
modified_ strby_ type - The type of identity that last modified the resource.
- created
At String - The timestamp of resource creation (UTC).
- created
By String - The identity that created the resource.
- created
By StringType - The type of identity that created the resource.
- last
Modified StringAt - The timestamp of resource last modification (UTC)
- last
Modified StringBy - The identity that last modified the resource.
- last
Modified StringBy Type - The type of identity that last modified the resource.
TlsProperties, TlsPropertiesArgs
- Mode
string | Pulumi.
Azure Native. Io TOperations. Operational Mode - Mode for TLS.
- Trusted
Ca stringCertificate Config Map Ref - Trusted CA certificate config map.
- Mode
string | Operational
Mode - Mode for TLS.
- Trusted
Ca stringCertificate Config Map Ref - Trusted CA certificate config map.
- mode
String | Operational
Mode - Mode for TLS.
- trusted
Ca StringCertificate Config Map Ref - Trusted CA certificate config map.
- mode
string | Operational
Mode - Mode for TLS.
- trusted
Ca stringCertificate Config Map Ref - Trusted CA certificate config map.
- mode
str | Operational
Mode - Mode for TLS.
- trusted_
ca_ strcertificate_ config_ map_ ref - Trusted CA certificate config map.
- mode String | "Enabled" | "Disabled"
- Mode for TLS.
- trusted
Ca StringCertificate Config Map Ref - Trusted CA certificate config map.
TlsPropertiesResponse, TlsPropertiesResponseArgs
- Mode string
- Mode for TLS.
- Trusted
Ca stringCertificate Config Map Ref - Trusted CA certificate config map.
- Mode string
- Mode for TLS.
- Trusted
Ca stringCertificate Config Map Ref - Trusted CA certificate config map.
- mode String
- Mode for TLS.
- trusted
Ca StringCertificate Config Map Ref - Trusted CA certificate config map.
- mode string
- Mode for TLS.
- trusted
Ca stringCertificate Config Map Ref - Trusted CA certificate config map.
- mode str
- Mode for TLS.
- trusted_
ca_ strcertificate_ config_ map_ ref - Trusted CA certificate config map.
- mode String
- Mode for TLS.
- trusted
Ca StringCertificate Config Map Ref - 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 zyhxscudobzfacetvgyjiav /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
This is the latest version of Azure Native. Use the Azure Native v2 docs if using the v2 version of this package.
Azure Native v3.2.0 published on Monday, Apr 14, 2025 by Pulumi