使用QueueTrigger的Azure Function运行时如何直接向队列回发新消息

完全可以在当前QueueTrigger触发的Azure Function内部直接实现消息回发操作，以下是两种常用实现方案：

方案1：使用QueueOutput输出绑定（推荐） #

这种方式是Azure Functions原生支持的绑定模式，不需要手动管理队列客户端，运行时会自动处理连接、序列化等逻辑，适配你当前使用的隔离进程（Isolated Worker）模型的代码如下：

[Function("Batch")]
// 这里用QueueOutput特性绑定目标队列，和触发器用同一个队列即可
public async Task<QueueOutputResponse> Run([QueueTrigger("batch", Connection = "DataQueue")] string data,
    FunctionContext context)
{
    var model = JsonConvert.DeserializeObject<MyObject>(data);

    // 1. 处理当前model的业务逻辑
    // ...

    // 2. 构造要回发的新消息
    var newItem = new MyObject
    {
        // 填充新消息的属性
    };

    // 返回值绑定输出队列消息
    return new QueueOutputResponse
    {
        // 要回发的消息，运行时会自动序列化为字符串
        NewQueueItem = JsonConvert.SerializeObject(newItem)
    };
}

// 自定义输出类，用于绑定多个输出（如果只有一个输出也可以直接返回字符串）
public class QueueOutputResponse
{
    [QueueOutput("batch", Connection = "DataQueue")]
    public string NewQueueItem { get; set; }
}

如果要一次性发多条消息，把NewQueueItem的类型改成List<string>即可，运行时会自动把所有元素都发到队列。

方案2：手动使用QueueClient实现（灵活控制场景） #

如果需要自定义消息的可见时间、过期时间、重试策略等高级属性，可以手动引入Azure.Storage.QueuesNuGet包，自己实例化客户端发消息：

using Azure.Storage.Queues;

[Function("Batch")]
public async Task Run([QueueTrigger("batch", Connection = "DataQueue")] string data,
    FunctionContext context)
{
    var model = JsonConvert.DeserializeObject<MyObject>(data);

    // 1. 处理当前model的业务逻辑
    // ...

    // 2. 初始化QueueClient，连接字符串从配置中读取
    var connectionString = Environment.GetEnvironmentVariable("DataQueue");
    var queueClient = new QueueClient(connectionString, "batch");
    await queueClient.CreateIfNotExistsAsync();

    // 构造要发送的消息
    var newItem = new MyObject
    {
        // 填充属性
    };
    var messageContent = JsonConvert.SerializeObject(newItem);

    // 发送消息，可自定义参数，比如TimeSpan.FromMinutes(5)是延迟5分钟可见
    await queueClient.SendMessageAsync(messageContent, visibilityTimeout: TimeSpan.FromMinutes(5));
}

注意事项 #

• 一定要做好逻辑判断避免无限循环：如果处理逻辑异常导致重复生成相同消息反复入队，会造成函数无限触发消耗资源，可以给消息加处理次数标记，超过阈值后转到死信队列。
• 注意队列消息大小限制：普通队列单条消息最大为64KB，启用Base64编码后实际承载的内容会更小，如果需要传更大的消息可以考虑搭配Blob存储存内容，队列只存Blob引用。
• 做好异常处理：发送消息失败时要捕获异常，避免当前函数执行失败导致原消息被反复重试。

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