【发布时间】:2020-04-17 06:58:06
【问题描述】:
我有以下触发器:
"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@zzz.com",
"ishtml": true,
"subject": "message",
"text": "<p>want!!!@{items('For_each_2')?['MessageText']}</p>",
"to": "receiver@gmail.com"
},
"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\":\"werew@zzzz.com\"}}"
}
但Get_messages 有结果:
QueueMessage : []
我没有收到任何电子邮件。怎么了?
【问题讨论】: