azure.iot.TimeSeriesInsightsEventSourceIothub

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
    public MyStack()
    {
        var exampleResourceGroup = new Azure.Core.ResourceGroup("exampleResourceGroup", new Azure.Core.ResourceGroupArgs
        {
            Location = "West Europe",
        });
        var exampleIoTHub = new Azure.Iot.IoTHub("exampleIoTHub", new Azure.Iot.IoTHubArgs
        {
            ResourceGroupName = exampleResourceGroup.Name,
            Location = exampleResourceGroup.Location,
            Sku = new Azure.Iot.Inputs.IoTHubSkuArgs
            {
                Name = "B1",
                Capacity = 1,
            },
        });
        var exampleConsumerGroup = new Azure.Iot.ConsumerGroup("exampleConsumerGroup", new Azure.Iot.ConsumerGroupArgs
        {
            IothubName = exampleIoTHub.Name,
            EventhubEndpointName = "events",
            ResourceGroupName = exampleResourceGroup.Name,
        });
        var storage = new Azure.Storage.Account("storage", new Azure.Storage.AccountArgs
        {
            Location = exampleResourceGroup.Location,
            ResourceGroupName = exampleResourceGroup.Name,
            AccountTier = "Standard",
            AccountReplicationType = "LRS",
        });
        var exampleTimeSeriesInsightsGen2Environment = new Azure.Iot.TimeSeriesInsightsGen2Environment("exampleTimeSeriesInsightsGen2Environment", new Azure.Iot.TimeSeriesInsightsGen2EnvironmentArgs
        {
            Location = exampleResourceGroup.Location,
            ResourceGroupName = exampleResourceGroup.Name,
            SkuName = "L1",
            IdProperties = 
            {
                "id",
            },
            Storage = new Azure.Iot.Inputs.TimeSeriesInsightsGen2EnvironmentStorageArgs
            {
                Name = storage.Name,
                Key = storage.PrimaryAccessKey,
            },
        });
        var exampleTimeSeriesInsightsEventSourceIothub = new Azure.Iot.TimeSeriesInsightsEventSourceIothub("exampleTimeSeriesInsightsEventSourceIothub", new Azure.Iot.TimeSeriesInsightsEventSourceIothubArgs
        {
            Location = exampleResourceGroup.Location,
            EnvironmentId = exampleTimeSeriesInsightsGen2Environment.Id,
            IothubName = exampleIoTHub.Name,
            SharedAccessKey = exampleIoTHub.SharedAccessPolicies.Apply(sharedAccessPolicies => sharedAccessPolicies[0].PrimaryKey),
            SharedAccessKeyName = exampleIoTHub.SharedAccessPolicies.Apply(sharedAccessPolicies => sharedAccessPolicies[0].KeyName),
            ConsumerGroupName = exampleConsumerGroup.Name,
            EventSourceResourceId = exampleIoTHub.Id,
        });
    }

}

package main

import (
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/iot"
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/storage"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleResourceGroup, err := core.NewResourceGroup(ctx, "exampleResourceGroup", &core.ResourceGroupArgs{
			Location: pulumi.String("West Europe"),
		})
		if err != nil {
			return err
		}
		exampleIoTHub, err := iot.NewIoTHub(ctx, "exampleIoTHub", &iot.IoTHubArgs{
			ResourceGroupName: exampleResourceGroup.Name,
			Location:          exampleResourceGroup.Location,
			Sku: &iot.IoTHubSkuArgs{
				Name:     pulumi.String("B1"),
				Capacity: pulumi.Int(1),
			},
		})
		if err != nil {
			return err
		}
		exampleConsumerGroup, err := iot.NewConsumerGroup(ctx, "exampleConsumerGroup", &iot.ConsumerGroupArgs{
			IothubName:           exampleIoTHub.Name,
			EventhubEndpointName: pulumi.String("events"),
			ResourceGroupName:    exampleResourceGroup.Name,
		})
		if err != nil {
			return err
		}
		storage, err := storage.NewAccount(ctx, "storage", &storage.AccountArgs{
			Location:               exampleResourceGroup.Location,
			ResourceGroupName:      exampleResourceGroup.Name,
			AccountTier:            pulumi.String("Standard"),
			AccountReplicationType: pulumi.String("LRS"),
		})
		if err != nil {
			return err
		}
		exampleTimeSeriesInsightsGen2Environment, err := iot.NewTimeSeriesInsightsGen2Environment(ctx, "exampleTimeSeriesInsightsGen2Environment", &iot.TimeSeriesInsightsGen2EnvironmentArgs{
			Location:          exampleResourceGroup.Location,
			ResourceGroupName: exampleResourceGroup.Name,
			SkuName:           pulumi.String("L1"),
			IdProperties: pulumi.StringArray{
				pulumi.String("id"),
			},
			Storage: &iot.TimeSeriesInsightsGen2EnvironmentStorageArgs{
				Name: storage.Name,
				Key:  storage.PrimaryAccessKey,
			},
		})
		if err != nil {
			return err
		}
		_, err = iot.NewTimeSeriesInsightsEventSourceIothub(ctx, "exampleTimeSeriesInsightsEventSourceIothub", &iot.TimeSeriesInsightsEventSourceIothubArgs{
			Location:      exampleResourceGroup.Location,
			EnvironmentId: exampleTimeSeriesInsightsGen2Environment.ID(),
			IothubName:    exampleIoTHub.Name,
			SharedAccessKey: exampleIoTHub.SharedAccessPolicies.ApplyT(func(sharedAccessPolicies []iot.IoTHubSharedAccessPolicy) (string, error) {
				return sharedAccessPolicies[0].PrimaryKey, nil
			}).(pulumi.StringOutput),
			SharedAccessKeyName: exampleIoTHub.SharedAccessPolicies.ApplyT(func(sharedAccessPolicies []iot.IoTHubSharedAccessPolicy) (string, error) {
				return sharedAccessPolicies[0].KeyName, nil
			}).(pulumi.StringOutput),
			ConsumerGroupName:     exampleConsumerGroup.Name,
			EventSourceResourceId: exampleIoTHub.ID(),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";

const exampleResourceGroup = new azure.core.ResourceGroup("exampleResourceGroup", {location: "West Europe"});
const exampleIoTHub = new azure.iot.IoTHub("exampleIoTHub", {
    resourceGroupName: exampleResourceGroup.name,
    location: exampleResourceGroup.location,
    sku: {
        name: "B1",
        capacity: "1",
    },
});
const exampleConsumerGroup = new azure.iot.ConsumerGroup("exampleConsumerGroup", {
    iothubName: exampleIoTHub.name,
    eventhubEndpointName: "events",
    resourceGroupName: exampleResourceGroup.name,
});
const storage = new azure.storage.Account("storage", {
    location: exampleResourceGroup.location,
    resourceGroupName: exampleResourceGroup.name,
    accountTier: "Standard",
    accountReplicationType: "LRS",
});
const exampleTimeSeriesInsightsGen2Environment = new azure.iot.TimeSeriesInsightsGen2Environment("exampleTimeSeriesInsightsGen2Environment", {
    location: exampleResourceGroup.location,
    resourceGroupName: exampleResourceGroup.name,
    skuName: "L1",
    idProperties: ["id"],
    storage: {
        name: storage.name,
        key: storage.primaryAccessKey,
    },
});
const exampleTimeSeriesInsightsEventSourceIothub = new azure.iot.TimeSeriesInsightsEventSourceIothub("exampleTimeSeriesInsightsEventSourceIothub", {
    location: exampleResourceGroup.location,
    environmentId: exampleTimeSeriesInsightsGen2Environment.id,
    iothubName: exampleIoTHub.name,
    sharedAccessKey: exampleIoTHub.sharedAccessPolicies.apply(sharedAccessPolicies => sharedAccessPolicies[0].primaryKey),
    sharedAccessKeyName: exampleIoTHub.sharedAccessPolicies.apply(sharedAccessPolicies => sharedAccessPolicies[0].keyName),
    consumerGroupName: exampleConsumerGroup.name,
    eventSourceResourceId: exampleIoTHub.id,
});

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.ResourceGroup("exampleResourceGroup", location="West Europe")
example_io_t_hub = azure.iot.IoTHub("exampleIoTHub",
    resource_group_name=example_resource_group.name,
    location=example_resource_group.location,
    sku=azure.iot.IoTHubSkuArgs(
        name="B1",
        capacity=1,
    ))
example_consumer_group = azure.iot.ConsumerGroup("exampleConsumerGroup",
    iothub_name=example_io_t_hub.name,
    eventhub_endpoint_name="events",
    resource_group_name=example_resource_group.name)
storage = azure.storage.Account("storage",
    location=example_resource_group.location,
    resource_group_name=example_resource_group.name,
    account_tier="Standard",
    account_replication_type="LRS")
example_time_series_insights_gen2_environment = azure.iot.TimeSeriesInsightsGen2Environment("exampleTimeSeriesInsightsGen2Environment",
    location=example_resource_group.location,
    resource_group_name=example_resource_group.name,
    sku_name="L1",
    id_properties=["id"],
    storage=azure.iot.TimeSeriesInsightsGen2EnvironmentStorageArgs(
        name=storage.name,
        key=storage.primary_access_key,
    ))
example_time_series_insights_event_source_iothub = azure.iot.TimeSeriesInsightsEventSourceIothub("exampleTimeSeriesInsightsEventSourceIothub",
    location=example_resource_group.location,
    environment_id=example_time_series_insights_gen2_environment.id,
    iothub_name=example_io_t_hub.name,
    shared_access_key=example_io_t_hub.shared_access_policies[0].primary_key,
    shared_access_key_name=example_io_t_hub.shared_access_policies[0].key_name,
    consumer_group_name=example_consumer_group.name,
    event_source_resource_id=example_io_t_hub.id)