EventSubscriptionArgs

data class EventSubscriptionArgs constructor(val advancedFilter: Output<EventSubscriptionAdvancedFilterArgs>? = null, val advancedFilteringOnArraysEnabled: Output<Boolean>? = null, val azureFunctionEndpoint: Output<EventSubscriptionAzureFunctionEndpointArgs>? = null, val deadLetterIdentity: Output<EventSubscriptionDeadLetterIdentityArgs>? = null, val deliveryIdentity: Output<EventSubscriptionDeliveryIdentityArgs>? = null, val deliveryProperties: Output<List<EventSubscriptionDeliveryPropertyArgs>>? = null, val eventDeliverySchema: Output<String>? = null, val eventhubEndpointId: Output<String>? = null, val expirationTimeUtc: Output<String>? = null, val hybridConnectionEndpointId: Output<String>? = null, val includedEventTypes: Output<List<String>>? = null, val labels: Output<List<String>>? = null, val name: Output<String>? = null, val retryPolicy: Output<EventSubscriptionRetryPolicyArgs>? = null, val scope: Output<String>? = null, val serviceBusQueueEndpointId: Output<String>? = null, val serviceBusTopicEndpointId: Output<String>? = null, val storageBlobDeadLetterDestination: Output<EventSubscriptionStorageBlobDeadLetterDestinationArgs>? = null, val storageQueueEndpoint: Output<EventSubscriptionStorageQueueEndpointArgs>? = null, val subjectFilter: Output<EventSubscriptionSubjectFilterArgs>? = null, val webhookEndpoint: Output<EventSubscriptionWebhookEndpointArgs>? = null) : ConvertibleToJava<EventSubscriptionArgs>

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:eventhub/eventSubscription:EventSubscription eventSubscription1 /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.EventGrid/topics/topic1/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscription1

Constructors

Link copied to clipboard
constructor(advancedFilter: Output<EventSubscriptionAdvancedFilterArgs>? = null, advancedFilteringOnArraysEnabled: Output<Boolean>? = null, azureFunctionEndpoint: Output<EventSubscriptionAzureFunctionEndpointArgs>? = null, deadLetterIdentity: Output<EventSubscriptionDeadLetterIdentityArgs>? = null, deliveryIdentity: Output<EventSubscriptionDeliveryIdentityArgs>? = null, deliveryProperties: Output<List<EventSubscriptionDeliveryPropertyArgs>>? = null, eventDeliverySchema: Output<String>? = null, eventhubEndpointId: Output<String>? = null, expirationTimeUtc: Output<String>? = null, hybridConnectionEndpointId: Output<String>? = null, includedEventTypes: Output<List<String>>? = null, labels: Output<List<String>>? = null, name: Output<String>? = null, retryPolicy: Output<EventSubscriptionRetryPolicyArgs>? = null, scope: Output<String>? = null, serviceBusQueueEndpointId: Output<String>? = null, serviceBusTopicEndpointId: Output<String>? = null, storageBlobDeadLetterDestination: Output<EventSubscriptionStorageBlobDeadLetterDestinationArgs>? = null, storageQueueEndpoint: Output<EventSubscriptionStorageQueueEndpointArgs>? = null, subjectFilter: Output<EventSubscriptionSubjectFilterArgs>? = null, webhookEndpoint: Output<EventSubscriptionWebhookEndpointArgs>? = null)

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

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

Specifies the id where the Event Hub is located.

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

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

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

Specifies the id where the Hybrid Connection is located.

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

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

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

A list of labels to assign to the event subscription.

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

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

Link copied to clipboard

A retry_policy block as defined below.

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

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

Specifies the id where the Service Bus Queue is located.

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

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

A webhook_endpoint block as defined below.

Functions

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