Atlayan Pencere (Azure Stream Analytics)
Atlayan pencereler sabit boyutlu, çakışmayan ve bitişik zaman aralıkları dizisidir. Aşağıdaki diyagramda bir dizi olay içeren bir akış ve bunların 10 saniyelik atlayan pencerelere nasıl eşlendiği gösterilmektedir.
Syntax
{TUMBLINGWINDOW | TUMBLING} ( timeunit , windowsize, [offsetsize] )
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit , windowsize ), [Offset(timeunit , offsetsize)] )
Not
Atlayan Pencere yukarıdaki iki şekilde kullanılabilir. Atlama Penceresi ile tutarlılık sağlamak için Duration işlevi, pencere boyutunu belirtmek için tüm pencere türleriyle de kullanılabilir. Pencere süresi pozitif bir kayan sabit olmalıdır.
Bağımsız değişkenler
zaman birimi
Pencere boyutu için zaman birimidir. Aşağıdaki tabloda tüm geçerli zaman birimi bağımsız değişkenleri listelemektedir.
Zaman Birimi | Kısaltma |
---|---|
gün | dd, d |
saat | hh |
dakika | mi, n |
saniye | ss, s |
milisaniye | Bayan |
Microsecond | Mcs |
Windowsize
Pencerenin boyutunu açıklayan büyük bir tamsayı. Windowsize statiktir ve çalışma zamanında dinamik olarak değiştirilemez.
Pencerenin boyutu üst sınırı 7 gündür.
offsetsize
Varsayılan olarak, atlayan pencereler pencerenin sonunda kapsayıcıdır ve başlangıçta hariçtir ; örneğin 12:00 - 13:00 penceresi tam olarak 13:00'da gerçekleşen olayları içerir, ancak 12:00'de gerçekleşen olayları içermez (bu olaylar 11:00 – 12:00 PM penceresinin bir parçası olacaktır).
Offset parametresi, bu davranışı değiştirmek ve pencerenin başına olayları dahil etmek ve sonunda gerçekleşenleri hariç tutmak için kullanılabilir.
Örnekler
SELECT System.Timestamp() AS WindowEnd, TollId, COUNT(*)
FROM Input TIMESTAMP BY EntryTime
GROUP BY TollId, TumblingWindow(Duration(hour, 1), Offset(millisecond, -1))
SELECT 'reset' AS command
INTO
alert
FROM
temperature TIMESTAMP BY timeCreated
GROUP BY TumblingWindow(second,15)
HAVING Avg(machine.temperature) > 25
Zaman ile ilgili dikkat edilmesi gerekenler
Her pencere işlemi, pencerenin sonunda olay 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 süreniz varsa, zaman damgası 12:00'den büyük ve 12:05'e kadar (dahil) zaman damgası 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.
Ayrıca Bkz.
Geri Bildirim
https://aka.ms/ContentUserFeedback.
Çok yakında: 2024 boyunca, içerik için geri bildirim mekanizması olarak GitHub Sorunları’nı kullanımdan kaldıracak ve yeni bir geri bildirim sistemiyle değiştireceğiz. Daha fazla bilgi için bkz.Gönderin ve geri bildirimi görüntüleyin