Veri eşleme akışında filtre dönüşümü

ŞUNLARA UYGULANIR: Azure Data Factory Azure Synapse Analytics

İpucu

Microsoft Fabric'daki Data Factory, daha basit bir mimariye, yerleşik yapay zekaya ve yeni özelliklere sahip yeni nesil Azure Data Factory. Veri tümleştirmeyi yeni kullanmaya başladıysanız Fabric Data Factory ile başlayın. Mevcut ADF iş yükleri veri bilimi, gerçek zamanlı analiz ve raporlama genelinde yeni özelliklere erişmek için Fabric yükseltebilir.

Veri akışları hem Azure Data Factory işlem hatlarında hem de Azure Synapse Analytics işlem hatlarında kullanılabilir. Bu makale, eşleme veri akışları için geçerlidir. Dönüştürmeler hakkında yeniyseniz , Eşleme veri akışlarını kullanarak verileri dönüştürme başlıklı giriş makalesine bakın.

İpucu

Veri Akışı 2. Nesil'deki eşdeğer dönüştürme (Satırları filtrele) için bkz. Veri akışı kullanıcılarını eşlemek için Veri Akışı 2. Nesil kılavuzu.

Filtre dönüştürmeleri, bir koşula göre satır filtrelemeye izin verir. Çıkış akışı, filtreleme koşuluyla eşleşen tüm satırları içerir. Filtre dönüştürme, SQL'deki WHERE yan tümcesine benzer.

Yapılandırma

Filtre koşulu için bir ifade girmek için veri akışı ifade oluşturucusunu kullanın. İfade oluşturucusunu açmak için mavi kutuyu seçin. Filtre koşulu boole türünde olmalıdır. İfade oluşturma hakkında daha fazla bilgi için ifade oluşturucu belgelerine bakın.

Filtre dönüştürme

Veri akışı skripti

Sözdizimi

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

Örnek

Aşağıdaki örnek, gelen akış FilterBefore1960'i alan CleanData adlı bir filtre dönüşümüdür. Filtre koşulu ifadesidir year <= 1960.

Kullanıcı arabiriminde bu dönüştürme aşağıdaki görüntüye benzer:

Filtre dönüştürme

Bu dönüşümün veri akışı betiği aşağıdaki kod parçacığındadır:

CleanData
    filter(
        year <= 1960
    ) ~> FilterBefore1960

Seçme dönüştürmesi ile sütunları filtreleyin.