Microsoft.Azure.Management.EventHub.Models.Destination不支持Data Lake Storage咨询

你遇到的这个问题其实是由于旧版Event Hubs管理SDK的模型类未同步更新新功能导致的。

原因分析 #

Microsoft.Azure.Management.EventHub属于Azure SDK的旧世代（基于Microsoft.Rest.ClientRuntime），它对应的Event Hubs ARM API版本比较早，而Data Lake Storage作为Event Hub捕获的目标选项是后续Azure平台新增的功能，旧版SDK的Destination类并没有跟进添加对应的属性来支持这个功能，所以你在代码里看不到相关配置项。

解决方案：使用新一代Azure SDK #

现在微软推荐使用基于Azure.Core的新一代Azure SDK来管理Event Hubs，也就是Azure.Messaging.EventHubs.Management包。这个SDK的模型类已经完整支持Data Lake Storage Gen2作为捕获目标的配置。

举个简单的配置示例：

using Azure.Messaging.EventHubs.Management;
using Azure.Identity;

// 创建管理客户端
var client = new EventHubManagementClient(new Uri("https://<your-namespace>.servicebus.windows.net"), new DefaultAzureCredential());

// 配置捕获目标为Data Lake Storage Gen2
var captureDescription = new EventHubCaptureDescription
{
    Enabled = true,
    Destination = new CaptureDestination
    {
        // 针对Data Lake Storage Gen2，设置以下属性
        DataLakeAccountName = "<your-datalake-account-name>",
        DataLakeFileSystemName = "<your-file-system-name>",
        ArchiveNameFormat = "{Namespace}/{EventHub}/{PartitionId}/{Year}/{Month}/{Day}/{Hour}/{Minute}/{Second}",
        // 如果需要指定资源ID也可以设置
        StorageAccountResourceId = "/subscriptions/<subscription-id>/resourceGroups/<rg-name>/providers/Microsoft.Storage/storageAccounts/<account-name>"
    },
    Encoding = CaptureEncoding.Utf8,
    IntervalInSeconds = 300,
    SizeLimitInBytes = 10485760
};

// 更新Event Hub的捕获配置
await client.CreateOrUpdateEventHubAsync("<resource-group-name>", "<namespace-name>", "<eventhub-name>", new EventHubProperties
{
    CaptureDescription = captureDescription
});

如果你因为某些原因必须继续使用旧版Microsoft.Azure.Management.EventHub，可以尝试升级到该包的最新版本（不过需要注意，旧版SDK已经进入维护模式，不再添加新功能），或者直接通过ARM API的REST请求来配置，手动构造包含Data Lake相关参数的JSON请求体。

额外提示 #

新一代Azure SDK不仅支持Data Lake Storage捕获，还提供了更简洁的API设计、更好的性能和更完善的错误处理，建议优先迁移到新SDK来获得完整的功能支持。

内容的提问来源于stack exchange，提问作者Balasubramaniam