基於flink流處理的動態實時電商分析系統02

1:電商分析數據來源mysql      上報服務:從已有的業務系統中獲取數據sql      日誌數據:從已有的業務系統中經過flume獲取數據數據庫      數據庫數據:從關係型數據庫中獲取數據(mysql、oracle)後端 2:獲取不一樣源數據,將數據上傳到kafka消息隊列中。oracle 3:flink中kafka消息隊列中獲取數據,對數據級別進行處理框架     實時處理、批處理o
相關文章
相關標籤/搜索