Microsoft Fabric olay akışları - genel bakış
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. Ayrıca, Eventstream öğesinde bulunan Apache Kafka uç noktalarıyla Kafka protokollerini kullanarak gerçek zamanlı olaylar gönderebilir veya kullanabilirsiniz.
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. |
| VM DB'de SQL Server (CDC) | Doku olay akışları için VM DB üzerinde SQL Server (CDC) kaynak bağlayıcısı, VM'deki SQL Server veritabanındaki geçerli verilerin anlık görüntüsünü yakalamanıza olanak tanır. Ardından bağlayıcı, gelecekteki satır düzeyindeki değişiklikleri izler ve verilerde kaydeder. |
| cdc Azure SQL Yönetilen Örneği | Microsoft Fabric olay akışları için Azure SQL Yönetilen Örneği CDC kaynak bağlayıcısı, SQL Yönetilen Örneği veritabanındaki geçerli verilerin anlık görüntüsünü yakalamanızı sağlar. 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 Veri Akışları | Amazon Kinesis Veri 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 Veri Akışlarını olay akışınızda bir 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. |
| 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. |
| Apache Kafka | Apache Kafka, ölçeklenebilir, gerçek zamanlı veri sistemleri oluşturmaya yönelik açık kaynaklı, dağıtılmış bir platformdur. Apache Kafka'yı olay akışınızdaki bir kaynak olarak tümleştirerek, Apache Kafka'nızdan gerçek zamanlı olayları sorunsuz bir şekilde getirebilir ve Doku içindeki birden çok hedefe yönlendirmeden önce işleyebilirsiniz. |
| Amazon MSK Kafka | Amazon MSK Kafka, kurulumu, ölçeklendirmeyi ve yönetimi basitleştiren tam olarak yönetilen bir Kafka hizmetidir. Amazon MSK Kafka'yı olay akışınızdaki bir kaynak olarak tümleştirerek, MSK Kafka'nızdan gerçek zamanlı olayları sorunsuz bir şekilde getirebilir ve bunları Fabric içindeki birden çok hedefe yönlendirmeden önce 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 (ör. Standart özellikte Ö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 Eventhouse (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 (ör. Standart özellikte Ö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. |
| Eventhouse | Bu hedef, gerçek zamanlı olay verilerinizi bir Eventhouse'a almanızı sağlar. Burada güçlü Kusto Sorgu Dili (KQL) kullanarak verileri sorgulayabilir ve analiz edebilirsiniz. Eventhouse'daki verilerle, olay verileriniz hakkında daha derin içgörüler elde edebilir, 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.
Not
En az 4 kapasite birimi (SKU: F4) ile Microsoft Fabric olay akışları özelliğini kullanmanızı öneririz
Apache Kafka on Fabric olay akışları
Doku olay akışları özelliği, Olay Akışı öğesinde bir Apache Kafka uç noktası sunarak kullanıcıların Kafka protokolü aracılığıyla akış olaylarına bağlanmasına ve bunları kullanmasına olanak tanır. Belirli Kafka konularına sahip akış olaylarını göndermek veya kullanmak için Apache Kafka protokolünü kullanan bir uygulamanız varsa, bağlantı ayarlarınızı olay akışınızda sağlanan Kafka uç noktasına işaret etmek üzere güncelleştirerek aynı uygulamayı olay akışınızdaki akış olaylarını göndermek veya kullanmak için zahmetsizce uyarlayabilirsiniz.
Doku olay akışları özelliği, tam olarak yönetilen bir bulutta yerel hizmet olan Azure Event Hubs tarafından desteklenir. Bir olay akışı oluşturulduğunda, bir olay hub'ı ad alanı otomatik olarak sağlanır ve bir olay hub'ı herhangi bir sağlama yapılandırması gerektirmeden varsayılan akışa ayrılır. Azure Event Hubs hizmetindeki Kafka ile uyumlu özellikler hakkında daha fazla bilgi edinmek için bkz . Apache Kafka için Azure Event Hubs
Olay akışına olay göndermek için Kafka uç noktası ayrıntılarını alma hakkında daha fazla bilgi edinmek için bkz . Olay akışına özel uç nokta kaynağı ekleme; olay akışından olayları kullanmak için bkz . Olay akışına özel uç nokta hedefi ekleme
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.