从逻辑应用程序中的服务总线获取内容

Question

我是Azure逻辑应用程序的新手.我有一个服务总线并将json对象消息传递给该服务总线,然后我在逻辑应用程序中设置一个动作来收听我的服务总线.因此,每当有新消息进入该服务总线时,我的逻辑应用程序就会接收它 并将其发送到http.

我的问题是如何从服务总线中的消息中获取属性并将其传递给我的http操作.我试过这个

“Id” : “@{json(triggerBody()[‘ContentData’]).id}”

但它不起作用

Answer 1

谁和如何在队列中发送消息？

我以这种方式读取了一个json消息属性(DestinationPath):

@{json(base64ToString(triggerBody()?['ContentData'])).DestinationPath}

这是我的Logic App的样子

在我的情况下,消息作为BrokeredMessage从Azure webjob发送:

string jsonMessage = JsonConvert.SerializeObject(myObject);
Stream streamMessage = new MemoryStream(Encoding.UTF8.GetBytes(jsonMessage));
BrokeredMessage msg = new BrokeredMessage(streamMessage);

client.Send(msg);

Answer 2

我使用接口解密 Base 64 消息的精确设置。很容易在表达式生成器中输入。

json(base64ToString(triggerBody()?['ContentData']))