在Azure Function中通过多返回值实现多消息推送的可行性咨询

可以实现，Azure Functions支持多个输出绑定，你可以通过两种常用方式达成需求（本质都是利用多输出绑定能力，类似多返回值的实现思路）：

方法1：使用out参数添加额外输出绑定 #

直接在函数参数中添加另一个Service Bus的输出绑定，通过out参数传递要发送的消息内容。

修改后的代码示例：

[FunctionName("IntegrationFunction")]
[return: EventHub("%Transactions:EVH:Transactions:Hub%", Connection = "Transactions:EVH:Transactions")]
public Transaction Run(
    [ServiceBusTrigger(
        "%Transactions:SB:Transactions:ReceiveTopic%",
        "%Transactions:SB:Transactions:AnalyticsTopicSubscription%",
        Connection = "Transactions:SB:Transactions")]
    string mySbMsg,
    [ServiceBus("%AnotherSB:TargetTopic%", Connection = "AnotherSB:ConnectionString")] out string sbOutputMsg,
    ILogger log)
{
    // 初始化out参数，避免未赋值报错
    sbOutputMsg = null;
    
    if (string.IsNullOrWhiteSpace(mySbMsg))
    {
        throw new ArgumentNullException(nameof(mySbMsg));
    }

    log.LogInformation($"Service bus topic trigger function processing message: {mySbMsg}");
    
    var retailTransaction = JsonConvert.DeserializeObject<RetailTransaction>(
        mySbMsg,
        JsonSerialisationUtils.SerialiserSettings);
    
    if (retailTransaction == null)
    {
        throw new JsonException("Deserialized transaction was null");
    }

    try
    {
        var transaction = retailTransaction.ToDto();
        log.LogInformation($"Transaction {transaction.TransactionNumber} processed.");
        
        // 序列化要发送到目标Service Bus的消息内容（可根据需求调整格式）
        sbOutputMsg = JsonConvert.SerializeObject(transaction, JsonSerialisationUtils.SerialiserSettings);
        
        return transaction;
    }
    catch (Exception e)
    {
        log.LogError(e, "Error mapping transaction.");
    }

    return null;
}

方法2：返回带绑定属性的自定义类（模拟多返回值） #

创建一个包含多个属性的类，给每个属性添加对应的输出绑定特性，函数返回这个类的实例来同时推送多个目标。

步骤1：定义输出类 #

public class FunctionOutputs
{
    [EventHub("%Transactions:EVH:Transactions:Hub%", Connection = "Transactions:EVH:Transactions")]
    public Transaction EventHubOutput { get; set; }

    [ServiceBus("%AnotherSB:TargetTopic%", Connection = "AnotherSB:ConnectionString")]
    public string ServiceBusOutput { get; set; }
}

步骤2：修改函数逻辑 #

[FunctionName("IntegrationFunction")]
public FunctionOutputs Run(
    [ServiceBusTrigger(
        "%Transactions:SB:Transactions:ReceiveTopic%",
        "%Transactions:SB:Transactions:AnalyticsTopicSubscription%",
        Connection = "Transactions:SB:Transactions")]
    string mySbMsg,
    ILogger log)
{
    var outputs = new FunctionOutputs();
    
    if (string.IsNullOrWhiteSpace(mySbMsg))
    {
        throw new ArgumentNullException(nameof(mySbMsg));
    }

    log.LogInformation($"Service bus topic trigger function processing message: {mySbMsg}");
    
    var retailTransaction = JsonConvert.DeserializeObject<RetailTransaction>(
        mySbMsg,
        JsonSerialisationUtils.SerialiserSettings);
    
    if (retailTransaction == null)
    {
        throw new JsonException("Deserialized transaction was null");
    }

    try
    {
        var transaction = retailTransaction.ToDto();
        log.LogInformation($"Transaction {transaction.TransactionNumber} processed.");
        
        outputs.EventHubOutput = transaction;
        outputs.ServiceBusOutput = JsonConvert.SerializeObject(transaction, JsonSerialisationUtils.SerialiserSettings);
        
        return outputs;
    }
    catch (Exception e)
    {
        log.LogError(e, "Error mapping transaction.");
    }

    return outputs;
}

注意事项 #

• 确保目标Service Bus的配置项（主题名称、连接字符串）已在local.settings.json或Azure应用配置中正确设置，比如示例中的AnotherSB:TargetTopic和AnotherSB:ConnectionString。
• 发送到目标Service Bus的消息格式可按需调整，不一定和Event Hub的输出内容一致。
• 两种方法各有优势：out参数适合少量输出的场景，自定义类更适合输出较多时保持代码整洁。

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