Show / Hide Table of Contents

Class StreamInputIotHub

Manages a Stream Analytics Stream Input IoTHub.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
    {
        Name = "example-resources",
    }));
    var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
    {
        Name = "example-job",
        ResourceGroupName = azurerm_resource_group.Example.Name,
    }));
    var exampleIoTHub = new Azure.Iot.IoTHub("exampleIoTHub", new Azure.Iot.IoTHubArgs
    {
        ResourceGroupName = azurerm_resource_group.Example.Name,
        Location = azurerm_resource_group.Example.Location,
        Sku = new Azure.Iot.Inputs.IoTHubSkuArgs
        {
            Name = "S1",
            Capacity = "1",
        },
    });
    var exampleStreamInputIotHub = new Azure.StreamAnalytics.StreamInputIotHub("exampleStreamInputIotHub", new Azure.StreamAnalytics.StreamInputIotHubArgs
    {
        StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
        ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
        Endpoint = "messages/events",
        EventhubConsumerGroupName = "$Default",
        IothubNamespace = exampleIoTHub.Name,
        SharedAccessPolicyKey = exampleIoTHub.SharedAccessPolicies.Apply(sharedAccessPolicies => sharedAccessPolicies[0].PrimaryKey),
        SharedAccessPolicyName = "iothubowner",
        Serialization = new Azure.StreamAnalytics.Inputs.StreamInputIotHubSerializationArgs
        {
            Type = "Json",
            Encoding = "UTF8",
        },
    });
}

}
Inheritance
System.Object
Resource
CustomResource
StreamInputIotHub
Inherited Members
CustomResource.Id
Resource.GetResourceType()
Resource.GetResourceName()
Resource.Urn
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Pulumi.Azure.StreamAnalytics
Assembly: Pulumi.Azure.dll
Syntax
public class StreamInputIotHub : CustomResource

Constructors

View Source

StreamInputIotHub(String, StreamInputIotHubArgs, CustomResourceOptions)

Create a StreamInputIotHub resource with the given unique name, arguments, and options.

Declaration
public StreamInputIotHub(string name, StreamInputIotHubArgs args, CustomResourceOptions options = null)
Parameters
Type Name Description
System.String name

The unique name of the resource

StreamInputIotHubArgs args

The arguments used to populate this resource's properties

CustomResourceOptions options

A bag of options that control this resource's behavior

Properties

View Source

Endpoint

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

Declaration
public Output<string> Endpoint { get; }
Property Value
Type Description
Output<System.String>
View Source

EventhubConsumerGroupName

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.

Declaration
public Output<string> EventhubConsumerGroupName { get; }
Property Value
Type Description
Output<System.String>
View Source

IothubNamespace

The name or the URI of the IoT Hub.

Declaration
public Output<string> IothubNamespace { get; }
Property Value
Type Description
Output<System.String>
View Source

Name

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

Declaration
public Output<string> Name { get; }
Property Value
Type Description
Output<System.String>
View Source

ResourceGroupName

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

Declaration
public Output<string> ResourceGroupName { get; }
Property Value
Type Description
Output<System.String>
View Source

Serialization

A serialization block as defined below.

Declaration
public Output<StreamInputIotHubSerialization> Serialization { get; }
Property Value
Type Description
Output<StreamInputIotHubSerialization>
View Source

SharedAccessPolicyKey

The shared access policy key for the specified shared access policy.

Declaration
public Output<string> SharedAccessPolicyKey { get; }
Property Value
Type Description
Output<System.String>
View Source

SharedAccessPolicyName

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

Declaration
public Output<string> SharedAccessPolicyName { get; }
Property Value
Type Description
Output<System.String>
View Source

StreamAnalyticsJobName

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

Declaration
public Output<string> StreamAnalyticsJobName { get; }
Property Value
Type Description
Output<System.String>

Methods

View Source

Get(String, Input<String>, StreamInputIotHubState, CustomResourceOptions)

Get an existing StreamInputIotHub resource's state with the given name, ID, and optional extra properties used to qualify the lookup.

Declaration
public static StreamInputIotHub Get(string name, Input<string> id, StreamInputIotHubState state = null, CustomResourceOptions options = null)
Parameters
Type Name Description
System.String name

The unique name of the resulting resource.

Input<System.String> id

The unique provider ID of the resource to lookup.

StreamInputIotHubState state

Any extra arguments used during the lookup.

CustomResourceOptions options

A bag of options that control this resource's behavior

Returns
Type Description
StreamInputIotHub
  • View Source
Back to top Copyright 2016-2020, Pulumi Corporation.