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

OutputEventHubArgs

data class OutputEventHubArgs(val authenticationMode: Output<String>? = null, val eventhubName: Output<String>? = null, val name: Output<String>? = null, val partitionKey: Output<String>? = null, val propertyColumns: Output<List<String>>? = null, val resourceGroupName: Output<String>? = null, val serialization: Output<OutputEventHubSerializationArgs>? = null, val servicebusNamespace: Output<String>? = null, val sharedAccessPolicyKey: Output<String>? = null, val sharedAccessPolicyName: Output<String>? = null, val streamAnalyticsJobName: Output<String>? = null) : ConvertibleToJava<OutputEventHubArgs>

Manages a Stream Analytics Output to an EventHub.

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.eventhub.EventHubNamespace;
import com.pulumi.azure.eventhub.EventHubNamespaceArgs;
import com.pulumi.azure.eventhub.EventHub;
import com.pulumi.azure.eventhub.EventHubArgs;
import com.pulumi.azure.streamanalytics.OutputEventHub;
import com.pulumi.azure.streamanalytics.OutputEventHubArgs;
import com.pulumi.azure.streamanalytics.inputs.OutputEventHubSerializationArgs;
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()
            .location("West Europe")
            .build());
        final var exampleJob = StreamanalyticsFunctions.getJob(GetJobArgs.builder()
            .name("example-job")
            .resourceGroupName(exampleResourceGroup.name())
            .build());
        var exampleEventHubNamespace = new EventHubNamespace("exampleEventHubNamespace", EventHubNamespaceArgs.builder()
            .location(exampleResourceGroup.location())
            .resourceGroupName(exampleResourceGroup.name())
            .sku("Standard")
            .capacity(1)
            .build());
        var exampleEventHub = new EventHub("exampleEventHub", EventHubArgs.builder()
            .namespaceName(exampleEventHubNamespace.name())
            .resourceGroupName(exampleResourceGroup.name())
            .partitionCount(2)
            .messageRetention(1)
            .build());
        var exampleOutputEventHub = new OutputEventHub("exampleOutputEventHub", OutputEventHubArgs.builder()
            .streamAnalyticsJobName(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.applyValue(getJobResult -> getJobResult.name())))
            .resourceGroupName(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.applyValue(getJobResult -> getJobResult.resourceGroupName())))
            .eventhubName(exampleEventHub.name())
            .servicebusNamespace(exampleEventHubNamespace.name())
            .sharedAccessPolicyKey(exampleEventHubNamespace.defaultPrimaryKey())
            .sharedAccessPolicyName("RootManageSharedAccessKey")
            .serialization(OutputEventHubSerializationArgs.builder()
                .type("Avro")
                .build())
            .build());
    }
}
Content copied to clipboard

Import

Stream Analytics Outputs to an EventHub can be imported using the resource id, e.g.

$ pulumi import azure:streamanalytics/outputEventHub:OutputEventHub example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1/outputs/output1
Content copied to clipboard

Constructors

Link copied to clipboard
fun OutputEventHubArgs(authenticationMode: Output<String>? = null, eventhubName: Output<String>? = null, name: Output<String>? = null, partitionKey: Output<String>? = null, propertyColumns: Output<List<String>>? = null, resourceGroupName: Output<String>? = null, serialization: Output<OutputEventHubSerializationArgs>? = null, servicebusNamespace: Output<String>? = null, sharedAccessPolicyKey: Output<String>? = null, sharedAccessPolicyName: Output<String>? = null, streamAnalyticsJobName: Output<String>? = null)

Functions

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

Properties

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

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

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

The name of the Event Hub.

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

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

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

The column that is used for the Event Hub partition key.

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

A list of property columns to add to the Event Hub output.

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

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

Link copied to clipboard
val serialization: Output<OutputEventHubSerializationArgs>? = null

A serialization block as defined below.

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

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

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

The shared access policy key for the specified shared access policy. Required when authentication_mode is set to ConnectionString.

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

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

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

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