pulumi-azure-kotlin/com.pulumi.azure.streamanalytics.kotlin/OutputServiceBusQueue

OutputServiceBusQueue

class OutputServiceBusQueue : KotlinCustomResource

Manages a Stream Analytics Output to a ServiceBus Queue.

Example Usage

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azure.core.ResourceGroup;
import com.pulumi.azure.core.ResourceGroupArgs;
import com.pulumi.azure.streamanalytics.StreamanalyticsFunctions;
import com.pulumi.azure.streamanalytics.inputs.GetJobArgs;
import com.pulumi.azure.servicebus.Namespace;
import com.pulumi.azure.servicebus.NamespaceArgs;
import com.pulumi.azure.servicebus.Queue;
import com.pulumi.azure.servicebus.QueueArgs;
import com.pulumi.azure.streamanalytics.OutputServiceBusQueue;
import com.pulumi.azure.streamanalytics.OutputServiceBusQueueArgs;
import com.pulumi.azure.streamanalytics.inputs.OutputServiceBusQueueSerializationArgs;
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 exampleResourceGroup = new ResourceGroup("exampleResourceGroup", ResourceGroupArgs.builder()
            .name("rg-example")
            .location("West Europe")
            .build());
        final var example = StreamanalyticsFunctions.getJob(GetJobArgs.builder()
            .name("example-job")
            .resourceGroupName(exampleResourceGroup.name())
            .build());
        var exampleNamespace = new Namespace("exampleNamespace", NamespaceArgs.builder()
            .name("example-namespace")
            .location(exampleResourceGroup.location())
            .resourceGroupName(exampleResourceGroup.name())
            .sku("Standard")
            .build());
        var exampleQueue = new Queue("exampleQueue", QueueArgs.builder()
            .name("example-queue")
            .namespaceId(exampleNamespace.id())
            .enablePartitioning(true)
            .build());
        var exampleOutputServiceBusQueue = new OutputServiceBusQueue("exampleOutputServiceBusQueue", OutputServiceBusQueueArgs.builder()
            .name("blob-storage-output")
            .streamAnalyticsJobName(example.applyValue(getJobResult -> getJobResult).applyValue(example -> example.applyValue(getJobResult -> getJobResult.name())))
            .resourceGroupName(example.applyValue(getJobResult -> getJobResult).applyValue(example -> example.applyValue(getJobResult -> getJobResult.resourceGroupName())))
            .queueName(exampleQueue.name())
            .servicebusNamespace(exampleNamespace.name())
            .sharedAccessPolicyKey(exampleNamespace.defaultPrimaryKey())
            .sharedAccessPolicyName("RootManageSharedAccessKey")
            .serialization(OutputServiceBusQueueSerializationArgs.builder()
                .type("Csv")
                .format("Array")
                .build())
            .build());
    }
}

Import

Stream Analytics Output ServiceBus Queue's can be imported using the resource id, e.g.

$ pulumi import azure:streamanalytics/outputServiceBusQueue:OutputServiceBusQueue example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1/outputs/output1

Properties

authenticationMode

val authenticationMode: Output<String>?

The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.

val id: Output<String>

name

val name: Output<String>

The name of the Stream Output. Changing this forces a new resource to be created.

propertyColumns

val propertyColumns: Output<List<String>>?

A list of property columns to add to the Service Bus Queue output.

pulumiChildResources

val pulumiChildResources: Set<KotlinResource>

pulumiResourceName

val pulumiResourceName: String

pulumiResourceType

val pulumiResourceType: String

queueName

val queueName: Output<String>

The name of the Service Bus Queue.

resourceGroupName

val resourceGroupName: Output<String>

The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.

serialization

val serialization: Output<OutputServiceBusQueueSerialization>

A serialization block as defined below.

servicebusNamespace

val servicebusNamespace: Output<String>

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

sharedAccessPolicyKey

val sharedAccessPolicyKey: Output<String>?

The shared access policy key for the specified shared access policy. Required if authentication_mode is ConnectionString.

sharedAccessPolicyName

val sharedAccessPolicyName: Output<String>?

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required if authentication_mode is ConnectionString.

streamAnalyticsJobName

val streamAnalyticsJobName: Output<String>

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

systemPropertyColumns

val systemPropertyColumns: Output<Map<String, String>>?

A key-value pair of system property columns that will be attached to the outgoing messages for the Service Bus Queue Output.

urn

val urn: Output<String>