我有以下触发器:
"triggers": {
"When_there_are_messages_in_a_queue": {
"inputs": {
"host": {
"connection": {
"name": "@parameters('$connections')['azurequeues']['connectionId']"
}
},
"method": "get",
"path": "/@{encodeURIComponent('drugconsortium-positive-result')}/message_trigger"
},
"recurrence": {
"frequency": "Minute",
"interval": 1
},
"splitOn": "@triggerBody()?['QueueMessagesList']?['QueueMessage']",
"type": "ApiConnection"
}
}
然后我尝试从队列中获取消息:
"Get_messages": {
"inputs": {
"host": {
"connection": {
"name": "@parameters('$connections')['azurequeues']['connectionId']"
}
},
"method": "get",
"path": "/@{encodeURIComponent('drugconsortium-positive-result')}/messages",
"queries": {
"visibilitytimeout": "30"
}
},
"runAfter": {},
"type": "ApiConnection"
}
然后尝试发送包含队列内容的电子邮件:
"For_each_2": {
"actions": {
"Send_email_(V4)_3": {
"inputs": {
"body": {
"from": "[email protected]",
"ishtml": true,
"subject": "message",
"text": "<p>want!!!@{items('For_each_2')?['MessageText']}</p>",
"to": "[email protected]"
},
"host": {
"connection": {
"name": "@parameters('$connections')['sendgrid']['connectionId']"
}
},
"method": "post",
"path": "/v4/mail/send"
},
"runAfter": {},
"type": "ApiConnection"
}
},
"foreach": "@body('Get_messages')?['QueueMessagesList']?['QueueMessage']",
"runAfter": {
"Get_messages": [
"Succeeded"
]
},
"type": "Foreach"
}
执行后,我会看到一条触发消息:
{
"MessageId": "83aac220-9ee5-440c-9a34-391abaa0e464",
"InsertionTime": "Thu, 12 Mar 2020 20:21:51 GMT",
"ExpirationTime": "Thu, 19 Mar 2020 20:21:51 GMT",
"PopReceipt": "AgAAAAMAAAAAAAAA+JoXDKz41QE=",
"TimeNextVisible": "Thu, 12 Mar 2020 20:23:09 GMT",
"DequeueCount": "1",
"MessageText": "{\"DriverId\":-1,\"DriverName\":\"John Smith\",\"DriverSSN\":\"111-11-1111\",\"CarrierName\":\"Carrier Name\",\"DER\":{\"Name\":\"Der name\",\"Email\":\"[email protected]\"}}"
}
但Get_messages
结果是:
QueueMessage : []
而且我没有收到任何电子邮件。怎么了?
这是因为您不需要Get_messages
,检查触发器定义。当队列中有消息时,它将返回Messages
类型,表示您已经获得消息。
由于触发器已经处理了队列,因此将从队列中将其删除,因此您无法通过该操作再次获取它。
因此,在触发之后,您可以获得带有动态内容的消息内容。
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句