使用 Azure 函数服务总线触发器读取 SB 消息

Question

我刚刚使用服务总线触发器创建了一个简单的 azure 函数。我正在使用提供的默认示例。我可以在下面的代码中读取 messageid

public static void Run(string mySbMsg, TraceWriter log)
{
log.Info($"C# ServiceBus topic trigger function processed message: 
{mySbMsg}");
}

我正在努力寻找显示如何阅读已发布的 json 消息的代码。谢谢你的帮助

Answer 1

您可以使用BrokeredMessage参数获取Azure Function Service Bus Trigger中的消息正文。

这将 return 使用 BrokeredMessage.GetBody() 方法的消息。

获取更多信息here。

在 Azure 门户中，在“查看文件”中添加 "project.json"。这是包含 BrokeredMessage 对象的库。

project.json 应该看起来像

{
  "frameworks": 
    {  
      "net46":
      { 
        "dependencies":
        {
          "WindowsAzure.ServiceBus": "4.1.2"
        }
      }
    }
}

保存时，您可以看到包已恢复。

在运行方法中，添加 BrokeredMessage 作为参数。该方法应该看起来像

public static void Run(BrokeredMessage message, TraceWriter log)
{
string messageBody = message.Properties["Message"].ToString();
string messageId = message.Properties["Id"].ToString();
log.Info($"message - " + messageBody + " Id " + messageId);
}

不要忘记在"Run.csx"中添加Using Microsoft.ServiceBus.Messaging并将name属性更改为"Function.json"

中的消息

使用 Azure 函数服务总线触发器读取 SB 消息

read SB message with azure functions service bus trigger

azure

azureservicebus

azure-functions