通过


你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

映射数据流中的过滤转换

适用于: Azure 数据工厂 Azure Synapse Analytics

提示

Microsoft Fabric 中的 Data Factory 是下一代 Azure 数据工厂,具有更加简化的架构、内置人工智能和新功能。 如果不熟悉数据集成,请从Fabric数据工厂开始。 现有 ADF 工作负载可以升级到 Fabric,以跨数据科学、实时分析和报告访问新功能。

数据流可在Azure 数据工厂管道和Azure Synapse Analytics管道中使用。 本文适用于映射数据流。 如果你不熟悉转换,请参阅介绍性文章: 使用映射数据流转换数据

筛选转换允许根据条件对行进行筛选。 输出流包括与筛选条件匹配的所有行。 筛选转换类似于 SQL 中的 WHERE 子句。

配置

使用数据流表达式生成器为筛选条件输入表达式。 若要打开表达式生成器,请选择蓝色框。 筛选条件必须为布尔型。 有关如何创建表达式的详细信息,请参阅表达式生成器文档。

筛选转换

数据流脚本

语法

<incomingStream>
    filter(
        <conditionalExpression>
    ) ~> <filterTransformationName>

示例

下面的示例是一个名为 FilterBefore1960 的筛选转换,它接收传入流 CleanData。 筛选条件是 year <= 1960 表达式。

在 UI 中,此转换如下图所示:

筛选转换

此转换的数据流脚本位于下面的代码片段中:

CleanData
    filter(
        year <= 1960
    ) ~> FilterBefore1960

筛选出具有 选择转换的列。