Dairesel Pencere

✅ Azure Stream Analytics ✅ Fabric Olay Akışı

Yuvarlanan pencereler sabit boyutlu, örtüşmeyen ve bitişik zaman aralıkları dizisidir. Aşağıdaki diyagramda bir dizi olay içeren bir akış ve bunların 10 saniyelik yuvarlanan pencerelere nasıl eşlendiği gösterilmektedir.

Stream Analytics atlayan pencere 5 dk

Sözdizimi

{TUMBLINGWINDOW | TUMBLING} ( timeunit  , windowsize, [offsetsize] )  
{TUMBLINGWINDOW | TUMBLING} ( Duration( timeunit  , windowsize ), [Offset(timeunit  , offsetsize)] )  
  

Uyarı

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 float sabiti olmalıdır.

Tartışmalar

zaman birimi

Windowsize için zaman birimidir. Aşağıdaki tabloda tüm geçerli zaman birimi bağımsız değişkenleri listelemektedir.

Zaman Birimi Kısaltmalar
gün dd, d
saat Hh
dakika mi, n
saniye ss, s
milisaniye Ms
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 en büyük boyutu 7 gündür.

offsetsize

Varsayılan olarak, yuvarlanan pencereler pencerenin sonunda kapsayıcıdır ve başlangıçta hariçtir ; örneğin 12:00 – 13:00 penceresi tam olarak 13:00'te gerçekleşen olayları içerir, ancak 12:00'de gerçekleşen olayları içermez (bu olaylar 11:00 – 12:00 pm penceresinin parçası olacaktır).

Offset parametresi, bu davranışı değiştirmek ve pencerenin başına olayları dahil etmek ve sonunda gerçekleşenleri dışlamak 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 çı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.

Ayrıca Bkz.

Atlama Penceresi
Kayan Pencere
Pencereleme