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

StreamInputEventHubV2Args

data class StreamInputEventHubV2Args(val authenticationMode: Output<String>? = null, val eventhubConsumerGroupName: Output<String>? = null, val eventhubName: Output<String>? = null, val name: Output<String>? = null, val partitionKey: Output<String>? = null, val serialization: Output<StreamInputEventHubV2SerializationArgs>? = null, val servicebusNamespace: Output<String>? = null, val sharedAccessPolicyKey: Output<String>? = null, val sharedAccessPolicyName: Output<String>? = null, val streamAnalyticsJobId: Output<String>? = null) : ConvertibleToJava<StreamInputEventHubV2Args>

Note: This resource creates a Stream Input of type Microsoft.EventHub/EventHub, to create a Stream Input of type Microsoft.ServiceBus/EventHub please use the resource azurerm_stream_analytics_stream_input_eventhub. Manages a Stream Analytics Stream Input EventHub V2.

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.eventhub.ConsumerGroup;
import com.pulumi.azure.eventhub.ConsumerGroupArgs;
import com.pulumi.azure.streamanalytics.StreamInputEventHubV2;
import com.pulumi.azure.streamanalytics.StreamInputEventHubV2Args;
import com.pulumi.azure.streamanalytics.inputs.StreamInputEventHubV2SerializationArgs;
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 exampleConsumerGroup = new ConsumerGroup("exampleConsumerGroup", ConsumerGroupArgs.builder()
            .namespaceName(exampleEventHubNamespace.name())
            .eventhubName(exampleEventHub.name())
            .resourceGroupName(exampleResourceGroup.name())
            .build());
        var exampleStreamInputEventHubV2 = new StreamInputEventHubV2("exampleStreamInputEventHubV2", StreamInputEventHubV2Args.builder()
            .streamAnalyticsJobId(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.applyValue(getJobResult -> getJobResult.id())))
            .eventhubConsumerGroupName(exampleConsumerGroup.name())
            .eventhubName(exampleEventHub.name())
            .servicebusNamespace(exampleEventHubNamespace.name())
            .sharedAccessPolicyKey(exampleEventHubNamespace.defaultPrimaryKey())
            .sharedAccessPolicyName("RootManageSharedAccessKey")
            .serialization(StreamInputEventHubV2SerializationArgs.builder()
                .type("Json")
                .encoding("UTF8")
                .build())
            .build());
    }
}
Content copied to clipboard

Import

Stream Analytics Stream Input EventHub's can be imported using the resource id, e.g.

$ pulumi import azure:streamanalytics/streamInputEventHubV2:StreamInputEventHubV2 example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1/inputs/input1
Content copied to clipboard

Constructors

Link copied to clipboard
fun StreamInputEventHubV2Args(authenticationMode: Output<String>? = null, eventhubConsumerGroupName: Output<String>? = null, eventhubName: Output<String>? = null, name: Output<String>? = null, partitionKey: Output<String>? = null, serialization: Output<StreamInputEventHubV2SerializationArgs>? = null, servicebusNamespace: Output<String>? = null, sharedAccessPolicyKey: Output<String>? = null, sharedAccessPolicyName: Output<String>? = null, streamAnalyticsJobId: Output<String>? = null)

Functions

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

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 eventhubConsumerGroupName: Output<String>? = null

The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not set the input will use the Event Hub's default consumer group.

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 Input EventHub V2. Changing this forces a new resource to be created.

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

The property the input Event Hub has been partitioned by.

Link copied to clipboard
val serialization: Output<StreamInputEventHubV2SerializationArgs>? = 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.

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.

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

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