Pencereleme işlevleri

✅ Azure Stream Analytics ✅ Fabric Olay Akışı

Gerçek zamanlı olayları işleyen uygulamalarda, belirli bir süre içinde gerçekleşen olayların alt kümeleri üzerinde bazı ayar tabanlı hesaplamalar (toplama) veya başka işlemler gerçekleştirmek yaygın bir durumdur. Zaman kavramı karmaşık olay işleme sistemleri için temel bir gereklilik olduğundan, sistemdeki sorgu mantığının zaman bileşeniyle çalışmak için basit bir yönteme sahip olmak önemlidir. Azure Stream Analytics'te bu olay alt kümeleri, gruplara göre zaman gösterimi için pencereler aracılığıyla tanımlanır. Bu makalede pencereler ve bunların nasıl tanımlandığı açıklanır, desteklenen pencere türleri tanımlanır ve çeşitli işleçlerle pencereleri nasıl kullanabileceğiniz açıklanır.

Windows'un anlaşılması

Bir pencere zaman çizelgesi boyunca olay verileri içerir ve bu pencere içindeki olaylara karşı çeşitli işlemler gerçekleştirmenizi sağlar. Örneğin, aşağıdaki çizimde gösterildiği gibi belirli bir penceredeki yük alanlarının değerlerini toplamak isteyebilirsiniz.

Her pencere işlemi, pencerenin sonunda olay çıkışı oluşturur. Azure Stream Analytics pencereleri, pencere başlangıç zamanında açılır ve pencere bitiş saatinde kapatılır. Örneğin, saat 12:00 ile 12:05 arasında 5 dakikalık bir pencereniz varsa, zaman damgası 12:00'den büyük olan ve 12:05'e kadar (dahil) zaman damgasına sahip tüm olaylar bu pencereye eklenir. Pencerenin çıkışı, pencere bitiş zamanına eşit bir zaman damgası ile kullanılan toplama işlevini temel alan tek bir olay olacaktır. Pencerenin çıkış olayının zaman damgası, system.timestamp() özelliği kullanılarak select deyiminde diğer ad kullanılarak yansıtılabilir. Her pencere otomatik olarak sıfırıncı saate hizalanır. Örneğin, 5 dakikalık atlayan bir pencere kendisini (12:00-12:05] , (12:05-12:10], ... vb. ile hizalar.

Pencere işleminden sonra, bir olayın zaman damgası özgün olay zamanı özniteliğinden ( varış saati veya TIMESTAMP BY ile kullanılan sütun) farklılık gösterir. Bir olayın geçerli, güncelleştirilmiş zaman damgasına her zaman system.timestamp() ile erişilebilir.

Uyarı

Tüm pencereler GROUP BY yan tümcesinde kullanılmalıdır.

Beş pencere türü vardır:

1. Atlayan Pencere

2. Atlama Penceresi

3. Kayan Pencere

4. Oturum Penceresi

5. Anlık Görüntü Penceresi

Her durumda pencerenin en büyük boyutu 7 gündür.

Windows işlevini kullanarak aynı GROUP BY deyiminde birden çok zaman penceresi toplayabilirsiniz.

Ayrıca Bkz.

Yerleşik İşlevler
Toplama İşlevleri
Analitik Fonksiyonlar
Dizi İşlevleri (Stream Analytics)
Dönüştürme İşlevleri
Tarih ve Saat İşlevleri
Kayıt İşlevleri