DataLakeConnectorTopicMapArgs

data class DataLakeConnectorTopicMapArgs(val dataLakeConnectorName: Output<String>? = null, val dataLakeConnectorRef: Output<String>? = null, val extendedLocation: Output<ExtendedLocationPropertyArgs>? = null, val location: Output<String>? = null, val mapping: Output<DataLakeConnectorMapArgs>? = null, val mqName: Output<String>? = null, val resourceGroupName: Output<String>? = null, val tags: Output<Map<String, String>>? = null, val topicMapName: Output<String>? = null) : ConvertibleToJava<DataLakeConnectorTopicMapArgs>

MQ dataLakeConnector/topicMap resource Uses Azure REST API version 2023-10-04-preview.

Example Usage

DataLakeConnectorTopicMap_CreateOrUpdate

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
var dataLakeConnectorTopicMap = new AzureNative.IoTOperationsMQ.DataLakeConnectorTopicMap("dataLakeConnectorTopicMap", new()
{
DataLakeConnectorName = "E9gU89-1QnIG7-IP8qOQLV-",
DataLakeConnectorRef = "zirczjfua",
ExtendedLocation = new AzureNative.IoTOperationsMQ.Inputs.ExtendedLocationPropertyArgs
{
Name = "an",
Type = AzureNative.IoTOperationsMQ.ExtendedLocationType.CustomLocation,
},
Location = "wjmgeh",
Mapping = new AzureNative.IoTOperationsMQ.Inputs.DataLakeConnectorMapArgs
{
AllowedLatencySecs = 25407,
ClientId = "gyjduryceozwqyjdrxhrtwuw",
MaxMessagesPerBatch = 1581641880,
MessagePayloadType = "pwhpwzqlzlhdrozpqziipvjqrnipo",
MqttSourceTopic = "mtac",
Qos = 2,
Table = new AzureNative.IoTOperationsMQ.Inputs.DeltaTableArgs
{
Schema = new[]
{
new AzureNative.IoTOperationsMQ.Inputs.DeltaTableSchemaArgs
{
Format = AzureNative.IoTOperationsMQ.DeltaTableFormatEnum.Boolean,
Mapping = "lfnyjp",
Name = "hejqncdsueoerueffbaqix",
Optional = true,
},
},
TableName = "qyvzigmefvxwyjqksofyrstn",
TablePath = "cyrkvxsjhbhwjegmhzyixchkdnxe",
},
},
MqName = "rc-8Z--2m-MU",
ResourceGroupName = "rgiotoperationsmq",
Tags = null,
TopicMapName = "17-",
});
});
package main
import (
iotoperationsmq "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.NewDataLakeConnectorTopicMap(ctx, "dataLakeConnectorTopicMap", &iotoperationsmq.DataLakeConnectorTopicMapArgs{
DataLakeConnectorName: pulumi.String("E9gU89-1QnIG7-IP8qOQLV-"),
DataLakeConnectorRef: pulumi.String("zirczjfua"),
ExtendedLocation: &iotoperationsmq.ExtendedLocationPropertyArgs{
Name: pulumi.String("an"),
Type: pulumi.String(iotoperationsmq.ExtendedLocationTypeCustomLocation),
},
Location: pulumi.String("wjmgeh"),
Mapping: &iotoperationsmq.DataLakeConnectorMapArgs{
AllowedLatencySecs: pulumi.Int(25407),
ClientId: pulumi.String("gyjduryceozwqyjdrxhrtwuw"),
MaxMessagesPerBatch: pulumi.Float64(1581641880),
MessagePayloadType: pulumi.String("pwhpwzqlzlhdrozpqziipvjqrnipo"),
MqttSourceTopic: pulumi.String("mtac"),
Qos: pulumi.Int(2),
Table: &iotoperationsmq.DeltaTableArgs{
Schema: iotoperationsmq.DeltaTableSchemaArray{
&iotoperationsmq.DeltaTableSchemaArgs{
Format: pulumi.String(iotoperationsmq.DeltaTableFormatEnumBoolean),
Mapping: pulumi.String("lfnyjp"),
Name: pulumi.String("hejqncdsueoerueffbaqix"),
Optional: pulumi.Bool(true),
},
},
TableName: pulumi.String("qyvzigmefvxwyjqksofyrstn"),
TablePath: pulumi.String("cyrkvxsjhbhwjegmhzyixchkdnxe"),
},
},
MqName: pulumi.String("rc-8Z--2m-MU"),
ResourceGroupName: pulumi.String("rgiotoperationsmq"),
Tags: pulumi.StringMap{},
TopicMapName: pulumi.String("17-"),
})
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.DataLakeConnectorTopicMap;
import com.pulumi.azurenative.iotoperationsmq.DataLakeConnectorTopicMapArgs;
import com.pulumi.azurenative.iotoperationsmq.inputs.ExtendedLocationPropertyArgs;
import com.pulumi.azurenative.iotoperationsmq.inputs.DataLakeConnectorMapArgs;
import com.pulumi.azurenative.iotoperationsmq.inputs.DeltaTableArgs;
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 dataLakeConnectorTopicMap = new DataLakeConnectorTopicMap("dataLakeConnectorTopicMap", DataLakeConnectorTopicMapArgs.builder()
.dataLakeConnectorName("E9gU89-1QnIG7-IP8qOQLV-")
.dataLakeConnectorRef("zirczjfua")
.extendedLocation(ExtendedLocationPropertyArgs.builder()
.name("an")
.type("CustomLocation")
.build())
.location("wjmgeh")
.mapping(DataLakeConnectorMapArgs.builder()
.allowedLatencySecs(25407)
.clientId("gyjduryceozwqyjdrxhrtwuw")
.maxMessagesPerBatch(1581641880)
.messagePayloadType("pwhpwzqlzlhdrozpqziipvjqrnipo")
.mqttSourceTopic("mtac")
.qos(2)
.table(DeltaTableArgs.builder()
.schema(DeltaTableSchemaArgs.builder()
.format("boolean")
.mapping("lfnyjp")
.name("hejqncdsueoerueffbaqix")
.optional(true)
.build())
.tableName("qyvzigmefvxwyjqksofyrstn")
.tablePath("cyrkvxsjhbhwjegmhzyixchkdnxe")
.build())
.build())
.mqName("rc-8Z--2m-MU")
.resourceGroupName("rgiotoperationsmq")
.tags()
.topicMapName("17-")
.build());
}
}

Import

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

$ pulumi import azure-native:iotoperationsmq:DataLakeConnectorTopicMap l /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperationsMQ/mq/{mqName}/dataLakeConnector/{dataLakeConnectorName}/topicMap/{topicMapName}

Constructors

Link copied to clipboard
constructor(dataLakeConnectorName: Output<String>? = null, dataLakeConnectorRef: Output<String>? = null, extendedLocation: Output<ExtendedLocationPropertyArgs>? = null, location: Output<String>? = null, mapping: Output<DataLakeConnectorMapArgs>? = null, mqName: Output<String>? = null, resourceGroupName: Output<String>? = null, tags: Output<Map<String, String>>? = null, topicMapName: Output<String>? = null)

Properties

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

Name of MQ dataLakeConnector resource

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

DataLake Connector CRD to use.

Link copied to clipboard

Extended Location

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

The geo-location where the resource lives

Link copied to clipboard
val mapping: Output<DataLakeConnectorMapArgs>? = null

TopicMap for DataLake connector.

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

Name of MQ resource

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 topicMapName: Output<String>? = null

Name of MQ dataLakeConnector/topicMap resource

Functions

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