DataLakeConnectorTopicMap

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 = "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 = "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 (
	"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("CustomLocation"),
},
Location: pulumi.String("wjmgeh"),
Mapping: iotoperationsmq.DataLakeConnectorMapResponse{
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: interface{}{
Schema: iotoperationsmq.DeltaTableSchemaArray{
&iotoperationsmq.DeltaTableSchemaArgs{
Format: pulumi.String("boolean"),
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: nil,
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 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(Map.ofEntries(
                Map.entry("name", "an"),
                Map.entry("type", "CustomLocation")
            ))
            .location("wjmgeh")
            .mapping(Map.ofEntries(
                Map.entry("allowedLatencySecs", 25407),
                Map.entry("clientId", "gyjduryceozwqyjdrxhrtwuw"),
                Map.entry("maxMessagesPerBatch", 1581641880),
                Map.entry("messagePayloadType", "pwhpwzqlzlhdrozpqziipvjqrnipo"),
                Map.entry("mqttSourceTopic", "mtac"),
                Map.entry("qos", 2),
                Map.entry("table", Map.ofEntries(
                    Map.entry("schema", Map.ofEntries(
                        Map.entry("format", "boolean"),
                        Map.entry("mapping", "lfnyjp"),
                        Map.entry("name", "hejqncdsueoerueffbaqix"),
                        Map.entry("optional", true)
                    )),
                    Map.entry("tableName", "qyvzigmefvxwyjqksofyrstn"),
                    Map.entry("tablePath", "cyrkvxsjhbhwjegmhzyixchkdnxe")
                ))
            ))
            .mqName("rc-8Z--2m-MU")
            .resourceGroupName("rgiotoperationsmq")
            .tags()
            .topicMapName("17-")
            .build());
    }
}

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