azure-event-grid

@fgarofalo56/azure-event-grid

2 forks

Updated 4/29/2026

Event routing with Azure Event Grid. Configure topics, subscriptions, event handlers, and dead-lettering. Use for event-driven architectures, serverless triggers, and reactive systems on Azure.

Installation

$npx agent-skills-cli install @fgarofalo56/azure-event-grid

Claude Code

Cursor

Copilot

Codex

Antigravity

Details

Repositoryfgarofalo56/Suppercharge_Microsoft_Fabric

Path.github/skills/azure-event-grid/SKILL.md

Branchmain

Scoped Name@fgarofalo56/azure-event-grid

Usage

After installing, this skill will be available to your AI coding assistant.

Verify installation:

npx agent-skills-cli list

Skill Instructions

name: azure-event-grid description: Event routing with Azure Event Grid. Configure topics, subscriptions, event handlers, and dead-lettering. Use for event-driven architectures, serverless triggers, and reactive systems on Azure.

Azure Event Grid

Expert guidance for event routing and serverless event handling.

Create Resources

# Create custom topic
az eventgrid topic create \
  --name myeventtopic \
  --resource-group myResourceGroup \
  --location eastus

# Create system topic (for Azure services)
az eventgrid system-topic create \
  --name mysystemtopic \
  --resource-group myResourceGroup \
  --source /subscriptions/{sub}/resourceGroups/{rg}/providers/Microsoft.Storage/storageAccounts/{account} \
  --topic-type Microsoft.Storage.StorageAccounts \
  --location eastus

# Create subscription
az eventgrid event-subscription create \
  --name mysubscription \
  --source-resource-id /subscriptions/{sub}/resourceGroups/{rg}/providers/Microsoft.EventGrid/topics/myeventtopic \
  --endpoint https://myfunction.azurewebsites.net/api/handler \
  --endpoint-type webhook

Event Subscriptions

Webhook Endpoint

az eventgrid event-subscription create \
  --name webhook-sub \
  --source-resource-id $TOPIC_ID \
  --endpoint https://myapi.com/events \
  --endpoint-type webhook \
  --event-delivery-schema eventgridschema

Azure Function

az eventgrid event-subscription create \
  --name function-sub \
  --source-resource-id $TOPIC_ID \
  --endpoint /subscriptions/{sub}/resourceGroups/{rg}/providers/Microsoft.Web/sites/{app}/functions/{function} \
  --endpoint-type azurefunction

Service Bus Queue

az eventgrid event-subscription create \
  --name servicebus-sub \
  --source-resource-id $TOPIC_ID \
  --endpoint /subscriptions/{sub}/resourceGroups/{rg}/providers/Microsoft.ServiceBus/namespaces/{ns}/queues/{queue} \
  --endpoint-type servicebusqueue

Storage Queue

az eventgrid event-subscription create \
  --name storage-sub \
  --source-resource-id $TOPIC_ID \
  --endpoint /subscriptions/{sub}/resourceGroups/{rg}/providers/Microsoft.Storage/storageAccounts/{account}/queueServices/default/queues/{queue} \
  --endpoint-type storagequeue

Publish Events

Python

from azure.eventgrid import EventGridPublisherClient, EventGridEvent
from azure.core.credentials import AzureKeyCredential

client = EventGridPublisherClient(
    endpoint="https://myeventtopic.eastus-1.eventgrid.azure.net/api/events",
    credential=AzureKeyCredential(key)
)

events = [
    EventGridEvent(
        event_type="MyApp.Orders.Created",
        data={"orderId": "12345", "customer": "John"},
        subject="orders/12345",
        data_version="1.0"
    )
]

client.send(events)

.NET

using Azure;
using Azure.Messaging.EventGrid;

var client = new EventGridPublisherClient(
    new Uri(topicEndpoint),
    new AzureKeyCredential(topicKey)
);

var events = new List<EventGridEvent>
{
    new EventGridEvent(
        subject: "orders/12345",
        eventType: "MyApp.Orders.Created",
        data        data: new { OrderId = "12345", Customer = "John" }
    )
};

await client.SendEventsAsync(events);

Cloud Events

from azure.eventgrid import EventGridPublisherClient
from azure.core.messaging import CloudEvent

client = EventGridPublisherClient(endpoint, credential)

events = [
    CloudEvent(
        type="MyApp.Orders.Created",
        source="/myapp/orders",
        data={"orderId": "12345"},
    )
]

client.send(events)

Event Filtering

Subject Filtering

az eventgrid event-subscription create \
  --name filtered-sub \
  --source-resource-id $TOPIC_ID \
  --endpoint https://myapi.com/events \
  --subject-begins-with "orders/" \
  --subject-ends-with ".json"

Advanced Filtering

az eventgrid event-subscription create \
  --name advanced-sub \
  --source-resource-id $TOPIC_ID \
  --endpoint https://myapi.com/events \
  --advanced-filter data.priority StringIn high critical \
  --advanced-filter data.amount NumberGreaterThan 1000

Advanced Filter Examples

{
  "filter": {
    "advancedFilters": [
      {
        "operatorType": "StringIn",
        "key": "data.category",
        "values": ["electronics", "clothing"]
      },
      {
        "operatorType": "NumberGreaterThan",
        "key": "data.price",
        "value": 100
      },
      {
        "operatorType": "IsNotNull",
        "key": "data.customerId"
      }
    ]
  }
}

Dead Lettering

az eventgrid event-subscription create \
  --name sub-with-dlq \
  --source-resource-id $TOPIC_ID \
  --endpoint https://myapi.com/events \
  --deadletter-endpoint /subscriptions/{sub}/resourceGroups/{rg}/providers/Microsoft.Storage/storageAccounts/{account}/blobServices/default/containers/deadletters \
  --max-delivery-attempts 10 \
  --event-ttl 1440

Azure Function Handler

import azure.functions as func
import json

def main(event: func.EventGridEvent):
    event_data = event.get_json()

    print(f"Event ID: {event.id}")
    print(f"Event Type: {event.event_type}")
    print(f"Subject: {event.subject}")
    print(f"Data: {json.dumps(event_data)}")

    # Process event
    if event.event_type == "MyApp.Orders.Created":
        process_order(event_data)

System Topics (Built-in Events)

# Storage events
az eventgrid system-topic event-subscription create \
  --name blob-created \
  --system-topic-name storage-topic \
  --resource-group myResourceGroup \
  --endpoint https://myfunction.azurewebsites.net/api/blobhandler \
  --included-event-types Microsoft.Storage.BlobCreated

# Resource events
az eventgrid event-subscription create \
  --name resource-changes \
  --source-resource-id /subscriptions/{sub} \
  --endpoint https://myapi.com/events \
  --included-event-types Microsoft.Resources.ResourceWriteSuccess

Bicep Deployment

resource eventGridTopic 'Microsoft.EventGrid/topics@2023-12-15-preview' = {
  name: topicName
  location: location
  properties: {
    inputSchema: 'EventGridSchema'
    publicNetworkAccess: 'Enabled'
  }
}

resource subscription 'Microsoft.EventGrid/eventSubscriptions@2023-12-15-preview' = {
  name: 'webhook-subscription'
  scope: eventGridTopic
  properties: {
    destination: {
      endpointType: 'WebHook'
      properties: {
        endpointUrl: webhookUrl
      }
    }
    filter: {
      includedEventTypes: [
        'MyApp.Orders.Created'
        'MyApp.Orders.Updated'
      ]
    }
    retryPolicy: {
      maxDeliveryAttempts: 10
      eventTimeToLiveInMinutes: 1440
    }
  }
}

Resources

More by fgarofalo56

View all

grafana-dashboards

Build monitoring dashboards with Grafana. Covers panel types, queries, variables, alerting, provisioning, and data sources like Prometheus and InfluxDB. Use for infrastructure monitoring, observability, and metrics visualization.

accessibility-wcag

Build accessible web applications meeting WCAG 2.1 AA standards. Covers ARIA attributes, keyboard navigation, screen reader optimization, focus management, color contrast, semantic HTML, and accessible components. Use for a11y audits, accessible UI development, and inclusive design.

markitdown

Expert guidance for converting files to Markdown using Microsoft's MarkItDown utility. Convert PDF, Word, PowerPoint, Excel, images, audio, HTML, CSV, JSON, XML, ZIP, and EPub files to LLM-friendly Markdown format. Use when processing documents for AI analysis, extracting content from files, or preparing data for language models.

instructor

Structured outputs with Instructor. Extract typed data from LLMs using Pydantic models and validation. Use for data extraction, structured generation, and type-safe LLM responses.