将参数传递给 U-SQL 分区函数

Question

我们想从 Azure 数据工厂 v2 向 U-SQL 传递一个参数，以控制我们在 ADLA 中的并行度。

因此，我拥有从 ADF 传递的参数 @USQL_Parallelism。

如何最好地将它集成到我的脚本中？

@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 活动，请在管道 json 的“typeProperties”部分添加以下代码。

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