Transformación de filtro en el flujo de datos de mapeo

SE APLICA A: Azure Data Factory Azure Synapse Analytics

Sugerencia

Data Factory en Microsoft Fabric es la próxima generación de Azure Data Factory, con una arquitectura más sencilla, inteligencia artificial integrada y nuevas características. Si no está familiarizado con la integración de datos, comience con Fabric Data Factory. Las cargas de trabajo de ADF existentes pueden actualizarse a Fabric para acceder a nuevas funcionalidades en ciencia de datos, análisis en tiempo real e informes.

• Iniciar una prueba gratuita de Fabric.
• Actualización de Azure Data Factory a Data Factory en Microsoft Fabric

Los flujos de datos están disponibles tanto en canalizaciones de Azure Data Factory como en canalizaciones de Azure Synapse Analytics. Este artículo se aplica a los flujos de datos de mapeo. Si no está familiarizado con las transformaciones, consulte el artículo introductorio Transformación de datos mediante flujos de datos de asignación.

La transformación del filtro permite el filtrado de filas en función de una condición. El flujo de salida incluye todas las filas que coinciden con la condición de filtrado. La transformación de filtro es similar a una cláusula WHERE de SQL.

Configuración

Utilice el generador de expresiones de flujo de datos para especificar una expresión como condición de filtro. Para abrir el generador de expresiones, seleccione el cuadro azul. La condición de filtro debe ser de tipo booleano. Para obtener más información sobre cómo crear una expresión, consulte la documentación del generador de expresiones.

Script de flujo de datos

Sintaxis

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

Ejemplo

En el ejemplo siguiente se muestra una transformación Filtrar denominada FilterBefore1960 que toma el flujo entrante CleanData. La condición de filtro es la expresión year <= 1960.

En la interfaz de usuario, esta transformación es similar a la siguiente imagen:

En el siguiente fragmento de código se muestra el script del flujo de datos para esta transformación:

CleanData
    filter(
        year <= 1960
    ) ~> FilterBefore1960

Contenido relacionado

Filtre las columnas mediante la transformación de selección.