azure.streamanalytics.OutputServicebusTopic

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
    public MyStack()
    {
        var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
        {
            Name = "example-resources",
        }));
        var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
        {
            Name = "example-job",
            ResourceGroupName = azurerm_resource_group.Example.Name,
        }));
        var exampleNamespace = new Azure.ServiceBus.Namespace("exampleNamespace", new Azure.ServiceBus.NamespaceArgs
        {
            Location = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Location),
            ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
            Sku = "Standard",
        });
        var exampleTopic = new Azure.ServiceBus.Topic("exampleTopic", new Azure.ServiceBus.TopicArgs
        {
            NamespaceId = exampleNamespace.Id,
            EnablePartitioning = true,
        });
        var exampleOutputServicebusTopic = new Azure.StreamAnalytics.OutputServicebusTopic("exampleOutputServicebusTopic", new Azure.StreamAnalytics.OutputServicebusTopicArgs
        {
            StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
            ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
            TopicName = exampleTopic.Name,
            ServicebusNamespace = exampleNamespace.Name,
            SharedAccessPolicyKey = exampleNamespace.DefaultPrimaryKey,
            SharedAccessPolicyName = "RootManageSharedAccessKey",
            PropertyColumns = 
            {
                "col1",
                "col2",
            },
            Serialization = new Azure.StreamAnalytics.Inputs.OutputServicebusTopicSerializationArgs
            {
                Format = "Avro",
            },
        });
    }

}

package main

import (
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/servicebus"
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		exampleJob, err := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleNamespace, err := servicebus.NewNamespace(ctx, "exampleNamespace", &servicebus.NamespaceArgs{
			Location:          pulumi.String(exampleResourceGroup.Location),
			ResourceGroupName: pulumi.String(exampleResourceGroup.Name),
			Sku:               pulumi.String("Standard"),
		})
		if err != nil {
			return err
		}
		exampleTopic, err := servicebus.NewTopic(ctx, "exampleTopic", &servicebus.TopicArgs{
			NamespaceId:        exampleNamespace.ID(),
			EnablePartitioning: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputServicebusTopic(ctx, "exampleOutputServicebusTopic", &streamanalytics.OutputServicebusTopicArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			TopicName:              exampleTopic.Name,
			ServicebusNamespace:    exampleNamespace.Name,
			SharedAccessPolicyKey:  exampleNamespace.DefaultPrimaryKey,
			SharedAccessPolicyName: pulumi.String("RootManageSharedAccessKey"),
			PropertyColumns: pulumi.StringArray{
				pulumi.String("col1"),
				pulumi.String("col2"),
			},
			Serialization: &streamanalytics.OutputServicebusTopicSerializationArgs{
				Format: pulumi.String("Avro"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleNamespace = new azure.servicebus.Namespace("exampleNamespace", {
    location: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.location),
    resourceGroupName: exampleResourceGroup.then(exampleResourceGroup => exampleResourceGroup.name),
    sku: "Standard",
});
const exampleTopic = new azure.servicebus.Topic("exampleTopic", {
    namespaceId: exampleNamespace.id,
    enablePartitioning: true,
});
const exampleOutputServicebusTopic = new azure.streamanalytics.OutputServicebusTopic("exampleOutputServicebusTopic", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    topicName: exampleTopic.name,
    servicebusNamespace: exampleNamespace.name,
    sharedAccessPolicyKey: exampleNamespace.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    propertyColumns: [
        "col1",
        "col2",
    ],
    serialization: {
        format: "Avro",
    },
});

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_namespace = azure.servicebus.Namespace("exampleNamespace",
    location=example_resource_group.location,
    resource_group_name=example_resource_group.name,
    sku="Standard")
example_topic = azure.servicebus.Topic("exampleTopic",
    namespace_id=example_namespace.id,
    enable_partitioning=True)
example_output_servicebus_topic = azure.streamanalytics.OutputServicebusTopic("exampleOutputServicebusTopic",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    topic_name=example_topic.name,
    servicebus_namespace=example_namespace.name,
    shared_access_policy_key=example_namespace.default_primary_key,
    shared_access_policy_name="RootManageSharedAccessKey",
    property_columns=[
        "col1",
        "col2",
    ],
    serialization=azure.streamanalytics.OutputServicebusTopicSerializationArgs(
        format="Avro",
    ))