Condividi tramite


Trasformazione filtro nel flusso di dati di mapping

APPLICABILE A: Azure Data Factory Azure Synapse Analytics

Suggerimento

Data Factory in Microsoft Fabric è la nuova generazione di Azure Data Factory, con un'architettura più semplice, un'intelligenza artificiale predefinita e nuove funzionalità. Se non si ha familiarità con l'integrazione dei dati, iniziare con Fabric Data Factory. I carichi di lavoro di Azure Data Factory esistenti possono eseguire l'aggiornamento a Fabric per accedere a nuove funzionalità tra data science, analisi in tempo reale e creazione di report.

I flussi di dati sono disponibili sia nelle pipeline Azure Data Factory che nelle pipeline di Azure Synapse Analytics. Questo articolo si applica ai flussi di dati di mappatura. Se non si ha familiarità con le trasformazioni, vedere l'articolo introduttivo Trasformare i dati usando flussi di dati di mapping.

Le trasformazioni filtro consentono il filtro delle righe in base a una condizione. Il flusso di output include tutte le righe che corrispondono alla condizione di filtro. La trasformazione del filtro è simile a una clausola WHERE in SQL.

Impostazione

Usare il generatore di espressioni del flusso di dati per immettere un'espressione per la condizione di filtro. Per aprire il generatore di espressioni, selezionare la casella blu. La condizione del filtro deve essere di tipo booleano. Per altre informazioni su come creare un'espressione, vedere la documentazione di Generatore di espressioni.

Trasformazione filtro

Script del flusso di dati

Sintassi

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

Esempio

L'esempio seguente è una trasformazione di filtro denominata FilterBefore1960 che riceve il flusso in ingresso CleanData. La condizione di filtro è l'espressione year <= 1960.

Nell'interfaccia utente questa trasformazione è simile all'immagine seguente:

Trasformazione filtro

Lo script del flusso di dati per questa trasformazione si trova nel frammento di codice seguente:

CleanData
    filter(
        year <= 1960
    ) ~> FilterBefore1960

Filtra le colonne con la trasformazione di selezione.