微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

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

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

谢谢

编辑1:
一个警告是我提前不知道队列的名称.这是传入消息的一部分,因此将queuename设置为输出绑定的参数
我按照@Mikhail的建议做了改动.这是现有的功能

#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<CloudQueue>(queueAttribute);
    outputQueue.AddMessage(
        new CloudQueueMessage("Hello " + input),
        TimeSpan.FromMinutes(5));
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐