Azure Function QueueTrigger - 将新项目放回队列

Question

我有一个基于 QueueTrigger 的 Azure 函数。这会在队列中出现某些内容时触发，但在处理完此项目后，我想将新项目放回队列中。

有没有办法直接从 Azure 函数中执行此操作？

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

    // 1. process model
    // 2. Put items back on queue?
}

Answer 1

您可以使用如下输出绑定：

[StorageAccount("MyStorageConnectionAppSetting")]
public static class QueueFunctions
{
    [FunctionName("QueueOutput")]
    [return: Queue("myqueue-items")]
    public static string QueueOutput([HttpTrigger] dynamic input,  ILogger log)
    {
        log.LogInformation($"C# function processed: {input.Text}");
        return input.Text;
    }
}