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

EventHubEventSource

class EventHubEventSource : KotlinCustomResource

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

Properties

Link copied to clipboard
val azureApiVersion: Output<String>

The Azure API version of the resource.

Link copied to clipboard
val consumerGroupName: Output<String>

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

Link copied to clipboard
val creationTime: Output<String>

The time the resource was created.

Link copied to clipboard
val eventHubName: Output<String>

The name of the event hub.

Link copied to clipboard
val eventSourceResourceId: Output<String>

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

Link copied to clipboard
val id: Output<String>
Link copied to clipboard
val keyName: Output<String>

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>

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

Link copied to clipboard
val localTimestamp: Output<LocalTimestampResponse>?

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>

Resource location

Link copied to clipboard
val name: Output<String>

Resource name

Link copied to clipboard
val provisioningState: Output<String>

Provisioning state of the resource.

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val serviceBusNamespace: Output<String>

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

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

Resource tags

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

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>?

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<String>

Resource type

Link copied to clipboard
val urn: Output<String>