Aracılığıyla paylaş

Microsoft Fabric olay akışları - genel bakış

  • Makale

Microsoft Fabric Gerçek Zamanlı Zeka deneyimindeki olay akışları özelliği, gerçek zamanlı olayları Doku'ya getirmenize, dönüştürmenize ve ardından kod yazmadan (kod yazmadan) çeşitli hedeflere yönlendirmenize olanak tanır. Doku'daki Eventstream öğesinin bir örneği olan bir olay akışı oluşturur, akışa olay veri kaynakları ekler, isteğe bağlı olarak olay verilerini dönüştürmek için dönüştürmeler ekler ve ardından verileri desteklenen hedeflere yönlendirirsiniz.

Olayları Dokuya getirme

Olay akışları özelliği, çeşitli kaynaklardan olay verilerini getirmek için çeşitli kaynak bağlayıcıları sağlar. Olay akışı oluştururken Gelişmiş özellikleri etkinleştirdiğinizde daha fazla kaynak kullanılabilir.

Önemli

Doku olay akışlarının gelişmiş özellikleri şu anda önizleme aşamasındadır.

Kaynaklar Açıklama
Azure Event Hubs Azure olay hub'ına sahipseniz Eventstream kullanarak olay hub'ı verilerini Microsoft Fabric'e alabilirsiniz.
Azure IoT Hub Azure IoT hub'ına sahipseniz Eventstream kullanarak IoT verilerini Microsoft Fabric'e alabilirsiniz.
Azure SQL Veritabanı Veri Yakalamayı Değiştir (CDC) Azure SQL Veritabanı CDC kaynak bağlayıcısı, Azure SQL veritabanındaki geçerli verilerin anlık görüntüsünü yakalamanıza olanak tanır. Bağlayıcı daha sonra bu verilerde gelecekteki satır düzeyindeki değişiklikleri izler ve kaydeder.
Postgre SQL Veritabanı CDC Postgre SQL Veritabanı Veri Yakalamayı Değiştir (CDC) kaynak bağlayıcısı, PostgreSQL veritabanındaki geçerli verilerin anlık görüntüsünü yakalamanıza olanak tanır. Bağlayıcı daha sonra bu verilerde gelecekteki satır düzeyindeki değişiklikleri izler ve kaydeder.
My SQL Veritabanı CDC Azure My SQL Veritabanı Change Data Capture (CDC) Kaynak bağlayıcısı, MySQL için Azure Veritabanı veritabanındaki geçerli verilerin anlık görüntüsünü yakalamanızı sağlar. İzlenecek tabloları belirtebilirsiniz ve olay akışı tablolarda gelecekteki satır düzeyi değişiklikleri kaydeder.
Azure Cosmos DB CDC Microsoft Fabric olay akışları için Azure Cosmos DB Değişiklik Veri Yakalama (CDC) kaynak bağlayıcısı, Azure Cosmos DB veritabanındaki geçerli verilerin anlık görüntüsünü yakalamanıza olanak tanır. Bağlayıcı daha sonra bu verilerde gelecekteki satır düzeyindeki değişiklikleri izler ve kaydeder.
Google Cloud Pub/Sub Google Pub/Sub, etkinlik akışlarını yayımlamanıza ve abone olmanıza olanak tanıyan bir mesajlaşma hizmetidir. Gerçek zamanlı olayları yakalamak, dönüştürmek ve Doku'daki çeşitli hedeflere yönlendirmek için olay akışınıza kaynak olarak Google Pub/Sub ekleyebilirsiniz.
Amazon Kinesis Data Akışlar Amazon Kinesis Data Akışlar, akış verileri için iyileştirilmiş, yüksek oranda ölçeklenebilir, son derece dayanıklı bir veri alımı ve işleme hizmetidir. Amazon Kinesis Data Akışlar olay akışınızda bir kaynak olarak tümleştirerek gerçek zamanlı veri akışlarını Fabric içindeki birden çok hedefe yönlendirmeden önce sorunsuz bir şekilde işleyebilirsiniz.
Confluent Cloud Kafka Confluent Cloud Kafka, Apache Kafka kullanarak güçlü veri akışı ve işleme işlevleri sunan bir akış platformudur. Confluent Cloud Kafka'yı olay akışınızda kaynak olarak tümleştirerek gerçek zamanlı veri akışlarını Doku içindeki birden çok hedefe yönlendirmeden önce sorunsuz bir şekilde işleyebilirsiniz.
olayları Azure Blob Depolama Azure Blob Depolama olaylar, bir istemci bir blob oluşturduğunda, değiştirdiğinde veya sildiğinde tetiklenir. Bağlayıcı, Blob Depolama olaylarını Gerçek Zamanlı hub'daki Doku olaylarına bağlamanıza olanak tanır. Bu olayları, Doku'daki çeşitli hedeflere yönlendirmeden önce sürekli veri akışlarına dönüştürebilir ve dönüştürebilirsiniz.
Doku Çalışma Alanı Öğesi olayları Doku Çalışma Alanı Öğesi olayları, Doku Çalışma Alanınızda değişiklik yapıldığında oluşan ayrık Doku olaylarıdır. Bu değişiklikler arasında Doku öğesi oluşturma, güncelleştirme veya silme yer alır. Doku olay akışları ile bu Doku çalışma alanı olaylarını yakalayabilir, dönüştürebilir ve daha fazla analiz için Doku'daki çeşitli hedeflere yönlendirebilirsiniz.
Örnek veriler Olay akışını ayarlarken veri alımını test etmek için örnek bir veri kaynağı olarak Bisikletler, Sarı Taksi veya Borsa olayları'nı seçebilirsiniz.
Özel uç nokta (eski özel uygulama) Özel uç nokta özelliği, uygulamalarınızın veya Kafka istemcilerinizin bir bağlantı dizesi kullanarak Eventstream'e bağlanmasına olanak tanıyarak akış verilerinin Eventstream'e sorunsuz bir şekilde alımını sağlar.

Kod içermeyen deneyimi kullanarak olayları işleme

Sürükle ve bırak deneyimi, herhangi bir kod yazmadan olay verileri işleme, dönüştürme ve yönlendirme mantığınızı oluşturmanın sezgisel ve kolay bir yolunu sunar. Bir olay akışındaki uçtan uca veri akışı diyagramı, veri akışı ve kuruluşu hakkında kapsamlı bir anlayışa sahip olmanıza olanak sağlayabilir. Olay işlemcisi düzenleyicisi, olay verileri işleme mantığını tasarlamak için sürükleyip bırakmanızı sağlayan kod içermeyen bir deneyimdir.

Dönüşüm Açıklama
Filtre Girişteki bir alanın değerine göre olayları filtrelemek için Filtre dönüştürmesini kullanın. Veri türüne (sayı veya metin) bağlı olarak dönüştürme, veya is not nullgibi is null seçili koşulla eşleşen değerleri tutar.
Alanları yönetme Alanları yönet dönüştürmesi, bir girişten veya başka bir dönüştürmeden gelen alanları eklemenize, kaldırmanıza, değiştirmenize veya yeniden adlandırmanıza olanak tanır.
Toplama Toplamayı (Toplam, Minimum, Maksimum veya Ortalama) bir süre boyunca yeni bir olay gerçekleştiğinde hesaplamak için Toplama dönüştürmesini kullanın. Bu işlem ayrıca bu hesaplanmış sütunların yeniden adlandırılmasına ve verilerinizdeki diğer boyutlara göre toplamayı filtrelemeye veya dilimlemenize de olanak tanır. Aynı dönüştürmede bir veya daha fazla toplamanız olabilir.
Gruplandırma ölçütü: Belirli bir zaman penceresindeki tüm olaylardaki toplamaları hesaplamak için Gruplandırma ölçütü dönüştürmesini kullanın. Bir veya daha fazla alandaki değerlere göre gruplandırabilirsiniz. Toplama dönüştürmesi sütunların yeniden adlandırılmasına olanak tanır, ancak toplama için daha fazla seçenek sağlar ve zaman pencereleri için daha karmaşık seçenekler içerir. Toplama gibi, dönüştürme başına birden fazla toplama ekleyebilirsiniz.
Birleşim İki veya daha fazla düğümü bağlamak ve paylaşılan alanlarla (aynı ad ve veri türüne sahip) olayları tek bir tabloya eklemek için Birleşim dönüştürmesini kullanın. Eşleşmeyen alanlar bırakılır ve çıkışa eklenmez.
Genişlet Dizi içindeki her değer için yeni bir satır oluşturmak için Dizi dönüştürmesini genişlet'i kullanın.
Katılın İki akıştan verileri, aralarındaki eşleşen bir koşula göre birleştirmek için Birleştirme dönüştürmesini kullanın.

Olay akışı oluştururken Gelişmiş özellikleri etkinleştirdiyseniz, dönüştürme işlemleri tüm hedefler için desteklenir (türetilmiş akış, Özel uç nokta, Reflex gibi bazı hedefler için ara köprü görevi görür). Bunu yapmadıysanız dönüştürme işlemleri yalnızca Lakehouse ve KQL Veritabanı (alımdan önce olay işleme) hedefleri için kullanılabilir.

Olayları hedeflere yönlendirme

Doku olay akışları özelliği, aşağıdaki desteklenen hedeflere veri göndermeyi destekler.

Hedef Açıklama
Özel uç nokta (eski özel uygulama) Bu hedefle, gerçek zamanlı olaylarınızı kolayca özel bir uç noktaya yönlendirebilirsiniz. Kendi uygulamalarınızı olay akışına bağlayabilir ve olay verilerini gerçek zamanlı olarak kullanabilirsiniz. Bu hedef, gerçek zamanlı verileri Microsoft Fabric dışındaki bir dış sisteme çıkarmak istediğinizde kullanışlıdır.
KQL Veritabanı Bu hedef, gerçek zamanlı olay verilerinizi bir KQL veritabanına almanızı sağlar; burada verileri sorgulamak ve analiz etmek için güçlü Kusto Sorgu Dili (KQL) kullanabilirsiniz. Kusto veritabanındaki verilerle, olay verileriniz hakkında daha derin içgörüler elde edebilir ve zengin raporlar ve panolar oluşturabilirsiniz. İki alım modu arasında seçim yapabilirsiniz: Doğrudan alma ve Almadan önce olay işleme.
Göl evi Bu hedef, gerçek zamanlı etkinliklerinizi göl binanıza almadan önce dönüştürmenizi sağlar. Gerçek zamanlı olaylar Delta Lake biçimine dönüşür ve belirlenen göl evi tablolarında depolar. Bu hedef, veri ambarı senaryolarını destekler.
Refleks Bu hedef, gerçek zamanlı olay verilerinizi bir Reflex'e doğrudan bağlamanızı sağlar. Reflex, verilere bağlanmak, koşulları izlemek ve harekete geçmek için gereken tüm bilgileri içeren bir akıllı aracı türüdür. Veriler belirli eşiklere ulaştığında veya diğer desenlerle eşleştiğinde, Reflex otomatik olarak kullanıcıları uyarma veya Power Automate iş akışlarını başlatma gibi uygun eylemleri gerçekleştirir.
Türetilmiş akış Türetilmiş akış, bir olay akışına Alanları Filtrele veya Yönet gibi akış işlemleri ekledikten sonra oluşturabileceğiniz özel bir hedef türüdür. Türetilen akış, akış işleme sonrasında dönüştürülen varsayılan akışı temsil eder. Türetilmiş akışı Doku'da birden çok hedefe yönlendirebilir ve türetilmiş akışı Gerçek Zamanlı hub'da görüntüleyebilirsiniz.

Birbirini engellemeden olay akışlarınızdan aynı anda veri almak için bir olay akışına birden çok hedef ekleyebilirsiniz.

Olay Akışı öğesine genel bakışı gösteren ekran görüntüsü.

Not

En az 4 kapasite birimi (SKU: F4) ile Microsoft Fabric olay akışları özelliğini kullanmanızı öneririz

Gelişmiş özellikler (önizleme)

Olay akışı oluştururken Gelişmiş özellikler (önizleme) seçeneğini etkinleştirdiğinizde kullanılabilecek daha fazla özellik, kaynak ve hedef vardır. Gelişmiş özelliklerle desteklenen ek kaynaklar ve hedefler hakkında bilgi edinmek için Gelişmiş özellikler (önizleme) ve Standart özellikler sekmelerini kullanın.

Gelişmiş özelliklerin (önizleme) diğer dikkat çekici özelliklerinden birkaçı aşağıdadır:

  • Düzenleme Modu ve Canlı Görünüm. Akış işlemeyi görselleştirmek ve tasarlamak için iki farklı modu keşfedin.
  • Varsayılan ve türetilmiş akışlar. Daha sonra Gerçek Zamanlı hub'da kullanılabilecek bir olay işlemcisi ile tasarladığınız biçimle sürekli akış akışı oluşturun.
  • İçeriğe göre veri akışı yönlendirme. Olay işlemcisi ile tasarladığınız veri akışı içeriğine göre veri akışlarınızı Doku içinde herhangi bir yere dönüştürün ve yönlendirin.

İlgili içerik