Class StreamInputEventHub

Manages a Stream Analytics Stream Input EventHub.

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 exampleEventHubNamespace = new Azure.EventHub.EventHubNamespace("exampleEventHubNamespace", new Azure.EventHub.EventHubNamespaceArgs
    {
        Location = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Location),
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        Sku = "Standard",
        Capacity = 1,
    });
    var exampleEventHub = new Azure.EventHub.EventHub("exampleEventHub", new Azure.EventHub.EventHubArgs
    {
        NamespaceName = exampleEventHubNamespace.Name,
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
        PartitionCount = 2,
        MessageRetention = 1,
    });
    var exampleConsumerGroup = new Azure.EventHub.ConsumerGroup("exampleConsumerGroup", new Azure.EventHub.ConsumerGroupArgs
    {
        NamespaceName = exampleEventHubNamespace.Name,
        EventhubName = exampleEventHub.Name,
        ResourceGroupName = exampleResourceGroup.Apply(exampleResourceGroup => exampleResourceGroup.Name),
    });
    var exampleStreamInputEventHub = new Azure.StreamAnalytics.StreamInputEventHub("exampleStreamInputEventHub", new Azure.StreamAnalytics.StreamInputEventHubArgs
    {
        StreamAnalyticsJobName = exampleJob.Apply(exampleJob => exampleJob.Name),
        ResourceGroupName = exampleJob.Apply(exampleJob => exampleJob.ResourceGroupName),
        EventhubConsumerGroupName = exampleConsumerGroup.Name,
        EventhubName = exampleEventHub.Name,
        ServicebusNamespace = exampleEventHubNamespace.Name,
        SharedAccessPolicyKey = exampleEventHubNamespace.DefaultPrimaryKey,
        SharedAccessPolicyName = "RootManageSharedAccessKey",
        Serialization = new Azure.StreamAnalytics.Inputs.StreamInputEventHubSerializationArgs
        {
            Type = "Json",
            Encoding = "UTF8",
        },
    });
}

}

Inheritance

System.Object

Resource

CustomResource

StreamInputEventHub

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 StreamInputEventHub : CustomResource

Constructors

StreamInputEventHub(String, StreamInputEventHubArgs, CustomResourceOptions)

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

Declaration

public StreamInputEventHub(string name, StreamInputEventHubArgs args, CustomResourceOptions options = null)

Parameters

Type	Name	Description
System.String	name	The unique name of the resource
StreamInputEventHubArgs	args	The arguments used to populate this resource's properties
CustomResourceOptions	options	A bag of options that control this resource's behavior

Properties

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>

EventhubName

The name of the Event Hub.

Declaration

public Output<string> EventhubName { get; }

Property Value

Type	Description
Output<System.String>

Name

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

Declaration

public Output<string> Name { get; }

Property Value

Type	Description
Output<System.String>

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>

Serialization

A serialization block as defined below.

Declaration

public Output<StreamInputEventHubSerialization> Serialization { get; }

Property Value

Type	Description
Output<StreamInputEventHubSerialization>

ServicebusNamespace

The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc.

Declaration

public Output<string> ServicebusNamespace { get; }

Property Value

Type	Description
Output<System.String>

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>

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>

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

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

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

Declaration

public static StreamInputEventHub Get(string name, Input<string> id, StreamInputEventHubState 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.
StreamInputEventHubState	state	Any extra arguments used during the lookup.
CustomResourceOptions	options	A bag of options that control this resource's behavior

Returns

Type	Description
StreamInputEventHub