pulumi-azure-native-kotlin/com.pulumi.azurenative.iotoperationsmq.kotlin/DataLakeConnectorArgs

DataLakeConnectorArgs

data class DataLakeConnectorArgs(val dataLakeConnectorName: Output<String>? = null, val databaseFormat: Output<Either<String, DataLakeDatabaseFormat>>? = null, val extendedLocation: Output<ExtendedLocationPropertyArgs>? = null, val image: Output<ContainerImageArgs>? = null, val instances: Output<Int>? = null, val localBrokerConnection: Output<LocalBrokerConnectionSpecArgs>? = null, val location: Output<String>? = null, val logLevel: Output<String>? = null, val mqName: Output<String>? = null, val nodeTolerations: Output<NodeTolerationsArgs>? = null, val protocol: Output<Either<String, MqttProtocol>>? = null, val resourceGroupName: Output<String>? = null, val tags: Output<Map<String, String>>? = null, val target: Output<DataLakeTargetStorageArgs>? = null) : ConvertibleToJava<DataLakeConnectorArgs>

MQ dataLakeConnector resource Azure REST API version: 2023-10-04-preview.

Example Usage

DataLakeConnector_CreateOrUpdate

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
    var dataLakeConnector = new AzureNative.IoTOperationsMQ.DataLakeConnector("dataLakeConnector", new()
    {
        DataLakeConnectorName = "87v4D",
        DatabaseFormat = "delta",
        ExtendedLocation = new AzureNative.IoTOperationsMQ.Inputs.ExtendedLocationPropertyArgs
        {
            Name = "an",
            Type = "CustomLocation",
        },
        Image = new AzureNative.IoTOperationsMQ.Inputs.ContainerImageArgs
        {
            PullPolicy = "imfuzvqxgbdwliqnn",
            PullSecrets = "klnqimxqsrdwhcqldjvdtsrs",
            Repository = "m",
            Tag = "jygfdiamhhm",
        },
        Instances = 53467,
        LocalBrokerConnection = new AzureNative.IoTOperationsMQ.Inputs.LocalBrokerConnectionSpecArgs
        {
            Authentication = new AzureNative.IoTOperationsMQ.Inputs.LocalBrokerAuthenticationMethodsArgs
            {
                Kubernetes = new AzureNative.IoTOperationsMQ.Inputs.LocalBrokerKubernetesAuthenticationArgs
                {
                    SecretPath = "soukzfkouir",
                    ServiceAccountTokenName = "suwetviuhmhorhvsidlznnufe",
                },
            },
            Endpoint = "xc",
            Tls = new AzureNative.IoTOperationsMQ.Inputs.LocalBrokerConnectionTlsArgs
            {
                TlsEnabled = true,
                TrustedCaCertificateConfigMap = "rinkomfeznsfedbmllxlbmmhc",
            },
        },
        Location = "ewguwvlahlu",
        LogLevel = "ikicyoalavfmqlodnupfjayxjti",
        MqName = "Ox--3e65kYN0731DJ1Qg",
        NodeTolerations = new AzureNative.IoTOperationsMQ.Inputs.NodeTolerationsArgs
        {
            Effect = "eeswvciblqmmaeesjoflyvxqbz",
            Key = "wbrstdwxgm",
            Operator = "lbegegneekwnyodtzraarivtwhmzep",
            Value = "sfafsjdcezdmkwibxeluukxgl",
        },
        Protocol = "v3",
        ResourceGroupName = "rgiotoperationsmq",
        Tags = null,
        Target = new AzureNative.IoTOperationsMQ.Inputs.DataLakeTargetStorageArgs
        {
            DatalakeStorage = new AzureNative.IoTOperationsMQ.Inputs.DataLakeServiceStorageArgs
            {
                Authentication = new AzureNative.IoTOperationsMQ.Inputs.DataLakeServiceStorageAuthenticationArgs
                {
                    AccessTokenSecretName = "cfaoxjbfbwdldqjbfczvovgooyqkl",
                    SystemAssignedManagedIdentity = new AzureNative.IoTOperationsMQ.Inputs.ManagedIdentityAuthenticationArgs
                    {
                        Audience = "kjderojhpehosgfcrxxbh",
                        ExtensionName = "cyckjqqzspleajbtkniwrfsqygjfhe",
                    },
                },
                Endpoint = "bddy",
            },
            FabricOneLake = new AzureNative.IoTOperationsMQ.Inputs.DataLakeFabricStorageArgs
            {
                Authentication = new AzureNative.IoTOperationsMQ.Inputs.DataLakeFabricStorageAuthenticationArgs
                {
                    SystemAssignedManagedIdentity = new AzureNative.IoTOperationsMQ.Inputs.ManagedIdentityAuthenticationArgs
                    {
                        Audience = "kjderojhpehosgfcrxxbh",
                        ExtensionName = "cyckjqqzspleajbtkniwrfsqygjfhe",
                    },
                },
                Endpoint = "S.fabric.microsoft.com",
                FabricPath = "files",
                Guids = new AzureNative.IoTOperationsMQ.Inputs.FabricGuidsArgs
                {
                    LakehouseGuid = "grsapopwjnuzbmnxbjnawaae",
                    WorkspaceGuid = "iwqfplayvdkdxumpdc",
                },
                Names = new AzureNative.IoTOperationsMQ.Inputs.FabricNamesArgs
                {
                    LakehouseName = "iqgqtk",
                    WorkspaceName = "fxvlfhfcmlhcbgpopyqfikqsryct",
                },
            },
            LocalStorage = new AzureNative.IoTOperationsMQ.Inputs.DataLakeLocalStorageArgs
            {
                VolumeName = "nmzsioldiwteljpplmftk",
            },
        },
    });
});
Content copied to clipboard
package main
import (
	"github.com/pulumi/pulumi-azure-native-sdk/iotoperationsmq/v2"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := iotoperationsmq.NewDataLakeConnector(ctx, "dataLakeConnector", &iotoperationsmq.DataLakeConnectorArgs{
DataLakeConnectorName: pulumi.String("87v4D"),
DatabaseFormat: pulumi.String("delta"),
ExtendedLocation: &iotoperationsmq.ExtendedLocationPropertyArgs{
Name: pulumi.String("an"),
Type: pulumi.String("CustomLocation"),
},
Image: &iotoperationsmq.ContainerImageArgs{
PullPolicy: pulumi.String("imfuzvqxgbdwliqnn"),
PullSecrets: pulumi.String("klnqimxqsrdwhcqldjvdtsrs"),
Repository: pulumi.String("m"),
Tag: pulumi.String("jygfdiamhhm"),
},
Instances: pulumi.Int(53467),
LocalBrokerConnection: iotoperationsmq.LocalBrokerConnectionSpecResponse{
Authentication: interface{}{
Kubernetes: &iotoperationsmq.LocalBrokerKubernetesAuthenticationArgs{
SecretPath: pulumi.String("soukzfkouir"),
ServiceAccountTokenName: pulumi.String("suwetviuhmhorhvsidlznnufe"),
},
},
Endpoint: pulumi.String("xc"),
Tls: &iotoperationsmq.LocalBrokerConnectionTlsArgs{
TlsEnabled: pulumi.Bool(true),
TrustedCaCertificateConfigMap: pulumi.String("rinkomfeznsfedbmllxlbmmhc"),
},
},
Location: pulumi.String("ewguwvlahlu"),
LogLevel: pulumi.String("ikicyoalavfmqlodnupfjayxjti"),
MqName: pulumi.String("Ox--3e65kYN0731DJ1Qg"),
NodeTolerations: &iotoperationsmq.NodeTolerationsArgs{
Effect: pulumi.String("eeswvciblqmmaeesjoflyvxqbz"),
Key: pulumi.String("wbrstdwxgm"),
Operator: pulumi.String("lbegegneekwnyodtzraarivtwhmzep"),
Value: pulumi.String("sfafsjdcezdmkwibxeluukxgl"),
},
Protocol: pulumi.String("v3"),
ResourceGroupName: pulumi.String("rgiotoperationsmq"),
Tags: nil,
Target: iotoperationsmq.DataLakeTargetStorageResponse{
DatalakeStorage: interface{}{
Authentication: interface{}{
AccessTokenSecretName: pulumi.String("cfaoxjbfbwdldqjbfczvovgooyqkl"),
SystemAssignedManagedIdentity: &iotoperationsmq.ManagedIdentityAuthenticationArgs{
Audience: pulumi.String("kjderojhpehosgfcrxxbh"),
ExtensionName: pulumi.String("cyckjqqzspleajbtkniwrfsqygjfhe"),
},
},
Endpoint: pulumi.String("bddy"),
},
FabricOneLake: interface{}{
Authentication: interface{}{
SystemAssignedManagedIdentity: &iotoperationsmq.ManagedIdentityAuthenticationArgs{
Audience: pulumi.String("kjderojhpehosgfcrxxbh"),
ExtensionName: pulumi.String("cyckjqqzspleajbtkniwrfsqygjfhe"),
},
},
Endpoint: pulumi.String("S.fabric.microsoft.com"),
FabricPath: pulumi.String("files"),
Guids: &iotoperationsmq.FabricGuidsArgs{
LakehouseGuid: pulumi.String("grsapopwjnuzbmnxbjnawaae"),
WorkspaceGuid: pulumi.String("iwqfplayvdkdxumpdc"),
},
Names: &iotoperationsmq.FabricNamesArgs{
LakehouseName: pulumi.String("iqgqtk"),
WorkspaceName: pulumi.String("fxvlfhfcmlhcbgpopyqfikqsryct"),
},
},
LocalStorage: &iotoperationsmq.DataLakeLocalStorageArgs{
VolumeName: pulumi.String("nmzsioldiwteljpplmftk"),
},
},
})
if err != nil {
return err
}
return nil
})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.iotoperationsmq.DataLakeConnector;
import com.pulumi.azurenative.iotoperationsmq.DataLakeConnectorArgs;
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 dataLakeConnector = new DataLakeConnector("dataLakeConnector", DataLakeConnectorArgs.builder()
            .dataLakeConnectorName("87v4D")
            .databaseFormat("delta")
            .extendedLocation(Map.ofEntries(
                Map.entry("name", "an"),
                Map.entry("type", "CustomLocation")
            ))
            .image(Map.ofEntries(
                Map.entry("pullPolicy", "imfuzvqxgbdwliqnn"),
                Map.entry("pullSecrets", "klnqimxqsrdwhcqldjvdtsrs"),
                Map.entry("repository", "m"),
                Map.entry("tag", "jygfdiamhhm")
            ))
            .instances(53467)
            .localBrokerConnection(Map.ofEntries(
                Map.entry("authentication", Map.of("kubernetes", Map.ofEntries(
                    Map.entry("secretPath", "soukzfkouir"),
                    Map.entry("serviceAccountTokenName", "suwetviuhmhorhvsidlznnufe")
                ))),
                Map.entry("endpoint", "xc"),
                Map.entry("tls", Map.ofEntries(
                    Map.entry("tlsEnabled", true),
                    Map.entry("trustedCaCertificateConfigMap", "rinkomfeznsfedbmllxlbmmhc")
                ))
            ))
            .location("ewguwvlahlu")
            .logLevel("ikicyoalavfmqlodnupfjayxjti")
            .mqName("Ox--3e65kYN0731DJ1Qg")
            .nodeTolerations(Map.ofEntries(
                Map.entry("effect", "eeswvciblqmmaeesjoflyvxqbz"),
                Map.entry("key", "wbrstdwxgm"),
                Map.entry("operator", "lbegegneekwnyodtzraarivtwhmzep"),
                Map.entry("value", "sfafsjdcezdmkwibxeluukxgl")
            ))
            .protocol("v3")
            .resourceGroupName("rgiotoperationsmq")
            .tags()
            .target(Map.ofEntries(
                Map.entry("datalakeStorage", Map.ofEntries(
                    Map.entry("authentication", Map.ofEntries(
                        Map.entry("accessTokenSecretName", "cfaoxjbfbwdldqjbfczvovgooyqkl"),
                        Map.entry("systemAssignedManagedIdentity", Map.ofEntries(
                            Map.entry("audience", "kjderojhpehosgfcrxxbh"),
                            Map.entry("extensionName", "cyckjqqzspleajbtkniwrfsqygjfhe")
                        ))
                    )),
                    Map.entry("endpoint", "bddy")
                )),
                Map.entry("fabricOneLake", Map.ofEntries(
                    Map.entry("authentication", Map.of("systemAssignedManagedIdentity", Map.ofEntries(
                        Map.entry("audience", "kjderojhpehosgfcrxxbh"),
                        Map.entry("extensionName", "cyckjqqzspleajbtkniwrfsqygjfhe")
                    ))),
                    Map.entry("endpoint", "S.fabric.microsoft.com"),
                    Map.entry("fabricPath", "files"),
                    Map.entry("guids", Map.ofEntries(
                        Map.entry("lakehouseGuid", "grsapopwjnuzbmnxbjnawaae"),
                        Map.entry("workspaceGuid", "iwqfplayvdkdxumpdc")
                    )),
                    Map.entry("names", Map.ofEntries(
                        Map.entry("lakehouseName", "iqgqtk"),
                        Map.entry("workspaceName", "fxvlfhfcmlhcbgpopyqfikqsryct")
                    ))
                )),
                Map.entry("localStorage", Map.of("volumeName", "nmzsioldiwteljpplmftk"))
            ))
            .build());
    }
}
Content copied to clipboard

Import

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

$ pulumi import azure-native:iotoperationsmq:DataLakeConnector yduqhtfsalzehud /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperationsMQ/mq/{mqName}/dataLakeConnector/{dataLakeConnectorName}
Content copied to clipboard

Constructors

Link copied to clipboard
fun DataLakeConnectorArgs(dataLakeConnectorName: Output<String>? = null, databaseFormat: Output<Either<String, DataLakeDatabaseFormat>>? = null, extendedLocation: Output<ExtendedLocationPropertyArgs>? = null, image: Output<ContainerImageArgs>? = null, instances: Output<Int>? = null, localBrokerConnection: Output<LocalBrokerConnectionSpecArgs>? = null, location: Output<String>? = null, logLevel: Output<String>? = null, mqName: Output<String>? = null, nodeTolerations: Output<NodeTolerationsArgs>? = null, protocol: Output<Either<String, MqttProtocol>>? = null, resourceGroupName: Output<String>? = null, tags: Output<Map<String, String>>? = null, target: Output<DataLakeTargetStorageArgs>? = null)

Functions

Link copied to clipboard
open override fun toJava(): DataLakeConnectorArgs

Properties

Link copied to clipboard
val databaseFormat: Output<Either<String, DataLakeDatabaseFormat>>? = null

DataLake database format to use.

Link copied to clipboard
val dataLakeConnectorName: Output<String>? = null

Name of MQ dataLakeConnector resource

Link copied to clipboard
val extendedLocation: Output<ExtendedLocationPropertyArgs>? = null

Extended Location

Link copied to clipboard
val image: Output<ContainerImageArgs>? = null

The details of DataLakeConnector Docker Image.

Link copied to clipboard
val instances: Output<Int>? = null

The number of DataLakeConnector pods to spin up.

Link copied to clipboard
val localBrokerConnection: Output<LocalBrokerConnectionSpecArgs>? = null

The details for connecting with Local Broker.

Link copied to clipboard
val location: Output<String>? = null

The geo-location where the resource lives

Link copied to clipboard
val logLevel: Output<String>? = null

The log level of the DataLake Connector instances.

Link copied to clipboard
val mqName: Output<String>? = null

Name of MQ resource

Link copied to clipboard
val nodeTolerations: Output<NodeTolerationsArgs>? = null

The Node Tolerations for the DataLake Connector pods.

Link copied to clipboard
val protocol: Output<Either<String, MqttProtocol>>? = null

The protocol to use for connecting with Brokers.

Link copied to clipboard
val resourceGroupName: Output<String>? = null

The name of the resource group. The name is case insensitive.

Link copied to clipboard
val tags: Output<Map<String, String>>? = null

Resource tags.

Link copied to clipboard
val target: Output<DataLakeTargetStorageArgs>? = null

The protocol to use for connecting with Brokers. NOTE - Enum only storage is supported at at time.