1 作業
1.1 新建一個作業
通過使用Kettle工具,創建一個作業,并添加Start控制元件、發送郵件控制元件、成功控制元件以及作業跳連接線,具體如圖1所示,
圖1 創建作業
1.2 配置start控制元件
雙擊“Start”控制元件,進入“作業定時調度”界面,單擊“型別”處的下拉框,選擇“時間間隔”定時,并設定以秒計算的間隔是10,以分鐘計算的間隔是0(即作業運行10秒后發送郵件),如圖2所示,

圖2 start配置
1.3 發送郵件設定
雙擊“發送郵件”控制元件,進入“發送郵件”界面雙擊“發送郵件”控制元件,進入“發送郵件”界面,在“地址”選項卡中,添加收件人和發件人的相關資訊,如圖3所示,

圖3 發送郵件設定
1.4 郵件服務器設定
發件人用的是qq郵箱,設定為SMTP服務器:smtp.qq.com,埠設定為465,然后填入發件人用戶密碼以及郵件密碼,
圖4 服務器配置
服務器配置成功,運行后,出現報錯:Problem while sending message: javax.mail.MessagingException: Could not connect to SMTP host: smtp.qq.com, port: 465, response: -1,
圖5 發送失敗
1.4.1 456埠登錄失敗問題
465埠是為SMTPS(SMTP-over-SSL)協議服務開放的,這是SMTP協議基于SSL安全協議之上的一種變種協議,它繼承了SSL安全協議的非對稱加密的高度安全可靠性,可防止郵件泄露所以要開啟SSL,所以解決辦法有兩種換埠或者開啟SSL驗證開啟SSL驗證如下圖
圖6 服務器設定
圖7 發送成功
2 轉換
2.1 創建轉換
通過使用Kettle工具,創建一個轉換,并添加表輸入控制元件、JavaScript代碼控制元件、插入/更新控制元件以及跳連接線,具體如圖所示,

2.2 配置表輸入控制元件
雙擊“表輸入”控制元件,進入“表輸入”界面,如圖所示,

配置mysql連接,如圖所示,

單擊【獲取SQL查詢陳述句】按鈕,獲取資料表personal_a中的資料

“表輸入”界面配置的最終效果
2.3 配置JavaScript代碼控制元件
雙擊“JavaScript代碼”控制元件,進入“JavaScript代碼”界面

在Java script視窗中,撰寫Java script腳本代碼;單擊【獲取變數】按鈕,在欄位視窗的“改名為”欄位處添加新的欄位名稱username,

2.4 配置插入/更新控制元件
雙擊“插入/更新”控制元件,進入“插入/更新”界面,并配置資料庫連接,接著單擊【瀏覽】按鈕,獲取目標表personal_b,隨后單擊【獲取欄位】按鈕,指定查詢資料所需要的關鍵字,即資料表personal_b中的id_b欄位和輸入流中的id欄位,最后單擊【編輯映射】按鈕,配置映射匹配視窗,然后單擊【確定】按鈕,并插入/更新”控制元件的配置效果,




轉載請註明出處,本文鏈接:https://www.uj5u.com/qukuanlian/304064.html
標籤:區塊鏈
