azure-eventgrid-dotnet

Compare original and translation side by side

🇺🇸

Original

English

🇨🇳

Translation

Chinese

Azure.Messaging.EventGrid (.NET)

Azure.Messaging.EventGrid（.NET）

Client library for publishing events to Azure Event Grid topics, domains, and namespaces.

用于向Azure Event Grid主题、域和命名空间发布事件的客户端库。

Installation

安装

bash

undefined

bash

undefined

For topics and domains (push delivery)

适用于主题和域（推送交付）

dotnet add package Azure.Messaging.EventGrid

For namespaces (pull delivery)

适用于命名空间（拉取交付）

dotnet add package Azure.Messaging.EventGrid.Namespaces

For CloudNative CloudEvents interop

用于CloudNative CloudEvents互操作

dotnet add package Microsoft.Azure.Messaging.EventGrid.CloudNativeCloudEvents


**Current Version**: 4.28.0 (stable)

dotnet add package Microsoft.Azure.Messaging.EventGrid.CloudNativeCloudEvents


**当前版本**：4.28.0（稳定版）

Environment Variables

环境变量

bash

undefined

bash

undefined

Topic/Domain endpoint

主题/域端点

EVENT_GRID_TOPIC_ENDPOINT=https://<topic-name>.<region>.eventgrid.azure.net/api/events EVENT_GRID_TOPIC_KEY=<access-key>

Namespace endpoint (for pull delivery)

命名空间端点（用于拉取交付）

EVENT_GRID_NAMESPACE_ENDPOINT=https://<namespace>.<region>.eventgrid.azure.net EVENT_GRID_TOPIC_NAME=<topic-name> EVENT_GRID_SUBSCRIPTION_NAME=<subscription-name>

undefined

EVENT_GRID_NAMESPACE_ENDPOINT=https://<namespace>.<region>.eventgrid.azure.net EVENT_GRID_TOPIC_NAME=<topic-name> EVENT_GRID_SUBSCRIPTION_NAME=<subscription-name>

undefined

Client Hierarchy

客户端层级结构

Push Delivery (Topics/Domains)
└── EventGridPublisherClient
    ├── SendEventAsync(EventGridEvent)
    ├── SendEventsAsync(IEnumerable<EventGridEvent>)
    ├── SendEventAsync(CloudEvent)
    └── SendEventsAsync(IEnumerable<CloudEvent>)

Pull Delivery (Namespaces)
├── EventGridSenderClient
│   └── SendAsync(CloudEvent)
└── EventGridReceiverClient
    ├── ReceiveAsync()
    ├── AcknowledgeAsync()
    ├── ReleaseAsync()
    └── RejectAsync()

推送交付（主题/域）
└── EventGridPublisherClient
    ├── SendEventAsync(EventGridEvent)
    ├── SendEventsAsync(IEnumerable<EventGridEvent>)
    ├── SendEventAsync(CloudEvent)
    └── SendEventsAsync(IEnumerable<CloudEvent>)

拉取交付（命名空间）
├── EventGridSenderClient
│   └── SendAsync(CloudEvent)
└── EventGridReceiverClient
    ├── ReceiveAsync()
    ├── AcknowledgeAsync()
    ├── ReleaseAsync()
    └── RejectAsync()

Authentication

身份验证

API Key Authentication

API密钥身份验证

csharp

using Azure;
using Azure.Messaging.EventGrid;

EventGridPublisherClient client = new(
    new Uri("https://mytopic.eastus-1.eventgrid.azure.net/api/events"),
    new AzureKeyCredential("<access-key>"));

csharp

using Azure;
using Azure.Messaging.EventGrid;

EventGridPublisherClient client = new(
    new Uri("https://mytopic.eastus-1.eventgrid.azure.net/api/events"),
    new AzureKeyCredential("<access-key>"));

Microsoft Entra ID (Recommended)

Microsoft Entra ID（推荐）

csharp

using Azure.Identity;
using Azure.Messaging.EventGrid;

EventGridPublisherClient client = new(
    new Uri("https://mytopic.eastus-1.eventgrid.azure.net/api/events"),
    new DefaultAzureCredential());

csharp

using Azure.Identity;
using Azure.Messaging.EventGrid;

EventGridPublisherClient client = new(
    new Uri("https://mytopic.eastus-1.eventgrid.azure.net/api/events"),
    new DefaultAzureCredential());

SAS Token Authentication

SAS令牌身份验证

csharp

string sasToken = EventGridPublisherClient.BuildSharedAccessSignature(
    new Uri(topicEndpoint),
    DateTimeOffset.UtcNow.AddHours(1),
    new AzureKeyCredential(topicKey));

var sasCredential = new AzureSasCredential(sasToken);
EventGridPublisherClient client = new(
    new Uri(topicEndpoint),
    sasCredential);

csharp

string sasToken = EventGridPublisherClient.BuildSharedAccessSignature(
    new Uri(topicEndpoint),
    DateTimeOffset.UtcNow.AddHours(1),
    new AzureKeyCredential(topicKey));

var sasCredential = new AzureSasCredential(sasToken);
EventGridPublisherClient client = new(
    new Uri(topicEndpoint),
    sasCredential);

Publishing Events

发布事件

EventGridEvent Schema

EventGridEvent架构

csharp

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

// Single event
EventGridEvent egEvent = new(
    subject: "orders/12345",
    eventType: "Order.Created",
    dataVersion: "1.0",
    data: new { OrderId = "12345", Amount = 99.99 });

await client.SendEventAsync(egEvent);

// Batch of events
List<EventGridEvent> events = new()
{
    new EventGridEvent(
        subject: "orders/12345",
        eventType: "Order.Created",
        dataVersion: "1.0",
        data: new OrderData { OrderId = "12345", Amount = 99.99 }),
    new EventGridEvent(
        subject: "orders/12346",
        eventType: "Order.Created",
        dataVersion: "1.0",
        data: new OrderData { OrderId = "12346", Amount = 149.99 })
};

await client.SendEventsAsync(events);

csharp

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

// 单个事件
EventGridEvent egEvent = new(
    subject: "orders/12345",
    eventType: "Order.Created",
    dataVersion: "1.0",
    data: new { OrderId = "12345", Amount = 99.99 });

await client.SendEventAsync(egEvent);

// 事件批次
List<EventGridEvent> events = new()
{
    new EventGridEvent(
        subject: "orders/12345",
        eventType: "Order.Created",
        dataVersion: "1.0",
        data: new OrderData { OrderId = "12345", Amount = 99.99 }),
    new EventGridEvent(
        subject: "orders/12346",
        eventType: "Order.Created",
        dataVersion: "1.0",
        data: new OrderData { OrderId = "12346", Amount = 149.99 })
};

await client.SendEventsAsync(events);

CloudEvent Schema

CloudEvent架构

csharp

CloudEvent cloudEvent = new(
    source: "/orders/system",
    type: "Order.Created",
    data: new { OrderId = "12345", Amount = 99.99 });

cloudEvent.Subject = "orders/12345";
cloudEvent.Id = Guid.NewGuid().ToString();
cloudEvent.Time = DateTimeOffset.UtcNow;

await client.SendEventAsync(cloudEvent);

// Batch of CloudEvents
List<CloudEvent> cloudEvents = new()
{
    new CloudEvent("/orders", "Order.Created", new { OrderId = "1" }),
    new CloudEvent("/orders", "Order.Updated", new { OrderId = "2" })
};

await client.SendEventsAsync(cloudEvents);

csharp

CloudEvent cloudEvent = new(
    source: "/orders/system",
    type: "Order.Created",
    data: new { OrderId = "12345", Amount = 99.99 });

cloudEvent.Subject = "orders/12345";
cloudEvent.Id = Guid.NewGuid().ToString();
cloudEvent.Time = DateTimeOffset.UtcNow;

await client.SendEventAsync(cloudEvent);

// CloudEvents批次
List<CloudEvent> cloudEvents = new()
{
    new CloudEvent("/orders", "Order.Created", new { OrderId = "1" }),
    new CloudEvent("/orders", "Order.Updated", new { OrderId = "2" })
};

await client.SendEventsAsync(cloudEvents);

Publishing to Event Grid Domain

发布到Event Grid域

csharp

// Events must specify the Topic property for domain routing
List<EventGridEvent> events = new()
{
    new EventGridEvent(
        subject: "orders/12345",
        eventType: "Order.Created",
        dataVersion: "1.0",
        data: new { OrderId = "12345" })
    {
        Topic = "orders-topic"  // Domain topic name
    },
    new EventGridEvent(
        subject: "inventory/item-1",
        eventType: "Inventory.Updated",
        dataVersion: "1.0",
        data: new { ItemId = "item-1" })
    {
        Topic = "inventory-topic"
    }
};

await client.SendEventsAsync(events);

csharp

// 事件必须指定Topic属性以进行域路由
List<EventGridEvent> events = new()
{
    new EventGridEvent(
        subject: "orders/12345",
        eventType: "Order.Created",
        dataVersion: "1.0",
        data: new { OrderId = "12345" })
    {
        Topic = "orders-topic"  // 域主题名称
    },
    new EventGridEvent(
        subject: "inventory/item-1",
        eventType: "Inventory.Updated",
        dataVersion: "1.0",
        data: new { ItemId = "item-1" })
    {
        Topic = "inventory-topic"
    }
};

await client.SendEventsAsync(events);

Custom Serialization

自定义序列化

csharp

using System.Text.Json;

var serializerOptions = new JsonSerializerOptions
{
    PropertyNamingPolicy = JsonNamingPolicy.CamelCase
};

var customSerializer = new JsonObjectSerializer(serializerOptions);

EventGridEvent egEvent = new(
    subject: "orders/12345",
    eventType: "Order.Created",
    dataVersion: "1.0",
    data: customSerializer.Serialize(new OrderData { OrderId = "12345" }));

await client.SendEventAsync(egEvent);

csharp

using System.Text.Json;

var serializerOptions = new JsonSerializerOptions
{
    PropertyNamingPolicy = JsonNamingPolicy.CamelCase
};

var customSerializer = new JsonObjectSerializer(serializerOptions);

EventGridEvent egEvent = new(
    subject: "orders/12345",
    eventType: "Order.Created",
    dataVersion: "1.0",
    data: customSerializer.Serialize(new OrderData { OrderId = "12345" }));

await client.SendEventAsync(egEvent);

Pull Delivery (Namespaces)

拉取交付（命名空间）

Send Events to Namespace Topic

向命名空间主题发送事件

csharp

using Azure;
using Azure.Messaging;
using Azure.Messaging.EventGrid.Namespaces;

var senderClient = new EventGridSenderClient(
    new Uri(namespaceEndpoint),
    topicName,
    new AzureKeyCredential(topicKey));

// Send single event
CloudEvent cloudEvent = new("employee_source", "Employee.Created", 
    new { Name = "John", Age = 30 });
await senderClient.SendAsync(cloudEvent);

// Send batch
await senderClient.SendAsync(new[]
{
    new CloudEvent("source", "type", new { Name = "Alice" }),
    new CloudEvent("source", "type", new { Name = "Bob" })
});

csharp

using Azure;
using Azure.Messaging;
using Azure.Messaging.EventGrid.Namespaces;

var senderClient = new EventGridSenderClient(
    new Uri(namespaceEndpoint),
    topicName,
    new AzureKeyCredential(topicKey));

// 发送单个事件
CloudEvent cloudEvent = new("employee_source", "Employee.Created", 
    new { Name = "John", Age = 30 });
await senderClient.SendAsync(cloudEvent);

// 发送批次
await senderClient.SendAsync(new[]
{
    new CloudEvent("source", "type", new { Name = "Alice" }),
    new CloudEvent("source", "type", new { Name = "Bob" })
});

Receive and Process Events

接收并处理事件

csharp

var receiverClient = new EventGridReceiverClient(
    new Uri(namespaceEndpoint),
    topicName,
    subscriptionName,
    new AzureKeyCredential(topicKey));

// Receive events
ReceiveResult result = await receiverClient.ReceiveAsync(maxEvents: 10);

List<string> lockTokensToAck = new();
List<string> lockTokensToRelease = new();

foreach (ReceiveDetails detail in result.Details)
{
    CloudEvent cloudEvent = detail.Event;
    string lockToken = detail.BrokerProperties.LockToken;
    
    try
    {
        // Process the event
        Console.WriteLine($"Event: {cloudEvent.Type}, Data: {cloudEvent.Data}");
        lockTokensToAck.Add(lockToken);
    }
    catch (Exception)
    {
        // Release for retry
        lockTokensToRelease.Add(lockToken);
    }
}

// Acknowledge successfully processed events
if (lockTokensToAck.Any())
{
    await receiverClient.AcknowledgeAsync(lockTokensToAck);
}

// Release events for retry
if (lockTokensToRelease.Any())
{
    await receiverClient.ReleaseAsync(lockTokensToRelease);
}

csharp

var receiverClient = new EventGridReceiverClient(
    new Uri(namespaceEndpoint),
    topicName,
    subscriptionName,
    new AzureKeyCredential(topicKey));

// 接收事件
ReceiveResult result = await receiverClient.ReceiveAsync(maxEvents: 10);

List<string> lockTokensToAck = new();
List<string> lockTokensToRelease = new();

foreach (ReceiveDetails detail in result.Details)
{
    CloudEvent cloudEvent = detail.Event;
    string lockToken = detail.BrokerProperties.LockToken;
    
    try
    {
        // 处理事件
        Console.WriteLine($"Event: {cloudEvent.Type}, Data: {cloudEvent.Data}");
        lockTokensToAck.Add(lockToken);
    }
    catch (Exception)
    {
        // 释放以重试
        lockTokensToRelease.Add(lockToken);
    }
}

// 确认已成功处理的事件
if (lockTokensToAck.Any())
{
    await receiverClient.AcknowledgeAsync(lockTokensToAck);
}

// 释放事件以重试
if (lockTokensToRelease.Any())
{
    await receiverClient.ReleaseAsync(lockTokensToRelease);
}

Reject Events (Dead Letter)

拒绝事件（死信）

csharp

// Reject events that cannot be processed
await receiverClient.RejectAsync(new[] { lockToken });

csharp

// 拒绝无法处理的事件
await receiverClient.RejectAsync(new[] { lockToken });

Consuming Events (Azure Functions)

消费事件（Azure Functions）

EventGridEvent Trigger

EventGridEvent触发器

csharp

using Azure.Messaging.EventGrid;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.EventGrid;

public static class EventGridFunction
{
    [FunctionName("ProcessEventGridEvent")]
    public static void Run(
        [EventGridTrigger] EventGridEvent eventGridEvent,
        ILogger log)
    {
        log.LogInformation($"Event Type: {eventGridEvent.EventType}");
        log.LogInformation($"Subject: {eventGridEvent.Subject}");
        log.LogInformation($"Data: {eventGridEvent.Data}");
    }
}

csharp

using Azure.Messaging.EventGrid;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.EventGrid;

public static class EventGridFunction
{
    [FunctionName("ProcessEventGridEvent")]
    public static void Run(
        [EventGridTrigger] EventGridEvent eventGridEvent,
        ILogger log)
    {
        log.LogInformation($"Event Type: {eventGridEvent.EventType}");
        log.LogInformation($"Subject: {eventGridEvent.Subject}");
        log.LogInformation($"Data: {eventGridEvent.Data}");
    }
}

CloudEvent Trigger

CloudEvent触发器

csharp

using Azure.Messaging;
using Microsoft.Azure.Functions.Worker;

public class CloudEventFunction
{
    [Function("ProcessCloudEvent")]
    public void Run(
        [EventGridTrigger] CloudEvent cloudEvent,
        FunctionContext context)
    {
        var logger = context.GetLogger("ProcessCloudEvent");
        logger.LogInformation($"Event Type: {cloudEvent.Type}");
        logger.LogInformation($"Source: {cloudEvent.Source}");
        logger.LogInformation($"Data: {cloudEvent.Data}");
    }
}

csharp

using Azure.Messaging;
using Microsoft.Azure.Functions.Worker;

public class CloudEventFunction
{
    [Function("ProcessCloudEvent")]
    public void Run(
        [EventGridTrigger] CloudEvent cloudEvent,
        FunctionContext context)
    {
        var logger = context.GetLogger("ProcessCloudEvent");
        logger.LogInformation($"Event Type: {cloudEvent.Type}");
        logger.LogInformation($"Source: {cloudEvent.Source}");
        logger.LogInformation($"Data: {cloudEvent.Data}");
    }
}

Parsing Events

解析事件

Parse EventGridEvent

解析EventGridEvent

csharp

// From JSON string
string json = "..."; // Event Grid webhook payload
EventGridEvent[] events = EventGridEvent.ParseMany(BinaryData.FromString(json));

foreach (EventGridEvent egEvent in events)
{
    if (egEvent.TryGetSystemEventData(out object systemEvent))
    {
        // Handle system event
        switch (systemEvent)
        {
            case StorageBlobCreatedEventData blobCreated:
                Console.WriteLine($"Blob created: {blobCreated.Url}");
                break;
        }
    }
    else
    {
        // Handle custom event
        var customData = egEvent.Data.ToObjectFromJson<MyCustomData>();
    }
}

csharp

// 从JSON字符串解析
string json = "..."; // Event Grid Webhook负载
EventGridEvent[] events = EventGridEvent.ParseMany(BinaryData.FromString(json));

foreach (EventGridEvent egEvent in events)
{
    if (egEvent.TryGetSystemEventData(out object systemEvent))
    {
        // 处理系统事件
        switch (systemEvent)
        {
            case StorageBlobCreatedEventData blobCreated:
                Console.WriteLine($"Blob created: {blobCreated.Url}");
                break;
        }
    }
    else
    {
        // 处理自定义事件
        var customData = egEvent.Data.ToObjectFromJson<MyCustomData>();
    }
}

Parse CloudEvent

解析CloudEvent

csharp

CloudEvent[] cloudEvents = CloudEvent.ParseMany(BinaryData.FromString(json));

foreach (CloudEvent cloudEvent in cloudEvents)
{
    var data = cloudEvent.Data.ToObjectFromJson<MyEventData>();
    Console.WriteLine($"Type: {cloudEvent.Type}, Data: {data}");
}

csharp

CloudEvent[] cloudEvents = CloudEvent.ParseMany(BinaryData.FromString(json));

foreach (CloudEvent cloudEvent in cloudEvents)
{
    var data = cloudEvent.Data.ToObjectFromJson<MyEventData>();
    Console.WriteLine($"Type: {cloudEvent.Type}, Data: {data}");
}

System Events

系统事件

csharp

// Common system event types
using Azure.Messaging.EventGrid.SystemEvents;

// Storage events
StorageBlobCreatedEventData blobCreated;
StorageBlobDeletedEventData blobDeleted;

// Resource events
ResourceWriteSuccessEventData resourceCreated;
ResourceDeleteSuccessEventData resourceDeleted;

// App Service events
WebAppUpdatedEventData webAppUpdated;

// Container Registry events
ContainerRegistryImagePushedEventData imagePushed;

// IoT Hub events
IotHubDeviceCreatedEventData deviceCreated;

csharp

// 常见系统事件类型
using Azure.Messaging.EventGrid.SystemEvents;

// 存储事件
StorageBlobCreatedEventData blobCreated;
StorageBlobDeletedEventData blobDeleted;

// 资源事件
ResourceWriteSuccessEventData resourceCreated;
ResourceDeleteSuccessEventData resourceDeleted;

// App Service事件
WebAppUpdatedEventData webAppUpdated;

// 容器注册表事件
ContainerRegistryImagePushedEventData imagePushed;

// IoT Hub事件
IotHubDeviceCreatedEventData deviceCreated;

Key Types Reference

关键类型参考

Type	Purpose
`EventGridPublisherClient`	Publish to topics/domains
`EventGridSenderClient`	Send to namespace topics
`EventGridReceiverClient`	Receive from namespace subscriptions
`EventGridEvent`	Event Grid native schema
`CloudEvent`	CloudEvents 1.0 schema
`ReceiveResult`	Pull delivery response
`ReceiveDetails`	Event with broker properties
`BrokerProperties`	Lock token, delivery count

类型	用途
`EventGridPublisherClient`	发布到主题/域
`EventGridSenderClient`	发送到命名空间主题
`EventGridReceiverClient`	从命名空间订阅接收
`EventGridEvent`	Event Grid原生架构
`CloudEvent`	CloudEvents 1.0架构
`ReceiveResult`	拉取交付响应
`ReceiveDetails`	包含代理属性的事件
`BrokerProperties`	锁定令牌、交付次数

Event Schemas Comparison

事件架构对比

Feature	EventGridEvent	CloudEvent
Standard	Azure-specific	CNCF standard
Required fields	subject, eventType, dataVersion, data	source, type
Extensibility	Limited	Extension attributes
Interoperability	Azure only	Cross-platform

特性	EventGridEvent	CloudEvent
标准	Azure专用	CNCF标准
必填字段	subject、eventType、dataVersion、data	source、type
扩展性	有限	扩展属性
互操作性	仅Azure	跨平台

Best Practices

最佳实践

Use CloudEvents — Prefer CloudEvents for new implementations (industry standard)
Batch events — Send multiple events in one call for efficiency
Use Entra ID — Prefer managed identity over access keys
Idempotent handlers — Events may be delivered more than once
Set event TTL — Configure time-to-live for namespace events
Handle partial failures — Acknowledge/release events individually
Use dead-letter — Configure dead-letter for failed events
Validate schemas — Validate event data before processing

使用CloudEvents — 新实现优先选择CloudEvents（行业标准）
事件批次处理 — 一次调用发送多个事件以提高效率
使用Entra ID — 优先使用托管标识而非访问密钥
幂等处理程序 — 事件可能会被多次交付
设置事件TTL — 为命名空间事件配置生存时间
处理部分失败 — 单独确认/释放事件
使用死信 — 为失败事件配置死信
验证架构 — 处理前验证事件数据

Error Handling

错误处理

csharp

using Azure;

try
{
    await client.SendEventAsync(cloudEvent);
}
catch (RequestFailedException ex) when (ex.Status == 401)
{
    Console.WriteLine("Authentication failed - check credentials");
}
catch (RequestFailedException ex) when (ex.Status == 403)
{
    Console.WriteLine("Authorization failed - check RBAC permissions");
}
catch (RequestFailedException ex) when (ex.Status == 413)
{
    Console.WriteLine("Payload too large - max 1MB per event, 1MB total batch");
}
catch (RequestFailedException ex)
{
    Console.WriteLine($"Event Grid error: {ex.Status} - {ex.Message}");
}

csharp

using Azure;

try
{
    await client.SendEventAsync(cloudEvent);
}
catch (RequestFailedException ex) when (ex.Status == 401)
{
    Console.WriteLine("身份验证失败 - 检查凭据");
}
catch (RequestFailedException ex) when (ex.Status == 403)
{
    Console.WriteLine("授权失败 - 检查RBAC权限");
}
catch (RequestFailedException ex) when (ex.Status == 413)
{
    Console.WriteLine("负载过大 - 单个事件最大1MB，批次总大小最大1MB");
}
catch (RequestFailedException ex)
{
    Console.WriteLine($"Event Grid错误: {ex.Status} - {ex.Message}");
}

Failover Pattern

故障转移模式

csharp

try
{
    var primaryClient = new EventGridPublisherClient(primaryUri, primaryKey);
    await primaryClient.SendEventsAsync(events);
}
catch (RequestFailedException)
{
    // Failover to secondary region
    var secondaryClient = new EventGridPublisherClient(secondaryUri, secondaryKey);
    await secondaryClient.SendEventsAsync(events);
}

csharp

try
{
    var primaryClient = new EventGridPublisherClient(primaryUri, primaryKey);
    await primaryClient.SendEventsAsync(events);
}
catch (RequestFailedException)
{
    // 故障转移到次要区域
    var secondaryClient = new EventGridPublisherClient(secondaryUri, secondaryKey);
    await secondaryClient.SendEventsAsync(events);
}

Related SDKs

SDK	Purpose	Install
`Azure.Messaging.EventGrid`	Topics/Domains (this SDK)	`dotnet add package Azure.Messaging.EventGrid`
`Azure.Messaging.EventGrid.Namespaces`	Pull delivery	`dotnet add package Azure.Messaging.EventGrid.Namespaces`
`Azure.Identity`	Authentication	`dotnet add package Azure.Identity`
`Microsoft.Azure.WebJobs.Extensions.EventGrid`	Azure Functions trigger	`dotnet add package Microsoft.Azure.WebJobs.Extensions.EventGrid`

SDK	用途	安装命令
`Azure.Messaging.EventGrid`	主题/域操作（本SDK）	`dotnet add package Azure.Messaging.EventGrid`
`Azure.Messaging.EventGrid.Namespaces`	拉取交付	`dotnet add package Azure.Messaging.EventGrid.Namespaces`
`Azure.Identity`	身份验证	`dotnet add package Azure.Identity`
`Microsoft.Azure.WebJobs.Extensions.EventGrid`	Azure Functions触发器	`dotnet add package Microsoft.Azure.WebJobs.Extensions.EventGrid`

Reference Links

参考链接

Resource	URL
NuGet Package	https://www.nuget.org/packages/Azure.Messaging.EventGrid
API Reference	https://learn.microsoft.com/dotnet/api/azure.messaging.eventgrid
Quickstart	https://learn.microsoft.com/azure/event-grid/custom-event-quickstart
Pull Delivery	https://learn.microsoft.com/azure/event-grid/pull-delivery-overview
GitHub Source	https://github.com/Azure/azure-sdk-for-net/tree/main/sdk/eventgrid/Azure.Messaging.EventGrid

资源	URL
NuGet包	https://www.nuget.org/packages/Azure.Messaging.EventGrid
API参考	https://learn.microsoft.com/dotnet/api/azure.messaging.eventgrid
快速入门	https://learn.microsoft.com/azure/event-grid/custom-event-quickstart
拉取交付	https://learn.microsoft.com/azure/event-grid/pull-delivery-overview
GitHub源码	https://github.com/Azure/azure-sdk-for-net/tree/main/sdk/eventgrid/Azure.Messaging.EventGrid

azure-eventgrid-dotnet

Original

Translation

Azure.Messaging.EventGrid (.NET)

Azure.Messaging.EventGrid（.NET）

Installation

安装

For topics and domains (push delivery)

适用于主题和域（推送交付）

For namespaces (pull delivery)

适用于命名空间（拉取交付）

For CloudNative CloudEvents interop

用于CloudNative CloudEvents互操作

Environment Variables

环境变量

Topic/Domain endpoint

主题/域端点

Namespace endpoint (for pull delivery)

命名空间端点（用于拉取交付）

Client Hierarchy

客户端层级结构

Authentication

身份验证

API Key Authentication

API密钥身份验证

Microsoft Entra ID (Recommended)

Microsoft Entra ID（推荐）

SAS Token Authentication

SAS令牌身份验证

Publishing Events

发布事件

EventGridEvent Schema

EventGridEvent架构

CloudEvent Schema

CloudEvent架构

Publishing to Event Grid Domain

发布到Event Grid域

Custom Serialization

自定义序列化

Pull Delivery (Namespaces)

拉取交付（命名空间）

Send Events to Namespace Topic

向命名空间主题发送事件

Receive and Process Events

接收并处理事件

Reject Events (Dead Letter)

拒绝事件（死信）

Consuming Events (Azure Functions)

消费事件（Azure Functions）

EventGridEvent Trigger

EventGridEvent触发器

CloudEvent Trigger

CloudEvent触发器

Parsing Events

解析事件

Parse EventGridEvent

解析EventGridEvent

Parse CloudEvent

解析CloudEvent

System Events

系统事件

Key Types Reference

关键类型参考

Event Schemas Comparison

事件架构对比

Best Practices

最佳实践

Error Handling

错误处理

Failover Pattern

故障转移模式

Related SDKs

相关SDK

Reference Links

参考链接