可以在ADF数据流表达式构建器中使用用户参数或全局参数作为变量来代替固定的值。以下是使用用户参数作为变量的示例。
定义用户参数 在ADF管道的参数选项中定义新的用户参数。 参数名称:param1 参数类型:字符串 默认值:空
在数据流转换活动中使用用户参数 在表达式构建器中使用以下语法引用参数: @pipeline().parameters.param1 参考代码:
source(format: "json", skipLineEnding: true, validateSchema: false, encodingName: "UTF-8", rowTag: "$", documentSerialization: "wholefile", storeWrites: true, ignoreNullValuesOnPartitionBy: true, storeMetadataInHeader: true, storeWholeFile: true, compressionCompressionLevel: "Optimal", compressionType: "Deflate", compressionIncludeHeader: true, enablePartitionDiscovery: true, storeWriteOptions: false, storeFileName: true, validateDataFlowOutputSchema: false, wildcardPaths: [ '/mypath/.json' ], recursiveWildcardPaths: [ '/mypath/**/.json' ], multiLine: false, fileSystem: 'ADLSGen2',cloudDataMovementUnits : 64, parallelCopies : 128, enableSkipIncompatibleRow : false, customLogPath : "log", formatDataflowResult : false, fileFormatType : 'Text', reportAdditionalProperties : false, reportDataFormat : false) ~> filter(RowFilter = @equals(@item().fieldname1, @pipeline().parameters.param1))
在示例代码中,用户参数param1 通过 @pipeline().parameters.param1 引用。
注意:全局参数和用户参数可以在ADF存储帐户的参数选项中定义。在筛选器等活动中,可以使用函数 @pipeline().globalParameters.<参数名称> 和 @pipeline().parameters.<参数名称> 引用全局参数和用户参数。