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

IoTHubEventSourceArgs

data class IoTHubEventSourceArgs(val consumerGroupName: Output<String>? = null, val environmentName: Output<String>? = null, val eventSourceName: Output<String>? = null, val eventSourceResourceId: Output<String>? = null, val iotHubName: 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 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<IoTHubEventSourceArgs>

An event source that receives its data from an Azure IoTHub. 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 ioTHubEventSource = new AzureNative.TimeSeriesInsights.IoTHubEventSource("ioTHubEventSource", new()
    {
        EnvironmentName = "env1",
        EventSourceName = "es1",
        ResourceGroupName = "rg1",
    });
});
Content copied to clipboard
package main
import (
	timeseriesinsights "github.com/pulumi/pulumi-azure-native-sdk/timeseriesinsights"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := timeseriesinsights.NewIoTHubEventSource(ctx, "ioTHubEventSource", &timeseriesinsights.IoTHubEventSourceArgs{
			EnvironmentName:   pulumi.String("env1"),
			EventSourceName:   pulumi.String("es1"),
			ResourceGroupName: pulumi.String("rg1"),
		})
		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.IoTHubEventSource;
import com.pulumi.azurenative.timeseriesinsights.IoTHubEventSourceArgs;
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 ioTHubEventSource = new IoTHubEventSource("ioTHubEventSource", IoTHubEventSourceArgs.builder()
            .environmentName("env1")
            .eventSourceName("es1")
            .resourceGroupName("rg1")
            .build());
    }
}
Content copied to clipboard

EventSourcesCreateEventHubWithCustomEnquedTime

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AzureNative = Pulumi.AzureNative;
return await Deployment.RunAsync(() =>
{
    var ioTHubEventSource = new AzureNative.TimeSeriesInsights.IoTHubEventSource("ioTHubEventSource", new()
    {
        EnvironmentName = "env1",
        EventSourceName = "es1",
        ResourceGroupName = "rg1",
    });
});
Content copied to clipboard
package main
import (
	timeseriesinsights "github.com/pulumi/pulumi-azure-native-sdk/timeseriesinsights"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := timeseriesinsights.NewIoTHubEventSource(ctx, "ioTHubEventSource", &timeseriesinsights.IoTHubEventSourceArgs{
			EnvironmentName:   pulumi.String("env1"),
			EventSourceName:   pulumi.String("es1"),
			ResourceGroupName: pulumi.String("rg1"),
		})
		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.IoTHubEventSource;
import com.pulumi.azurenative.timeseriesinsights.IoTHubEventSourceArgs;
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 ioTHubEventSource = new IoTHubEventSource("ioTHubEventSource", IoTHubEventSourceArgs.builder()
            .environmentName("env1")
            .eventSourceName("es1")
            .resourceGroupName("rg1")
            .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:IoTHubEventSource es1 /subscriptions/subid/resourceGroups/rg1/providers/Microsoft.TimeSeriesInsights/Environments/env1/eventSources/es1
Content copied to clipboard

Constructors

Link copied to clipboard
fun IoTHubEventSourceArgs(consumerGroupName: Output<String>? = null, environmentName: Output<String>? = null, eventSourceName: Output<String>? = null, eventSourceResourceId: Output<String>? = null, iotHubName: Output<String>? = null, keyName: Output<String>? = null, kind: Output<String>? = null, localTimestamp: Output<LocalTimestampArgs>? = null, location: Output<String>? = null, resourceGroupName: 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)

Functions

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

Properties

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

The name of the iot 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 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 iotHubName: Output<String>? = null

The name of the iot hub.

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

The name of the Shared Access Policy key that grants the Time Series Insights service access to the iot hub. This shared access policy key must grant 'service connect' permissions to the iot hub.

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

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

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 sharedAccessKey: Output<String>? = null

The value of the Shared Access Policy key that grants the Time Series Insights service read access to the iot 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".