Передать параметр в функцию U-SQL Partition

Question

Мы хотим передать параметр в U-SQL из фабрики данных Azure v2, чтобы контролировать уровень параллелизма в ADLA.

Поэтому у меня есть параметр @USQL_Parallelism, который я передаю из ADF.

Как мне лучше интегрировать это в мой скрипт?

@CompleteExtractClean = 
    SELECT
        [CE].[FileName],
        [CE].[iDocId],
        XXX
    FROM @CompleteExtract AS [CE]
    OPTION(PARTITION(iDocId)=(PARTITIONCOUNT=@USQL_Parallelism));

Теперь я получаю следующую ошибку:

В скрипте обнаружен неверный синтаксис.

Какой синтаксис для правильной обработки параметра?

Answer 1

вы использовали инструмент ADFv2 UI?Если это так, следуйте приведенному ниже рисунку, чтобы передать значение в «USQL_Parallelism».

если вы использовали Powershell или Rest API для запуска операций U-SQL, добавьте следующеекод в части "typeProperties" в конвейере json.

"parameters": {
  "USQL_Parallelism": "1"  // the value you need
}