【问题标题】:Azure Logic Apps, no content from queueAzure 逻辑应用,队列中没有内容
【发布时间】: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 : []

我没有收到任何电子邮件。怎么了?

【问题讨论】:

    标签: azure azure-logic-apps


    【解决方案1】:

    这是因为你不需要Get_messages,查看触发器定义When there are messages in a queue,它会返回Messages类型,表示你已经收到消息了。

    因为队列已被触发器处理,它将从队列中删除,因此您无法通过操作再次获取它。

    所以在触发后你可以得到带有动态内容的消息内容。

    【讨论】:

    • 非常感谢!文档对逻辑应用程序 + Azure 队列的主题覆盖得非常差,您的帖子是我能找到的所有内容中最重要的一个。
    • 它的疯狂之处在于 Logic Apps 据说是旧的、成熟的产品,但您的帖子才 1 个月大。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2017-10-17
    • 2017-04-08
    • 2017-09-21
    • 1970-01-01
    • 1970-01-01
    • 2019-05-09
    • 2020-01-03
    相关资源
    最近更新 更多