如何通过特性绑定Azure Function的Event Hub输入输出参数

我懂你想要的是直接通过特性把Function的输入、输出参数和Event Hub绑定，而不是依赖返回语句的方式——这确实比返回值绑定更灵活，尤其在需要处理多输出或者和其他参数配合的场景下。下面给你几个实用的示例：

1. Event Hub输入绑定（参数方式） #

你可以直接把EventHubTrigger特性标注在输入参数上，支持多种数据类型，比如字符串、EventData（方便获取元数据）：

[FunctionName("EventHubInputDemo")]
public static void Run(
    // 绑定到Event Hub作为输入，触发函数执行
    [EventHubTrigger("your-input-eventhub-name", Connection = "EventHub_Connection_String")] EventData incomingEvent,
    ILogger log)
{
    // 解析消息内容
    var messageContent = Encoding.UTF8.GetString(incomingEvent.Body);
    log.LogInformation($"Received Event Hub message: {messageContent}");
    log.LogInformation($"Message partition key: {incomingEvent.PartitionKey}");
}

如果只需要消息体，也可以直接绑定到字符串：

[FunctionName("SimpleEventHubInput")]
public static void Run(
    [EventHubTrigger("your-input-eventhub-name", Connection = "EventHub_Connection_String")] string messageBody,
    ILogger log)
{
    log.LogInformation($"Received message: {messageBody}");
}

2. Event Hub输出绑定（参数方式） #

不用返回值，直接给输出参数标注EventHub特性，支持三种常见方式：

单条消息输出（out参数） #

适合只发送一条消息的场景：

[FunctionName("SingleEventHubOutput")]
public static void Run(
    [TimerTrigger("0 */5 * * * *")] TimerInfo myTimer,
    // 绑定到Event Hub作为输出
    [EventHub("your-output-eventhub-name", Connection = "EventHub_Connection_String")] out string outgoingMessage,
    ILogger log)
{
    log.LogInformation("Preparing message to send to Event Hub...");
    outgoingMessage = $"Scheduled message generated at {DateTime.UtcNow:yyyy-MM-dd HH:mm:ss}";
}

多条消息输出（ICollector） #

如果需要批量发送多条消息，用ICollector<T>会更方便：

[FunctionName("BatchEventHubOutput")]
public static void Run(
    [TimerTrigger("0 */5 * * * *")] TimerInfo myTimer,
    [EventHub("your-output-eventhub-name", Connection = "EventHub_Connection_String")] ICollector<string> outgoingMessages,
    ILogger log)
{
    log.LogInformation("Sending batch messages to Event Hub...");
    outgoingMessages.Add($"Batch message 1 - {DateTime.UtcNow}");
    outgoingMessages.Add($"Batch message 2 - {DateTime.UtcNow}");
    outgoingMessages.Add($"Batch message 3 - {DateTime.UtcNow}");
}

异步批量输出（IAsyncCollector） #

如果你的函数是异步的，用IAsyncCollector<T>配合await：

[FunctionName("AsyncBatchEventHubOutput")]
public static async Task Run(
    [TimerTrigger("0 */5 * * * *")] TimerInfo myTimer,
    [EventHub("your-output-eventhub-name", Connection = "EventHub_Connection_String")] IAsyncCollector<string> outgoingMessages,
    ILogger log)
{
    log.LogInformation("Sending async batch messages to Event Hub...");
    await outgoingMessages.AddAsync($"Async message 1 - {DateTime.UtcNow}");
    await outgoingMessages.AddAsync($"Async message 2 - {DateTime.UtcNow}");
}

这些方式都是通过特性直接绑定到参数上，和返回值绑定的效果完全一致，但能更灵活地处理复杂的业务逻辑。

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