Azure函数根据消息数据将消息路由到队列名称

Question

我希望编写一个Azure函数，该函数接收来自IoTHub的消息，并根据消息中的数据将其放置在服务总线队列中。问题是，队列名称将根据我所查看的消息和留档的参数进行更改，例如，将队列名称设置为输出设置的一部分。有人做过类似的事情吗？或者有任何代码示例可以根据传入消息中的值写入队列？我试图设置一个函数，但它甚至不让我设置输出类型为服务总线，而不把队列名称，我不能，因为它是不固定的！

所以如果输入是：

{
    “queue”: “MyQ12345”,
    “data”: “some data here”
}

函数应将数据字段（或整个传入消息）写入服务总线队列“MyQ12345”，该队列已存在于同一订阅/资源组等中。谢谢

编辑1：以下是我到目前为止得到的：

所以我尝试了@Mikhail的建议，下面是我正在做的：

跑csx

using System;

public static string Run(MyPoco myEventHubMessage, TraceWriter log, out string queue)
{
    var queueName = myEventHubMessage.QueueName;
    queue = queueName;
    log.Info($"<IoT Hub => ServiceBus> C# Event Hub trigger function processed a message: {queueName}");
    return QueueName;
}

public class MyPoco
{
  public string QueueName { get; set; }
  public double Other { get; set; }
  public double Props { get; set; }
  public int Here { get; set; }
}

作用json:

{
      "type": "serviceBus",
      "name": "$return",
      "direction": "out",
      "queueName": "{queue}",
      "connection": "ServiceBusConnectionString",
      "accessRights": "manage"
}

但这给了我以下错误：

微软蔚蓝色的WebJobs。主机：无法将参数“队列”绑定到类型字符串

Answer 1

另一种方法是使用Azure IoT Hub的自定义endpoint和消息路由，直接将消息从IoT Hub发送到您选择的SB队列，而无需通过函数。

目前，IoT集线器路由仅适用于消息属性，还不适用于消息正文（在记录计划中），但您可以将队列名称放入消息属性中，然后简单地定义一个查询，根据此属性将消息路由到正确的队列。存在一些限制，例如您可以为IoT Hub设置自定义endpoint的数量，以及预定义队列应该是什么，但这取决于您的场景。

Answer 2

您可以定义一个类以使邮件具有强类型：

public class MyItem
{
    public string Queue { get; set; }
    public string Data { get; set; }
}

然后接受它作为函数输入参数：

public string Run(MyItem item)
{
    return item.Data;
}

并按如下方式定义输出绑定：

{
    "type": "serviceBus",
    "name": "$return",
    "queueName": "{queue}",
    "connection": "...",
    "accessRights_": "Manage",
    "direction": "out"
}