Azure function to route message to queue namebased on message data

Question

Im looking to write an Azure function that takes in a message from IoTHub and places it on a Service bus queue based on data in the message. The thing is, the queue name will changed based on the parameters of the message and the documentation I’ve looked at, such as this all set the queue name as part of the output settings. Has anyone done anything similar or have any code samples to write to a queue based upon a value in the incoming message? I'm trying to set a function up but it wont even let me set the output type to service bus and not put the queue name in, which I can't, as it isn't fixed!

So if the input was:

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

The function should write the data field (or the entire incoming message) to the service bus queue “MyQ12345” which already exists on the same subscription/resource group etc. Thanks

EDIT1: Here's what I've got thus far:

So I've tried what @Mikhail has suggested, here is what I'm doing:

run.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; }
}

function.json:

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

but this gives me the following error:

Microsoft.Azure.WebJobs.Host: Cannot bind parameter 'queue' to type String&. Make sure the parameter Type is supported by the binding.

Mikhail Shilkov Mikhail Shilkov · Accepted Answer · 2017-05-03T11:57:57

You can define a class to make your message strongly typed:

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

then accept it as function input parameter:

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

and define the output binding like this:

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

Azure function to route message to queue namebased on message data

2 Answers