【🔒 Message Queue - Kafka】串流式的SQL - ksqlDB

KSQL引擎， 串流形式的SQL？ 聽了應該霧煞煞吧！ 想像一下傳統的SQL， 是不是一個指令一個動作， 每發送一個指令之後就必須等到查詢/寫入…動作皆完成之後才回應， 然而在Streaming的應用上這顯然不太可行， 每分每秒都有資料流入的情境下， 資料的狀態都在變化， 假設我們一個指令一個動作， 那麼得到的結果肯定是失準的， 因此對於「串流」來說， 就必須要能夠即時的處理， 而KSQL正好可以對於「串流」的資料做即時的事件偵測與處理， 他讓我們使用起來像SQL一樣簡單。

除了特定條件監控之外， 還能夠即時分析產生報表， 對於客戶體驗來說更加的豐富了， 不像以往都是一來一往的請求/回應， 我們直接用一張圖來說明串流及ksqlDB的運作流程就比較清楚了， 底下的流程是一個串流的過濾器， 透過ksql語法幫我們攔截串流的每一筆訊息， 並進行相對應的處理。