資料推送節點可將Data Studio商務程序中其他節點產生的資料查詢結果,通過建立資料推送目標,將資料推送至DingTalk群、飛書群、企業微信群、Teams以及郵件,便於團隊成員及時接收和關注最新資料情況。
背景資訊
資料推送節點可以通過節點上下文參數擷取上遊資料查詢SQL節點(賦值節點、Hologres SQL節點、ClickHouse SQL節點等)的輸出參數,並將這些參數以預留位置等形式在推送本文中進行編輯,編輯完成後推送至目標。
上遊資料查詢SQL節點查詢完成後,將結果產生名為
outputs的節點輸出參數。在下遊資料推送節點中通過節點上下文參數擷取
outputs上遊節點輸出參數資訊,並綁定為資料推送節點的節點輸入參數。在資料推送節點配置引用節點輸入參數為推送內容,並設定推送目標後,進行內容推送。
支援的上遊資料查詢SQL節點:
賦值節點:暫不支援MaxCompute SQL資料查詢SQL節點,如有需要,可通過建立賦值節點來查詢MaxCompute相關資料。
其他SQL節點:Hologres SQL節點、ClickHouse SQL節點、EMR Spark SQL節點、EMR Hive節點、MaxCompute Script節點、ADB for PostgreSQL節點和MySQL節點。
前提條件
已建立工作空間。
已使用Serverless資源群組,並綁定到目標DataWorks工作空間。
使用限制
資料推送功能推送至不同對象時的資料大小限制。
推送目標
推送限制
DingTalk
推送資料大小不超過20KB。
飛書
推送資料大小不超過20KB,圖片小於10MB。
企業微信
每個機器人發送的訊息不能超過20條/分鐘。
Teams
推送大小不大於28KB。
郵件
每個資料推送任務僅支援添加一個郵件內文,若已添加郵件內文,則無法再次添加,更多限制可參考所使用郵件服務的SMTP限制。
資料推送支援地區:
華東1(杭州)、華東2(上海)、華北2(北京)、華南1(深圳)、西南1(成都)、中國香港、新加坡、日本(東京)、美國(矽谷)、美國(維吉尼亞)。
進入資料開發
進入DataWorks工作空間列表頁,在頂部切換至目標地區,找到目標工作空間,單擊操作列的,進入Data Studio。
在左側導覽列單擊
表徵圖,進入資料開發頁面。
建立推送鏈路
建立配置資料查詢SQL節點及資料推送節點鏈路。
建立周期工作流程編排,在工作流程中建立資料查詢SQL節點和資料推送節點。
建立資料查詢SQL節點,並在節點中添加需查詢推送的SQL代碼。
配置資料查詢SQL節點。
需在節點右側調度配置中配置計算資源、調度資源群組和同周期依賴資訊(如無上遊節點,可勾選使用工作空間根節點)。輸出參數配置區別如下:
節點類型
配置說明
賦值節點
賦值節點預設存在節點輸出參數,無需配置節點輸出參數。
其他資料查詢SQL節點
其他資料查詢SQL節點沒有預設的節點輸出參數資訊,您需在節點右側調度配置的節點上下文參數中找到節點輸出參數,單擊添加賦值參數,才能將當前查詢結果通過參數傳遞到下遊資料推送節點。
已建立資料推送節點,並配置引用資料查詢SQL節點為上遊節點。
單擊調度配置,在根據節點名稱單擊添加,將上面建立的資料查詢SQL節點添加為資料推送節點的上遊節點。
在選擇建立的Serverless資源群組。
在單擊添加參數,將資料查詢SQL節點的輸出參數作為取值來源添加為資料推送節點的輸入參數。
配置推送目標及內容
在資料推送節點編輯頁面中,自訂推送標題,並配置推送目標及本文內容。
配置推送目標
在資料推送目標選擇目標源。
若目標源不存在,可單擊建立資料推送目標。也可在資料服務中設定資料推送目標。
說明如需修改資料推送目標,僅支援在資料服務的資料推送中進行相應修改。
進入建立推送目標頁面,根據以下資訊建立資料推送目標。
建立DingTalk、飛書、企業微信及Teams推送目標
參數
配置說明
資料推送目標
選擇DingTalk、飛書、企業微信或Teams。
目標名稱
可根據業務需求進行自訂。
Webhook
根據所選的資料推送目標,擷取並配置對應的Webhook資訊。
飛書機器人Webhook擷取方式可參見:飛書Webhook觸發器配置。
Teams Webhook擷取方式可參見:使用Microsoft Teams工作流程建立傳入Webhook。
建立郵箱推送目標
參數
配置說明
資料推送目標
選擇郵件。
SMTP Host
SMTP伺服器的地址,用於發送郵件。
SMTP Port
SMTP伺服器的連接埠號碼,用於串連郵件伺服器。預設為465,可手動修改。
發信地址
郵件發送地址。
發信暱稱
非必填,自訂發信人暱稱。
SMTP帳號
用於登入SMTP伺服器的郵箱帳號。
SMTP密碼
用於驗證SMTP帳號身份的密碼。
接收地址
郵件接收方的郵箱地址,多個地址可用逗號分隔。
配置推送本文
可通過Markdown、表格、郵件內文三種方式配置本文資訊。
資料推送本文中的Markdown可以直接使用資料推送節點的節點輸入參數的參數名作為預留位置
${節點輸入參數名},擷取上遊輸出的參數。資料推送本文中的表格,可通過上遊資料查詢SQL節點的欄位名作為關聯參數擷取資料。
DataWorks資料推送中,支援在推送內容中添加郵件內文,編輯郵件內文內容時,需注意以下事項:
每個資料推送任務僅支援添加一個郵件內文。
郵件內文僅在推送目標為郵件時進行渲染此本文內容,推送目標非郵件時,郵件內文將會在Webhook推送的訊息中被隱藏。
調試運行資料推送
配置完成後,儲存資料查詢SQL節點和資料推送節點後,您可單擊工作流程上方工具列中的
表徵圖,調試運行資料推送任務。
表徵圖喚起發布流程,通過該流程將任務發布至生產環境。專案目錄下的節點只有在發布至生產環境後,才會進行周期性調度。