DataLakeConnector

class DataLakeConnector : KotlinCustomResource

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",
},
},
});
});
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
})
}
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());
}
}

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}

Properties

Link copied to clipboard
val databaseFormat: Output<String>

DataLake database format to use.

Link copied to clipboard
Link copied to clipboard
val id: Output<String>
Link copied to clipboard

The details of DataLakeConnector Docker Image.

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

The number of DataLakeConnector pods to spin up.

Link copied to clipboard

The details for connecting with Local Broker.

Link copied to clipboard
val location: Output<String>

The geo-location where the resource lives

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

The log level of the DataLake Connector instances.

Link copied to clipboard
val name: Output<String>

The name of the resource

Link copied to clipboard

The Node Tolerations for the DataLake Connector pods.

Link copied to clipboard
val protocol: Output<String>

The protocol to use for connecting with Brokers.

Link copied to clipboard

The status of the last operation.

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Azure Resource Manager metadata containing createdBy and modifiedBy information.

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

Resource tags.

Link copied to clipboard

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

Link copied to clipboard
val type: Output<String>

The type of the resource. E.g. "Microsoft.Compute/virtualMachines" or "Microsoft.Storage/storageAccounts"

Link copied to clipboard
val urn: Output<String>