EventSubscription

class EventSubscription : KotlinCustomResource

Manages an EventGrid Event Subscription

Example Usage

import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";
const example = new azure.core.ResourceGroup("example", {
name: "example-resources",
location: "West Europe",
});
const exampleAccount = new azure.storage.Account("example", {
name: "exampleasa",
resourceGroupName: example.name,
location: example.location,
accountTier: "Standard",
accountReplicationType: "LRS",
tags: {
environment: "staging",
},
});
const exampleQueue = new azure.storage.Queue("example", {
name: "example-astq",
storageAccountName: exampleAccount.name,
});
const exampleEventSubscription = new azure.eventgrid.EventSubscription("example", {
name: "example-aees",
scope: example.id,
storageQueueEndpoint: {
storageAccountId: exampleAccount.id,
queueName: exampleQueue.name,
},
});
import pulumi
import pulumi_azure as azure
example = azure.core.ResourceGroup("example",
name="example-resources",
location="West Europe")
example_account = azure.storage.Account("example",
name="exampleasa",
resource_group_name=example.name,
location=example.location,
account_tier="Standard",
account_replication_type="LRS",
tags={
"environment": "staging",
})
example_queue = azure.storage.Queue("example",
name="example-astq",
storage_account_name=example_account.name)
example_event_subscription = azure.eventgrid.EventSubscription("example",
name="example-aees",
scope=example.id,
storage_queue_endpoint={
"storage_account_id": example_account.id,
"queue_name": example_queue.name,
})
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Azure = Pulumi.Azure;
return await Deployment.RunAsync(() =>
{
var example = new Azure.Core.ResourceGroup("example", new()
{
Name = "example-resources",
Location = "West Europe",
});
var exampleAccount = new Azure.Storage.Account("example", new()
{
Name = "exampleasa",
ResourceGroupName = example.Name,
Location = example.Location,
AccountTier = "Standard",
AccountReplicationType = "LRS",
Tags =
{
{ "environment", "staging" },
},
});
var exampleQueue = new Azure.Storage.Queue("example", new()
{
Name = "example-astq",
StorageAccountName = exampleAccount.Name,
});
var exampleEventSubscription = new Azure.EventGrid.EventSubscription("example", new()
{
Name = "example-aees",
Scope = example.Id,
StorageQueueEndpoint = new Azure.EventGrid.Inputs.EventSubscriptionStorageQueueEndpointArgs
{
StorageAccountId = exampleAccount.Id,
QueueName = exampleQueue.Name,
},
});
});
package main
import (
"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/eventgrid"
"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/storage"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
example, err := core.NewResourceGroup(ctx, "example", &core.ResourceGroupArgs{
Name: pulumi.String("example-resources"),
Location: pulumi.String("West Europe"),
})
if err != nil {
return err
}
exampleAccount, err := storage.NewAccount(ctx, "example", &storage.AccountArgs{
Name: pulumi.String("exampleasa"),
ResourceGroupName: example.Name,
Location: example.Location,
AccountTier: pulumi.String("Standard"),
AccountReplicationType: pulumi.String("LRS"),
Tags: pulumi.StringMap{
"environment": pulumi.String("staging"),
},
})
if err != nil {
return err
}
exampleQueue, err := storage.NewQueue(ctx, "example", &storage.QueueArgs{
Name: pulumi.String("example-astq"),
StorageAccountName: exampleAccount.Name,
})
if err != nil {
return err
}
_, err = eventgrid.NewEventSubscription(ctx, "example", &eventgrid.EventSubscriptionArgs{
Name: pulumi.String("example-aees"),
Scope: example.ID(),
StorageQueueEndpoint: &eventgrid.EventSubscriptionStorageQueueEndpointArgs{
StorageAccountId: exampleAccount.ID(),
QueueName: exampleQueue.Name,
},
})
if err != nil {
return err
}
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azure.core.ResourceGroup;
import com.pulumi.azure.core.ResourceGroupArgs;
import com.pulumi.azure.storage.Account;
import com.pulumi.azure.storage.AccountArgs;
import com.pulumi.azure.storage.Queue;
import com.pulumi.azure.storage.QueueArgs;
import com.pulumi.azure.eventgrid.EventSubscription;
import com.pulumi.azure.eventgrid.EventSubscriptionArgs;
import com.pulumi.azure.eventgrid.inputs.EventSubscriptionStorageQueueEndpointArgs;
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 example = new ResourceGroup("example", ResourceGroupArgs.builder()
.name("example-resources")
.location("West Europe")
.build());
var exampleAccount = new Account("exampleAccount", AccountArgs.builder()
.name("exampleasa")
.resourceGroupName(example.name())
.location(example.location())
.accountTier("Standard")
.accountReplicationType("LRS")
.tags(Map.of("environment", "staging"))
.build());
var exampleQueue = new Queue("exampleQueue", QueueArgs.builder()
.name("example-astq")
.storageAccountName(exampleAccount.name())
.build());
var exampleEventSubscription = new EventSubscription("exampleEventSubscription", EventSubscriptionArgs.builder()
.name("example-aees")
.scope(example.id())
.storageQueueEndpoint(EventSubscriptionStorageQueueEndpointArgs.builder()
.storageAccountId(exampleAccount.id())
.queueName(exampleQueue.name())
.build())
.build());
}
}
resources:
example:
type: azure:core:ResourceGroup
properties:
name: example-resources
location: West Europe
exampleAccount:
type: azure:storage:Account
name: example
properties:
name: exampleasa
resourceGroupName: ${example.name}
location: ${example.location}
accountTier: Standard
accountReplicationType: LRS
tags:
environment: staging
exampleQueue:
type: azure:storage:Queue
name: example
properties:
name: example-astq
storageAccountName: ${exampleAccount.name}
exampleEventSubscription:
type: azure:eventgrid:EventSubscription
name: example
properties:
name: example-aees
scope: ${example.id}
storageQueueEndpoint:
storageAccountId: ${exampleAccount.id}
queueName: ${exampleQueue.name}

Import

EventGrid Event Subscription's can be imported using the resource id, e.g.

$ pulumi import azure:eventgrid/eventSubscription:EventSubscription eventSubscription1 /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.EventGrid/topics/topic1/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscription1

Properties

Link copied to clipboard

A advanced_filter block as defined below.

Link copied to clipboard

Specifies whether advanced filters should be evaluated against an array of values instead of expecting a singular value. Defaults to false.

Link copied to clipboard

An azure_function_endpoint block as defined below.

Link copied to clipboard

A dead_letter_identity block as defined below.

Link copied to clipboard

A delivery_identity block as defined below.

Link copied to clipboard

One or more delivery_property blocks as defined below.

Link copied to clipboard

Specifies the event delivery schema for the event subscription. Possible values include: EventGridSchema, CloudEventSchemaV1_0, CustomInputSchema. Defaults to EventGridSchema. Changing this forces a new resource to be created.

Link copied to clipboard

Specifies the id where the Event Hub is located.

Link copied to clipboard

Specifies the expiration time of the event subscription (Datetime Format RFC 3339).

Link copied to clipboard

Specifies the id where the Hybrid Connection is located.

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

A list of applicable event types that need to be part of the event subscription.

Link copied to clipboard
val labels: Output<List<String>>?

A list of labels to assign to the event subscription.

Link copied to clipboard
val name: Output<String>

Specifies the name of the EventGrid Event Subscription resource. Changing this forces a new resource to be created.

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

A retry_policy block as defined below.

Link copied to clipboard
val scope: Output<String>

Specifies the scope at which the EventGrid Event Subscription should be created. Changing this forces a new resource to be created.

Link copied to clipboard

Specifies the id where the Service Bus Queue is located.

Link copied to clipboard

Specifies the id where the Service Bus Topic is located.

Link copied to clipboard

A storage_blob_dead_letter_destination block as defined below.

Link copied to clipboard

A storage_queue_endpoint block as defined below.

Link copied to clipboard

A subject_filter block as defined below.

Link copied to clipboard
val urn: Output<String>
Link copied to clipboard

A webhook_endpoint block as defined below.