Условие приложения логики Azure не работает в цикле, если оно основано на изменении значений

Мне нужно написать простое приложение LogicApp, которое подключается к конечной точке http, получает некоторый JSON, перебирает сообщение JSON и отправляет его в другую конечную точку http кусками на основе значения в сообщении.

При этом я пришел к выводу, что условия внутри цикла For Each всегда оценивают условия перед циклом и выполняют путь, соответствующий результату перед циклом, даже если результат должен был измениться, поскольку некоторые переменные были обновлены в петля.

Мне удалось проиллюстрировать проблему на примере ниже.

{
    "definition": {
        "$schema": "https://schema.management.azure.com/providers/Microsoft.Logic/schemas/2016-06-01/workflowdefinition.json#",
        "actions": {
            "Compose": {
                "inputs": "@variables('TestStr')",
                "runAfter": {
                    "Compose_3": [
                        "Succeeded"
                    ]
                },
                "type": "Compose"
            },
            "Compose_3": {
                "inputs": "@variables('TestArray')",
                "runAfter": {
                    "For_each": [
                        "Succeeded"
                    ]
                },
                "type": "Compose"
            },
            "For_each": {
                "actions": {
                    "Compose_2": {
                        "inputs": "@variables('TestArray')",
                        "runAfter": {
                            "Condition": [
                                "Succeeded"
                            ]
                        },
                        "type": "Compose"
                    },
                    "Condition": {
                        "actions": {
                            "Append_to_array_variable": {
                                "inputs": {
                                    "name": "TestArray",
                                    "value": "@items('For_each')"
                                },
                                "runAfter": {},
                                "type": "AppendToArrayVariable"
                            },
                            "Set_variable_2": {
                                "inputs": {
                                    "name": "TestStr",
                                    "value": "XXXX"
                                },
                                "runAfter": {
                                    "Append_to_array_variable": [
                                        "Succeeded"
                                    ]
                                },
                                "type": "SetVariable"
                            }
                        },
                        "else": {
                            "actions": {
                                "Set_variable": {
                                    "inputs": {
                                        "name": "TestStr",
                                        "value": "not"
                                    },
                                    "runAfter": {},
                                    "type": "SetVariable"
                                }
                            }
                        },
                        "expression": {
                            "and": [
                                {
                                    "equals": [
                                        "@variables('TestStr')",
                                        "BlankValue"
                                    ]
                                }
                            ]
                        },
                        "runAfter": {},
                        "type": "If"
                    }
                },
                "foreach": "@variables('FullArray')",
                "runAfter": {
                    "Initialize_variable_3": [
                        "Succeeded"
                    ]
                },
                "type": "Foreach"
            },
            "Initialize_variable": {
                "inputs": {
                    "variables": [
                        {
                            "name": "TestStr",
                            "type": "String",
                            "value": "BlankValue"
                        }
                    ]
                },
                "runAfter": {},
                "type": "InitializeVariable"
            },
            "Initialize_variable_2": {
                "inputs": {
                    "variables": [
                        {
                            "name": "TestArray",
                            "type": "Array"
                        }
                    ]
                },
                "runAfter": {
                    "Initialize_variable": [
                        "Succeeded"
                    ]
                },
                "type": "InitializeVariable"
            },
            "Initialize_variable_3": {
                "inputs": {
                    "variables": [
                        {
                            "name": "FullArray",
                            "type": "Array",
                            "value": [
                                {
                                    "key": "value1"
                                },
                                {
                                    "key": "value2"
                                },
                                {
                                    "key": "value3"
                                }
                            ]
                        }
                    ]
                },
                "runAfter": {
                    "Initialize_variable_2": [
                        "Succeeded"
                    ]
                },
                "type": "InitializeVariable"
            }
        },
        "contentVersion": "1.0.0.0",
        "outputs": {},
        "parameters": {},
        "triggers": {
            "Recurrence": {
                "recurrence": {
                    "frequency": "Month",
                    "interval": 3
                },
                "type": "Recurrence"
            }
        }
    }
}

Я ожидал, что нижеприведенный LogicApp выполнит цикл три раза, каждый раз оценивая условие и выполняя вставку массива только один раз, с TestArray, содержащим одну запись

{
  "key":"value1"
}

и строка TestStr, имеющая значение 'not'

Но фактические результаты, похоже, различаются - TestArray содержит все три записи из FullArray, а TestStr - это 'XXXX'.

Что мне здесь не хватает? Есть ли обходные пути?


person Toms Jansons    schedule 14.05.2019    source источник


Ответы (1)


Я обнаружил причину такого поведения. Публикуйте здесь, если кто-нибудь столкнется с этим в будущем.

По умолчанию циклы For_each выполняются параллельно. Вот почему условия оцениваются для всех итераций перед запуском цикла.

Есть способ отключить это - в Настройках вы можете включить контроль параллелизма и установить параллелизм до 1

person Toms Jansons    schedule 15.05.2019