Фон
У меня есть конвейер ADF, который берет задания из «сторонней» очереди (через вызов REST), завершает задания и помечает сообщение в очереди как завершенное. Если очередь пуста, конвейер заканчивается. В противном случае конвейер зацикливается до тех пор, пока очередь не станет пустой.
Я могу масштабировать конвейер, создавая несколько «запланированных» триггеров, запускаемых каждую минуту. Я могу контролировать количество запущенных экземпляров конвейера, изменяя его номера параллелизма.
Вопрос
Есть ли способ, которым конвейер ADF изменяет свой номер параллелизма на основе вычисляемого условия, такого как длина очереди?





В настоящее время вы можете указать только значения числовой жестко закодированный в настройках параллелизма, и нет возможности передать значение динамически.