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

StreamInputEventHub

class StreamInputEventHub : KotlinCustomResource

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());
    }
}

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

Properties

authenticationMode

val authenticationMode: Output<String>?

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

eventhubConsumerGroupName

val eventhubConsumerGroupName: Output<String>?

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.

eventhubName

val eventhubName: Output<String>

The name of the Event Hub.