逻辑应用程序 - 从 Web 服务读取 XML 响应并将解析的数据存储在数据库中

Question

我正在尝试使用 Logic Apps 来完成我过去使用 Pentaho 所做的事情。我想构建一个带有 Recurrence 触发器的逻辑应用程序，它启动一个 HTTP 步骤以发布到 Web 服务并接收 XML 回复。我想解析那个 XML 回复（已知格式）并将结果存储在 Azure SQL Server 数据库中。

我已经成功测试了 HTTP 步骤并收到了回复 XML。我在 SQL 数据库中完成了目标表。我不知道如何使用逻辑应用程序将 XML 回复解析为类似 CSV 格式的内容，我可以将其传递给 SQL 查询以输入新的表行。

我浏览了几个教程和其他线程，但这些步骤要么假设我拥有比我拥有的更高水平的经验，要么是逻辑应用程序的非常基本的介绍。

我认为听到以下内容会有所帮助：

1. 这是否比我预期的更具挑战性？我擅长使用 SQL、Pentaho、R 和其他工具，但对 HTTP 调用/响应有些陌生，并且对 XML 的经验很少。

2. 我应该考虑哪些 Logic Flow 连接器，它们是免费产品的一部分，还是某些付费包的一部分？

在此先感谢您在入门方面的任何帮助。

Answer 1

如果您在解析之后将 XML 转换为 JSON 对象，那么它会简单得多。这两者都可以通过使用xml 和json 函数来完成。

此外，由于您知道 XML 的格式，因此您将知道转换后的 JSON 的格式，并让您使用 Parse JSON 操作来获取简单的令牌以在逻辑应用的其余部分中使用。

然后您可以直接在 SQL 查询中使用这些标记。

这是一个逻辑应用程序，展示了这种情况（没有 SQL 和 HTTP 步骤）

及其定义要明确

{
    "definition": {
        "$schema": "https://schema.management.azure.com/providers/Microsoft.Logic/schemas/2016-06-01/workflowdefinition.json#",
        "actions": {
            "CSV_Data": {
                "inputs": {
                    "variables": [
                        {
                            "name": "random_data_csv",
                            "type": "String",
                            "value": "@{body('Parse_JSON')?['data']?['name']},@{body('Parse_JSON')?['data']?['awesome']}"
                        }
                    ]
                },
                "runAfter": {
                    "Parse_JSON": [
                        "Succeeded"
                    ]
                },
                "type": "InitializeVariable"
            },
            "Parse_JSON": {
                "inputs": {
                    "content": "@json(xml(variables('random_data_xml')))",
                    "schema": {
                        "properties": {
                            "data": {
                                "properties": {
                                    "awesome": {
                                        "type": "string"
                                    },
                                    "name": {
                                        "type": "string"
                                    }
                                },
                                "type": "object"
                            }
                        },
                        "type": "object"
                    }
                },
                "runAfter": {
                    "XML_Data": [
                        "Succeeded"
                    ]
                },
                "type": "ParseJson"
            },
            "XML_Data": {
                "inputs": {
                    "variables": [
                        {
                            "name": "random_data_xml",
                            "type": "String",
                            "value": "<data>\n<name>Azure Logic Apps</name>\n<awesome>true</awesome>\n</data>"
                        }
                    ]
                },
                "runAfter": {},
                "type": "InitializeVariable"
            }
        },
        "contentVersion": "1.0.0.0",
        "outputs": {},
        "parameters": {},
        "triggers": {
            "manual": {
                "inputs": {
                    "schema": {}
                },
                "kind": "Http",
                "type": "Request"
            }
        }
    }
}