C# Azure Function如何为EventHub特性动态传入配置参数值

C# 语言层面限制特性（Attribute）的参数必须是编译期常量，你没法直接把依赖注入得到的_settings实例的动态属性值传给[EventHub]特性当参数，要实现动态配置EventHub的名称和连接串，有两种成熟的实现方案：

方案1：使用绑定表达式（推荐，保留输出绑定写法） #

Azure Functions 内置了配置绑定语法，你只需要在特性参数里用%配置键名%包裹对应的配置项键名，运行时会自动从配置系统（和你读IOptions<ConfigSettings>用的是完全相同的配置源，包括本地local.settings.json、线上应用配置、环境变量等）读取对应的值，不需要硬编码：

1. 确保你的配置项已经正确写入配置源，比如本地开发时的local.settings.json结构如下：

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "存储账户连接串",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet",
    "EventHub:Name": "你的事件中心实际名称",
    "EventHub:Connection": "你的事件中心实际连接字符串"
  }
}

2. 修改[EventHub]特性的参数，用绑定语法替换硬编码值：

[FunctionName("test")]
public HttpResponseMessage Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
    [EventHub("%EventHub:Name%", Connection = "EventHub:Connection")] out string outputEventHubMessage, 
    ILogger log, ExecutionContext ctx) 
{
    // 业务逻辑中给outputEventHubMessage赋值，就会自动发送到配置指定的EventHub
    outputEventHubMessage = "待发送的消息内容";
    var validationError = "请求参数校验失败";
    return new HttpResponseMessage
    {
        StatusCode = System.Net.HttpStatusCode.BadRequest,
        Content = new StringContent(validationError)
    };
}

你原来注入的IOptions<ConfigSettings>逻辑完全不需要改动，_settings读取的和绑定表达式读取的是同一份配置，不会出现配置不一致的问题。

方案2：移除输出绑定，直接用SDK手动发送消息（灵活度最高） #

如果需要完全通过依赖注入的_settings控制连接参数，可以放弃声明式输出绑定，直接在代码里用Azure EventHub官方SDK手动发送消息：

1. 引入EventHub对应的SDK包
2. 在函数类中直接用注入的配置初始化EventHub生产者客户端（生产环境建议单例注册客户端，避免重复创建连接带来的性能问题）
3. 在业务逻辑需要发消息的位置，调用客户端的发送方法即可
   示例代码：

using Azure.Messaging.EventHubs;
using Azure.Messaging.EventHubs.Producer;
using System.Text;

public class AzureTestFunc 
{
    private readonly ConfigSettings _settings;
    private readonly EventHubProducerClient _producerClient;

    public AzureTestFunc(IOptions<ConfigSettings> options)
    {
        _settings = options.Value;
        // 初始化客户端，生产环境建议放到DI容器做单例注入，不要每次构造函数new
        _producerClient = new EventHubProducerClient(_settings.Connection, _settings.EventHubName);
    }

    [FunctionName("test")]
    public async Task<HttpResponseMessage> Run(
        [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
        ILogger log, ExecutionContext ctx) 
    {
        // 业务逻辑中需要发消息时，直接调用客户端发送
        using var eventBatch = await _producerClient.CreateBatchAsync();
        eventBatch.TryAdd(new EventData(Encoding.UTF8.GetBytes("待发送的消息内容")));
        await _producerClient.SendAsync(eventBatch);

        var validationError = "请求参数校验失败";
        return new HttpResponseMessage
        {
            StatusCode = System.Net.HttpStatusCode.BadRequest,
            Content = new StringContent(validationError)
        };
    }
}

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