使用输出绑定向Azure Event Hub发消息并指定分区键

可以实现用transaction.StoreCode作为分区键发送消息到特定分区，具体有两种思路，其中第二种支持动态设置运行时的分区键：

1. 静态分区键（不适用你的场景） #

EventHubAttribute提供了PartitionKey参数，但它只能绑定静态配置值（比如从appsettings读取的固定字符串），没法直接传入运行时生成的transaction.StoreCode，所以这种方式不满足你的需求。

2. 动态设置分区键（推荐方案） #

改用IAsyncCollector<EventData>作为输出绑定类型，而非直接返回Transaction对象，这样就能手动创建EventData实例并指定分区键。修改后的代码如下：

[FunctionName("IntegrationFunction")]
public async Task Run(
    [ServiceBusTrigger(
        "%Transactions:SB:Transactions:ReceiveTopic%",
        "%Transactions:SB:Transactions:AnalyticsTopicSubscription%",
        Connection = "Transactions:SB:Transactions")]
    string mySbMsg,
    [EventHub("%Transactions:EVH:Transactions:Hub%", Connection = "Transactions:EVH:Transactions")] IAsyncCollector<EventData> eventHubOutput,
    ILogger log)
{
    var retailTransaction = JsonConvert.DeserializeObject<RetailTransaction>(
        mySbMsg,
        JsonSerialisationUtils.SerialiserSettings);
    
    try
    {
        var transaction = retailTransaction.ToDto();
        log.LogInformation($"Transaction {transaction.TransactionNumber} processed.");
        
        // 序列化Transaction对象并设置分区键
        var messageBytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(transaction, JsonSerialisationUtils.SerialiserSettings));
        var eventData = new EventData(messageBytes)
        {
            PartitionKey = transaction.StoreCode
        };
        
        await eventHubOutput.AddAsync(eventData);
    }
    catch (Exception e)
    {
        log.LogError(e, "Error mapping transaction.");
    }
}

关键说明： #

• 替换原返回值绑定为IAsyncCollector<EventData>，允许你批量或单个发送自定义配置的Event Hub消息
• 通过EventData的PartitionKey属性，可动态设置transaction.StoreCode作为分区键，Event Hub会根据该键哈希路由到对应分区
• 需要将Transaction对象序列化为字节数组，作为EventData的消息内容，保持和原逻辑一致的序列化规则

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