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

StreamInputEventHubArgs

data class StreamInputEventHubArgs(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 resourceGroupName: Output<String>? = null, val serialization: Output<StreamInputEventHubSerializationArgs>? = null, val servicebusNamespace: Output<String>? = null, val sharedAccessPolicyKey: Output<String>? = null, val sharedAccessPolicyName: Output<String>? = null, val streamAnalyticsJobName: Output<String>? = null) : ConvertibleToJava<StreamInputEventHubArgs>

Note: This resource creates a Stream Input of type Microsoft.ServiceBus/EventHub, to create a Stream Input of type Microsoft.EventHub/EventHub please use the resource azurerm_stream_analytics_stream_input_eventhub_v2. Manages a Stream Analytics Stream Input 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.eventhub.ConsumerGroup;
import com.pulumi.azure.eventhub.ConsumerGroupArgs;
import com.pulumi.azure.streamanalytics.StreamInputEventHub;
import com.pulumi.azure.streamanalytics.StreamInputEventHubArgs;
import com.pulumi.azure.streamanalytics.inputs.StreamInputEventHubSerializationArgs;
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 exampleStreamInputEventHub = new StreamInputEventHub("exampleStreamInputEventHub", StreamInputEventHubArgs.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())))
            .eventhubConsumerGroupName(exampleConsumerGroup.name())
            .eventhubName(exampleEventHub.name())
            .servicebusNamespace(exampleEventHubNamespace.name())
            .sharedAccessPolicyKey(exampleEventHubNamespace.defaultPrimaryKey())
            .sharedAccessPolicyName("RootManageSharedAccessKey")
            .serialization(StreamInputEventHubSerializationArgs.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/streamInputEventHub:StreamInputEventHub 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 StreamInputEventHubArgs(authenticationMode: Output<String>? = null, eventhubConsumerGroupName: Output<String>? = null, eventhubName: Output<String>? = null, name: Output<String>? = null, partitionKey: Output<String>? = null, resourceGroupName: Output<String>? = null, serialization: Output<StreamInputEventHubSerializationArgs>? = 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(): StreamInputEventHubArgs

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. 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 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<StreamInputEventHubSerializationArgs>? = 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 streamAnalyticsJobName: Output<String>? = null

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