Data Lake Connector
    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