azure.streamanalytics.OutputServiceBusQueue

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 exampleQueue = new Azure.ServiceBus.Queue("exampleQueue", new Azure.ServiceBus.QueueArgs
        {
            NamespaceId = exampleNamespace.Id,
            EnablePartitioning = true,
        });
        var exampleOutputServiceBusQueue = new Azure.StreamAnalytics.OutputServiceBusQueue("exampleOutputServiceBusQueue", new Azure.StreamAnalytics.OutputServiceBusQueueArgs
        {
            StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
            ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
            QueueName = exampleQueue.Name,
            ServicebusNamespace = exampleNamespace.Name,
            SharedAccessPolicyKey = exampleNamespace.DefaultPrimaryKey,
            SharedAccessPolicyName = "RootManageSharedAccessKey",
            Serialization = new Azure.StreamAnalytics.Inputs.OutputServiceBusQueueSerializationArgs
            {
                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
		}
		exampleQueue, err := servicebus.NewQueue(ctx, "exampleQueue", &servicebus.QueueArgs{
			NamespaceId:        exampleNamespace.ID(),
			EnablePartitioning: pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewOutputServiceBusQueue(ctx, "exampleOutputServiceBusQueue", &streamanalytics.OutputServiceBusQueueArgs{
			StreamAnalyticsJobName: pulumi.String(exampleJob.Name),
			ResourceGroupName:      pulumi.String(exampleJob.ResourceGroupName),
			QueueName:              exampleQueue.Name,
			ServicebusNamespace:    exampleNamespace.Name,
			SharedAccessPolicyKey:  exampleNamespace.DefaultPrimaryKey,
			SharedAccessPolicyName: pulumi.String("RootManageSharedAccessKey"),
			Serialization: &streamanalytics.OutputServiceBusQueueSerializationArgs{
				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 exampleQueue = new azure.servicebus.Queue("exampleQueue", {
    namespaceId: exampleNamespace.id,
    enablePartitioning: true,
});
const exampleOutputServiceBusQueue = new azure.streamanalytics.OutputServiceBusQueue("exampleOutputServiceBusQueue", {
    streamAnalyticsJobName: exampleJob.then(exampleJob => exampleJob.name),
    resourceGroupName: exampleJob.then(exampleJob => exampleJob.resourceGroupName),
    queueName: exampleQueue.name,
    servicebusNamespace: exampleNamespace.name,
    sharedAccessPolicyKey: exampleNamespace.defaultPrimaryKey,
    sharedAccessPolicyName: "RootManageSharedAccessKey",
    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_queue = azure.servicebus.Queue("exampleQueue",
    namespace_id=example_namespace.id,
    enable_partitioning=True)
example_output_service_bus_queue = azure.streamanalytics.OutputServiceBusQueue("exampleOutputServiceBusQueue",
    stream_analytics_job_name=example_job.name,
    resource_group_name=example_job.resource_group_name,
    queue_name=example_queue.name,
    servicebus_namespace=example_namespace.name,
    shared_access_policy_key=example_namespace.default_primary_key,
    shared_access_policy_name="RootManageSharedAccessKey",
    serialization=azure.streamanalytics.OutputServiceBusQueueSerializationArgs(
        format="Avro",
    ))