Azure函数用于写入队列 – 我可以设置元数据吗?

我可以从这个页面看到,当它们被用作触发器时,你可以简单地访问队列消息元数据属性,但我想做相反的事情。 我有一个Azure函数,它将消息写入队列,但它当前具有默认的到期时间,我想设置一个更短的过期时间,因此它们只在队列中存在很短的时间。

有没有办法从Azure函数将消息写入队列以设置过期时间?

谢谢

编辑1:有一点需要注意的是,我提前不知道队列的名称。 这是传入消息的一部分,因此将queuename设置为输出绑定的参数,我按照@Mikhail的建议进行了更改。 这是现在的function:

#r "Microsoft.WindowsAzure.Storage" #r "Newtonsoft.Json" using System; using Microsoft.WindowsAzure.Storage.Queue; using Newtonsoft.Json; public static void Run(MyType myEventHubMessage, CloudQueue outputQueue, TraceWriter log) { var deviceId = myEventHubMessage.DeviceId; var data = JsonConvert.SerializeObject(myEventHubMessage); var msg = new CloudQueueMessage(data); log.Info($"C# Event Hub trigger function processed a message: {deviceId}"); outputQueue.AddMessage(msg, TimeSpan.FromMinutes(3), null, null, null); } public class MyType { public string DeviceId { get; set; } public double Field1{ get; set; } public double Field2 { get; set; } public double Field3 { get; set; } } 

和我的function.json中的输出绑定:

 { "type": "CloudQueue", "name": "$return", "queueName": "{DeviceId}", "connection": "myConn", "direction": "out" } 

将参数类型更改为CloudQueue ,然后手动添加消息并设置到期时间属性(或者更确切地说是生存时间)。

 public static void Run(string input, CloudQueue outputQueue) { outputQueue.AddMessage( new CloudQueueMessage("Hello " + input), TimeSpan.FromMinutes(5)); } 

编辑:如果您的输出队列名称取决于请求,您可以使用命令式绑定:

 public static void Run(string input, IBinder binder) { string outputQueueName = "outputqueue " + input; QueueAttribute queueAttribute = new QueueAttribute(outputQueueName); CloudQueue outputQueue = binder.Bind(queueAttribute); outputQueue.AddMessage( new CloudQueueMessage("Hello " + input), TimeSpan.FromMinutes(5)); }