pulumi-azure-native-kotlin/com.pulumi.azurenative.timeseriesinsights.kotlin/EventHubEventSourceArgs

EventHubEventSourceArgs

data class EventHubEventSourceArgs(val consumerGroupName: Output<String>? = null, val environmentName: Output<String>? = null, val eventHubName: Output<String>? = null, val eventSourceName: Output<String>? = null, val eventSourceResourceId: Output<String>? = null, val keyName: Output<String>? = null, val kind: Output<String>? = null, val localTimestamp: Output<LocalTimestampArgs>? = null, val location: Output<String>? = null, val resourceGroupName: Output<String>? = null, val serviceBusNamespace: Output<String>? = null, val sharedAccessKey: Output<String>? = null, val tags: Output<Map<String, String>>? = null, val time: Output<String>? = null, val timestampPropertyName: Output<String>? = null, val type: Output<Either<String, IngressStartAtType>>? = null) : ConvertibleToJava<EventHubEventSourceArgs>

An event source that receives its data from an Azure EventHub. Uses Azure REST API version 2020-05-15. In version 2.x of the Azure Native provider, it used API version 2020-05-15.

Example Usage

CreateEventHubEventSource

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
    var eventHubEventSource = new AzureNative.TimeSeriesInsights.EventHubEventSource("eventHubEventSource", new()
    {
        ConsumerGroupName = "cgn",
        EnvironmentName = "env1",
        EventHubName = "ehn",
        EventSourceName = "es1",
        EventSourceResourceId = "somePathInArm",
        KeyName = "managementKey",
        Kind = "Microsoft.EventHub",
        Location = "West US",
        ResourceGroupName = "rg1",
        ServiceBusNamespace = "sbn",
        SharedAccessKey = "someSecretvalue",
        TimestampPropertyName = "someTimestampProperty",
        Type = AzureNative.TimeSeriesInsights.IngressStartAtType.EarliestAvailable,
    });
});
Content copied to clipboard
package main
import (
	timeseriesinsights "github.com/pulumi/pulumi-azure-native-sdk/timeseriesinsights/v3"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := timeseriesinsights.NewEventHubEventSource(ctx, "eventHubEventSource", &timeseriesinsights.EventHubEventSourceArgs{
			ConsumerGroupName:     pulumi.String("cgn"),
			EnvironmentName:       pulumi.String("env1"),
			EventHubName:          pulumi.String("ehn"),
			EventSourceName:       pulumi.String("es1"),
			EventSourceResourceId: pulumi.String("somePathInArm"),
			KeyName:               pulumi.String("managementKey"),
			Kind:                  pulumi.String("Microsoft.EventHub"),
			Location:              pulumi.String("West US"),
			ResourceGroupName:     pulumi.String("rg1"),
			ServiceBusNamespace:   pulumi.String("sbn"),
			SharedAccessKey:       pulumi.String("someSecretvalue"),
			TimestampPropertyName: pulumi.String("someTimestampProperty"),
			Type:                  pulumi.String(timeseriesinsights.IngressStartAtTypeEarliestAvailable),
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.timeseriesinsights.EventHubEventSource;
import com.pulumi.azurenative.timeseriesinsights.EventHubEventSourceArgs;
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 eventHubEventSource = new EventHubEventSource("eventHubEventSource", EventHubEventSourceArgs.builder()
            .consumerGroupName("cgn")
            .environmentName("env1")
            .eventHubName("ehn")
            .eventSourceName("es1")
            .eventSourceResourceId("somePathInArm")
            .keyName("managementKey")
            .kind("Microsoft.EventHub")
            .location("West US")
            .resourceGroupName("rg1")
            .serviceBusNamespace("sbn")
            .sharedAccessKey("someSecretvalue")
            .timestampPropertyName("someTimestampProperty")
            .type("EarliestAvailable")
            .build());
    }
}
Content copied to clipboard

EventSourcesCreateEventHubWithCustomEnquedTime

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
    var eventHubEventSource = new AzureNative.TimeSeriesInsights.EventHubEventSource("eventHubEventSource", new()
    {
        ConsumerGroupName = "cgn",
        EnvironmentName = "env1",
        EventHubName = "ehn",
        EventSourceName = "es1",
        EventSourceResourceId = "somePathInArm",
        KeyName = "managementKey",
        Kind = "Microsoft.EventHub",
        Location = "West US",
        ResourceGroupName = "rg1",
        ServiceBusNamespace = "sbn",
        SharedAccessKey = "someSecretvalue",
        Time = "2017-04-01T19:20:33.2288820Z",
        TimestampPropertyName = "someTimestampProperty",
        Type = AzureNative.TimeSeriesInsights.IngressStartAtType.CustomEnqueuedTime,
    });
});
Content copied to clipboard
package main
import (
	timeseriesinsights "github.com/pulumi/pulumi-azure-native-sdk/timeseriesinsights/v3"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := timeseriesinsights.NewEventHubEventSource(ctx, "eventHubEventSource", &timeseriesinsights.EventHubEventSourceArgs{
			ConsumerGroupName:     pulumi.String("cgn"),
			EnvironmentName:       pulumi.String("env1"),
			EventHubName:          pulumi.String("ehn"),
			EventSourceName:       pulumi.String("es1"),
			EventSourceResourceId: pulumi.String("somePathInArm"),
			KeyName:               pulumi.String("managementKey"),
			Kind:                  pulumi.String("Microsoft.EventHub"),
			Location:              pulumi.String("West US"),
			ResourceGroupName:     pulumi.String("rg1"),
			ServiceBusNamespace:   pulumi.String("sbn"),
			SharedAccessKey:       pulumi.String("someSecretvalue"),
			Time:                  pulumi.String("2017-04-01T19:20:33.2288820Z"),
			TimestampPropertyName: pulumi.String("someTimestampProperty"),
			Type:                  pulumi.String(timeseriesinsights.IngressStartAtTypeCustomEnqueuedTime),
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azurenative.timeseriesinsights.EventHubEventSource;
import com.pulumi.azurenative.timeseriesinsights.EventHubEventSourceArgs;
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 eventHubEventSource = new EventHubEventSource("eventHubEventSource", EventHubEventSourceArgs.builder()
            .consumerGroupName("cgn")
            .environmentName("env1")
            .eventHubName("ehn")
            .eventSourceName("es1")
            .eventSourceResourceId("somePathInArm")
            .keyName("managementKey")
            .kind("Microsoft.EventHub")
            .location("West US")
            .resourceGroupName("rg1")
            .serviceBusNamespace("sbn")
            .sharedAccessKey("someSecretvalue")
            .time("2017-04-01T19:20:33.2288820Z")
            .timestampPropertyName("someTimestampProperty")
            .type("CustomEnqueuedTime")
            .build());
    }
}
Content copied to clipboard

Import

An existing resource can be imported using its type token, name, and identifier, e.g.

$ pulumi import azure-native:timeseriesinsights:EventHubEventSource es1 /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.TimeSeriesInsights/environments/{environmentName}/eventSources/{eventSourceName}
Content copied to clipboard

Constructors

Link copied to clipboard
constructor(consumerGroupName: Output<String>? = null, environmentName: Output<String>? = null, eventHubName: Output<String>? = null, eventSourceName: Output<String>? = null, eventSourceResourceId: Output<String>? = null, keyName: Output<String>? = null, kind: Output<String>? = null, localTimestamp: Output<LocalTimestampArgs>? = null, location: Output<String>? = null, resourceGroupName: Output<String>? = null, serviceBusNamespace: Output<String>? = null, sharedAccessKey: Output<String>? = null, tags: Output<Map<String, String>>? = null, time: Output<String>? = null, timestampPropertyName: Output<String>? = null, type: Output<Either<String, IngressStartAtType>>? = null)

Properties

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

The name of the event hub's consumer group that holds the partitions from which events will be read.

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

The name of the Time Series Insights environment associated with the specified resource group.

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

The name of the event hub.

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

Name of the event source.

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

The resource id of the event source in Azure Resource Manager.

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

The name of the SAS key that grants the Time Series Insights service access to the event hub. The shared access policies for this key must grant 'Listen' permissions to the event hub.

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

The kind of the event source. Expected value is 'Microsoft.EventHub'.

Link copied to clipboard
val localTimestamp: Output<LocalTimestampArgs>? = null

An object that represents the local timestamp property. It contains the format of local timestamp that needs to be used and the corresponding timezone offset information. If a value isn't specified for localTimestamp, or if null, then the local timestamp will not be ingressed with the events.

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

The location of the resource.

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

Name of an Azure Resource group.

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

The name of the service bus that contains the event hub.

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

The value of the shared access key that grants the Time Series Insights service read access to the event hub. This property is not shown in event source responses.

Link copied to clipboard
val tags: Output<Map<String, String>>? = null

Key-value pairs of additional properties for the resource.

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

ISO8601 UTC datetime with seconds precision (milliseconds are optional), specifying the date and time that will be the starting point for Events to be consumed.

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

The event property that will be used as the event source's timestamp. If a value isn't specified for timestampPropertyName, or if null or empty-string is specified, the event creation time will be used.

Link copied to clipboard
val type: Output<Either<String, IngressStartAtType>>? = null

The type of the ingressStartAt, It can be "EarliestAvailable", "EventSourceCreationTime", "CustomEnqueuedTime".

Functions

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