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

StreamInputIotHub

class StreamInputIotHub : KotlinCustomResource

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

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

Properties

endpoint

val endpoint: Output<String>

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

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.

val id: Output<String>

iothubNamespace

val iothubNamespace: Output<String>

The name or the URI of the IoT Hub.

name

val name: Output<String>

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

pulumiChildResources

val pulumiChildResources: Set<KotlinResource>

pulumiResourceName

val pulumiResourceName: String

pulumiResourceType

val pulumiResourceType: String

resourceGroupName

val resourceGroupName: Output<String>

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

serialization

val serialization: Output<StreamInputIotHubSerialization>

A serialization block as defined below.

sharedAccessPolicyKey

val sharedAccessPolicyKey: Output<String>

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

sharedAccessPolicyName

val sharedAccessPolicyName: Output<String>

The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc.

streamAnalyticsJobName

val streamAnalyticsJobName: Output<String>

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

urn

val urn: Output<String>