Azure 数据工厂中的 Filter 活动Filter activity in Azure Data Factory
可以在管道中使用 Filter 活动将筛选器表达式应用到输入数组。You can use a Filter activity in a pipeline to apply a filter expression to an input array.
Azure 数据工厂 Azure Synapse Analytics（预览版）Azure Data Factory Azure Synapse Analytics (Preview)
语法Syntax
{
"name": "MyFilterActivity",
"type": "filter",
"typeProperties": {
"condition": "<condition>",
"items": "<input array>"
}
}
Type 属性Type properties
| 属性Property | 说明Description | 允许的值Allowed values | 必须Required |
|---|---|---|---|
| namename | Filter 活动的名称。Name of the Filter activity. |
StringString | 是Yes |
| typetype | 必须设置为 “filter”。Must be set to filter. | StringString | 是Yes |
| conditioncondition | 要用于筛选输入的条件。Condition to be used for filtering the input. | 表达式Expression | 是Yes |
| itemsitems | 应该应用筛选器的输入数组。Input array on which filter should be applied. | 表达式Expression | 是Yes |
示例Example
在此示例中，管道包含两个活动：Filter 和 ForEach。In this example, the pipeline has two activities: Filter and ForEach. Filter 活动配置为筛选输入数组中值大于 3 的项。The Filter activity is configured to filter the input array for items with a value greater than 3. 然后，ForEach 活动会循环访问筛选的值，并将变量 test 设置为当前值。The ForEach activity then iterates over the filtered values and sets the variable test to the current value.
{
"name": "PipelineName",
"properties": {
"activities": [{
"name": "MyFilterActivity",
"type": "filter",
"typeProperties": {
"condition": "@greater(item(),3)",
"items": "@pipeline().parameters.inputs"
}
},
{
"name": "MyForEach",
"type": "ForEach",
"dependsOn": [
{
"activity": "MyFilterActivity",
"dependencyConditions": [
"Succeeded"
]
}
],
"userProperties": [],
"typeProperties": {
"items": {
"value": "@activity('MyFilterActivity').output.value",
"type": "Expression"
},
"isSequential": "false",
"batchCount": 1,
"activities": [
{
"name": "Set Variable1",
"type": "SetVariable",
"dependsOn": [],
"userProperties": [],
"typeProperties": {
"variableName": "test",
"value": {
"value": "@string(item())",
"type": "Expression"
}
}
}
]
}
}],
"parameters": {
"inputs": {
"type": "Array",
"defaultValue": [1, 2, 3, 4, 5, 6]
}
},
"variables": {
"test": {
"type": "String"
}
},
"annotations": []
}
}
后续步骤Next steps
查看数据工厂支持的其他控制流活动：See other control flow activities supported by Data Factory: