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

StreamInputIotHubArgs

data class StreamInputIotHubArgs(val endpoint: Output<String>? = null, val eventhubConsumerGroupName: Output<String>? = null, val iothubNamespace: Output<String>? = null, val name: Output<String>? = null, val resourceGroupName: Output<String>? = null, val serialization: Output<StreamInputIotHubSerializationArgs>? = null, val sharedAccessPolicyKey: Output<String>? = null, val sharedAccessPolicyName: Output<String>? = null, val streamAnalyticsJobName: Output<String>? = null) : ConvertibleToJava<StreamInputIotHubArgs>

Manages a Stream Analytics Stream Input IoTHub.

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.iot.IoTHub;
import com.pulumi.azure.iot.IoTHubArgs;
import com.pulumi.azure.iot.inputs.IoTHubSkuArgs;
import com.pulumi.azure.streamanalytics.StreamInputIotHub;
import com.pulumi.azure.streamanalytics.StreamInputIotHubArgs;
import com.pulumi.azure.streamanalytics.inputs.StreamInputIotHubSerializationArgs;
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 exampleIoTHub = new IoTHub("exampleIoTHub", IoTHubArgs.builder()
            .resourceGroupName(exampleResourceGroup.name())
            .location(exampleResourceGroup.location())
            .sku(IoTHubSkuArgs.builder()
                .name("S1")
                .capacity("1")
                .build())
            .build());
        var exampleStreamInputIotHub = new StreamInputIotHub("exampleStreamInputIotHub", StreamInputIotHubArgs.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())))
            .endpoint("messages/events")
            .eventhubConsumerGroupName("$Default")
            .iothubNamespace(exampleIoTHub.name())
            .sharedAccessPolicyKey(exampleIoTHub.sharedAccessPolicies().applyValue(sharedAccessPolicies -> sharedAccessPolicies[0].primaryKey()))
            .sharedAccessPolicyName("iothubowner")
            .serialization(StreamInputIotHubSerializationArgs.builder()
                .type("Json")
                .encoding("UTF8")
                .build())
            .build());
    }
}
Content copied to clipboard

Import

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

$ pulumi import azure:streamanalytics/streamInputIotHub:StreamInputIotHub 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 StreamInputIotHubArgs(endpoint: Output<String>? = null, eventhubConsumerGroupName: Output<String>? = null, iothubNamespace: Output<String>? = null, name: Output<String>? = null, resourceGroupName: Output<String>? = null, serialization: Output<StreamInputIotHubSerializationArgs>? = null, sharedAccessPolicyKey: Output<String>? = null, sharedAccessPolicyName: Output<String>? = null, streamAnalyticsJobName: Output<String>? = null)

Functions

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

Properties

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

The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).

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.

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

The name or the URI of the IoT Hub.

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

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

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<StreamInputIotHubSerializationArgs>? = null

A serialization block as defined below.

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

The shared access policy key for the specified shared access policy. Changing this forces a new resource to be created.

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.