使用 StreamInsight LINQ

 

一旦資料傳遞到 StreamInsight 伺服器之後,可能會持續針對資料執行計算。 換句話說,當事件插入伺服器時,這些事件會由常設查詢所處理,這些查詢會發出已處理的輸出事件。 這些常設查詢是以語言架構 LINQ 所撰寫。 LINQ 是在資料集上表示宣告式查詢的一種機制,這個機制會完全整合到類似 C# 的主機語言中。 在目前的版本中,StreamInsight 只支援使用 C# 當做主機語言。 這個架構已經為了 StreamInsight 平台而改寫,如此就能夠利用 C# 來與 StreamInsight 伺服器緊密地整合在一起。 本節的主題會示範這個平台針對事件所支援的一些計算作業,並示範如何使用 StreamInsight LINQ 查詢來指定這些作業。

System_CAPS_ICON_note.jpg 注意事項


在 StreamInsight 2.0 (含) 以前版本中,暫時資料流是使用 CepStream<> 介面實作。 雖然持續支援 CepStream<> 介面,但在 2.1 (含) 以後版本中,暫時資料流是透過 IQStreamable<> 介面實作,並且可以使用 StreamInsight LINQ 來處理。 針對 IQStreamable<> 撰寫的暫時查詢語法與現有以 CepStream<> 為基礎的 LINQ 提供者一致,不過已有一些變更,以利用 IQStreamable<> 介面的新功能。 本節中會識別 IQStreamable<>CepStream<> 介面之間的任何差異。

如需有關針對 StreamInsight 撰寫 LINQ 查詢的詳細指引,請參閱 StreamInsight 查詢漫遊指南

本節內容

投射
篩選
聯結
聯集
群組及套用
時間戳記修改
使用者定義函數 (StreamInsight)
使用者定義的資料流運算子
使用事件視窗
計數視窗
跳動視窗
快照集視窗
彙總
TopK
使用者定義彙總和運算子

請參閱

Concepts du serveur StreamInsight
Language-Integrated Query