該解決方案有何用途？
該解決方案通過使用分布式消息服務 Kafka版獲取電商平臺實時寫入的商品的訂單信息，使用數(shù)據(jù)湖探索 DLI Flink SQL作業(yè)對業(yè)務數(shù)據(jù)進行處理分析，實時統(tǒng)計每種渠道的相關指標，輸出存儲到云數(shù)據(jù)庫 RDS中，并在數(shù)據(jù)可視化 DLV大屏展示。從而幫助電商平臺統(tǒng)計每天各平臺的實時訪問數(shù)據(jù)量、訂單數(shù)、訪問人數(shù)等等指標，并在顯示大屏上實時展示相關數(shù)據(jù)，方便電商平臺及時了解數(shù)據(jù)變化，有針對性地調整營銷策略。適用于通過web方式訪問、通過app的方式訪問、通過微信小程序的方式訪問等等電商線上購物。
方案架構
該解決方案基于數(shù)據(jù)湖探索 DLI完成電商業(yè)務實時數(shù)據(jù)的分析處理，獲取各個渠道的銷售匯總數(shù)據(jù)。
架構描述
該解決方案會部署如下資源：
1. 創(chuàng)建一臺云數(shù)據(jù)庫 RDS for MySQL實例，用于存儲統(tǒng)計的訂單指標數(shù)據(jù)，從而展示在數(shù)據(jù)可視化DLV大屏。
2. 創(chuàng)建分布式消息服務 Kafka版專享版實例，并創(chuàng)建 Topic，用于電商平臺寫入業(yè)務數(shù)據(jù)，為用戶提供便捷高效的消息隊列。
3. 創(chuàng)建數(shù)據(jù)湖探索 DLI增強型跨源隊列，并創(chuàng)建Flink作業(yè)，用于分析和處理電商平臺的業(yè)務數(shù)據(jù)。
4. 創(chuàng)建一個對象存儲服務 OBS桶，用于用戶上傳業(yè)務數(shù)據(jù)表csv文件。
5. 使用函數(shù)工作流 FunctionGraph創(chuàng)建一個函數(shù)，通過OBS觸發(fā)器，實現(xiàn)將用戶上傳至OBS桶中的業(yè)務數(shù)據(jù)寫入Kafka，同時在RDS創(chuàng)建數(shù)據(jù)結果表模板。
用戶可以購買并配置數(shù)據(jù)可視化 DLV大屏，快速定制數(shù)據(jù)大屏，將RDS中分析結果數(shù)據(jù)展示在大屏中。
架構描述
該解決方案會部署如下資源：
1. 創(chuàng)建一臺云數(shù)據(jù)庫 RDS for MySQL實例，用于存儲統(tǒng)計的訂單指標數(shù)據(jù)，從而展示在數(shù)據(jù)可視化DLV大屏。
2. 創(chuàng)建分布式消息服務 Kafka版專享版實例，并創(chuàng)建 Topic，用于電商平臺寫入業(yè)務數(shù)據(jù)，為用戶提供便捷高效的消息隊列。
3. 創(chuàng)建數(shù)據(jù)湖探索 DLI增強型跨源隊列，并創(chuàng)建Flink SQL作業(yè)，用于分析和處理電商平臺的業(yè)務數(shù)據(jù)。
4. 創(chuàng)建一個對象存儲服務 OBS桶，用于用戶上傳業(yè)務數(shù)據(jù)csv文件。
5. 使用函數(shù)工作流 FunctionGraph創(chuàng)建一個函數(shù)，通過OBS觸發(fā)器，實現(xiàn)將用戶上傳至OBS桶中的業(yè)務數(shù)據(jù)寫入Kafka，同時在RDS創(chuàng)建數(shù)據(jù)結果表模板。
用戶可以購買并配置數(shù)據(jù)可視化 DLV大屏，快速定制數(shù)據(jù)大屏，將RDS中分析結果數(shù)據(jù)展示在大屏中。