Pencereleme işlevleri (Azure Stream Analytics)

  • Makale

Gerçek zamanlı olayları işleyen uygulamalarda, belirli bir süre içinde gerçekleşen olayların alt kümeleri üzerinde bazı küme 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, gruplandırmaları zamana göre göstermek 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ı

Pencere, zaman çizelgesi boyunca olay verilerini 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.

Stream Analytics sorgu dili dönen pencere

Her pencere işlemi, pencerenin sonunda olay çıkışı oluşturur. Azure Stream Analytics pencereleri pencere başlangıç saatinde açılır ve pencere bitiş saatinde kapatılır. Örneğin, saat 12:00 ile 12:05 arasında 5 dakikalık bir zaman aralığınız varsa, zaman damgası 12:00'den büyük ve zaman damgası 12:05'e kadar (dahil) olan 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ı, diğer ad kullanılarak System.Timestamp() özelliği kullanılarak SELECT deyiminde yansıtılabilir. Her pencere otomatik olarak kendini sıfırıncı saate hizalar. Ö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.

Not

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

Beş tür pencere vardır:

  1. Atlayan Pencere (Azure Stream Analytics)

  2. Atlama Penceresi (Azure Stream Analytics)

  3. Kayan Pencere (Azure Stream Analytics)

  4. Oturum Penceresi (Azure Stream Analytics)

  5. Anlık Görüntü Penceresi (Azure Stream Analytics)

Tüm durumlarda pencerenin boyut üst sınırı 7 gündür.

Windows (Azure Stream Analytics) işlevini kullanarak aynı GROUP BY deyiminde birden çok zaman penceresi toplayabilirsiniz.

Ayrıca Bkz.

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