映射数据流中的筛选转换

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

提示

试用 Microsoft Fabric 中的数据工厂,这是一种适用于企业的一站式分析解决方案。 Microsoft Fabric 涵盖从数据移动到数据科学、实时分析、商业智能和报告的所有内容。 了解如何免费开始新的试用

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

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

Configuration

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

筛选转换

数据流脚本

语法

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

示例

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

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

筛选转换

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

CleanData
    filter(
        year <= 1960
    ) ~> FilterBefore1960

使用选择转换筛选掉列