1、數(shù)據(jù)同步需求

　　自動(dòng)識(shí)別源表中數(shù)據(jù)所歸屬的分公司進(jìn)行自動(dòng)同步，即將源表中A分公司的數(shù)據(jù)同步到A公司數(shù)據(jù)庫表，源表中B分公司的數(shù)據(jù)同步到B公司數(shù)據(jù)庫表，以此類推。

　　2、實(shí)現(xiàn)思路

　　一般ETL工具實(shí)現(xiàn)思路：建立同步到A分公司流程，抽取源表數(shù)據(jù)->過濾出A分公司->將過濾后的數(shù)據(jù)加載到A公司數(shù)據(jù)庫表。再建立同步到B分公司流程，有多少個(gè)分公司就建立多少條流程。

　　缺點(diǎn)：開發(fā)工作量隨分公司數(shù)量成正比，當(dāng)所有表存在變更時(shí)需要對(duì)所有流程進(jìn)行修改，日常運(yùn)行監(jiān)控、維護(hù)困難。

　　優(yōu)點(diǎn)：當(dāng)某個(gè)分公司數(shù)據(jù)庫表有變更時(shí)，只需要維護(hù)對(duì)應(yīng)的流程，不影響其他流程。

　　Restcloud ETL工具實(shí)現(xiàn)思路：創(chuàng)建1個(gè)主流程、1個(gè)子流程，主流程用于獲取需要同步的分公司并作為變量參數(shù)，并逐個(gè)輸出給子流程。子流程獲取主流程的變量參數(shù)作為數(shù)據(jù)過濾條件及動(dòng)態(tài)獲取對(duì)應(yīng)目標(biāo)數(shù)據(jù)源。

　　主流程工作原理：通過執(zhí)行SQL腳本做Groupby分組計(jì)算出要同步的分公司并作為變量參數(shù)，利用【逐行拆分輸出組件】控制循環(huán)調(diào)用子流程，逐個(gè)將變量參數(shù)傳送給子流程。

　　創(chuàng)建1個(gè)子流程，獲取主流程輸出數(shù)據(jù)作為參數(shù)條件抽取需要同步的數(shù)據(jù)，及需要調(diào)取的數(shù)據(jù)源。

　　缺點(diǎn)：存在一定限制，如要求所有分公司的表名稱、表結(jié)構(gòu)相同。

　　優(yōu)點(diǎn)：工作量小，日常運(yùn)行監(jiān)控、維護(hù)便捷。

　　3、示例

　　3.1建立主流程

　　3.1.1配置【執(zhí)行SQL腳本】組件

　　配置基本屬性：指定讀取源表的數(shù)據(jù)源

　　配置過濾條件：此處無需過濾數(shù)據(jù)，下一步跳過該項(xiàng)配置

　　配置SQL語句：編寫SQL已經(jīng)做Groupby分組計(jì)算出要同步的分公司并作為變量參數(shù)。

　　如果有存儲(chǔ)分公司名單與數(shù)據(jù)源對(duì)應(yīng)代碼表，此處可以直接用【表輸入】組件獲取

　　保存退出，完成【執(zhí)行SQL腳本】配置。

　　3.1.2配置【逐行拆分輸出】組件

　　3.1.3配置【子任務(wù)】組件

　　選擇已配置后的子流程，選擇數(shù)據(jù)流入(接收主流程輸出數(shù)據(jù))

　　3.2建立子流程

　　3.2.1配置【庫表輸入】

　　配置基本屬性：指定讀取源表的數(shù)據(jù)源

　　配置SQL語句：增加數(shù)據(jù)過濾條件參數(shù)

　　配置輸入字段：系統(tǒng)自動(dòng)讀取，無需配置。直接點(diǎn)擊保存退出完成【庫表輸入】組件配置。

　　3.2.2配置【執(zhí)行Java腳本】

　　配置基本屬性：無需修改配置，直接下一步。

　　配置Java代碼：代碼邏輯(通過判斷輸入的參數(shù)值獲取對(duì)應(yīng)同步的目標(biāo)數(shù)據(jù)源)

　　如輸入?yún)?shù)A，對(duì)應(yīng)同步到數(shù)據(jù)源“Stephen_MySql01”, Stephen_MySql01為配置A公司的的數(shù)據(jù)源名稱。

　　直接點(diǎn)擊編譯并保存，退出完成【執(zhí)行Java腳本】組件配置

　　3.2.3配置【庫表輸出】

　　配置基本屬性：指定讀取源表的數(shù)據(jù)源(此處根據(jù)參數(shù)動(dòng)態(tài)獲取指定輸出數(shù)據(jù)源)

　　配置輸出字段：根據(jù)目標(biāo)表的字段情況，手工點(diǎn)擊新增列完成輸出字段配置。

　　由于數(shù)據(jù)源是動(dòng)態(tài)原因，流程在不運(yùn)行情況下無法獲取到對(duì)應(yīng)表，因此無法自動(dòng)獲取表結(jié)構(gòu)。

　　輸出字段配置完成后，點(diǎn)擊保存完成【庫表輸出】配置。

　　3.3測(cè)試

　　3.3.1用例數(shù)據(jù)

　　源表數(shù)據(jù)如下：

　　3.3.2效果要求：

　　address為“廣州”的數(shù)據(jù)同步到mysql數(shù)據(jù)庫

　　address為“上海”的數(shù)據(jù)同步到SQL serve數(shù)據(jù)庫

　　address為“北京”的數(shù)據(jù)同步到Postgres數(shù)據(jù)庫

　　3.3.3運(yùn)行結(jié)果

　　數(shù)據(jù)庫結(jié)果

　　標(biāo)識(shí)為“廣州”的，就將該條數(shù)據(jù)插入到mysql數(shù)據(jù)庫

　　標(biāo)識(shí)為“上海”的，就將該條數(shù)據(jù)插入到SQL server數(shù)據(jù)庫

　　標(biāo)識(shí)為“北京”的，就將該條數(shù)據(jù)插入到postgres數(shù)據(jù)庫

（免責(zé)聲明：本網(wǎng)站內(nèi)容主要來自原創(chuàng)、合作伙伴供稿和第三方自媒體作者投稿，凡在本網(wǎng)站出現(xiàn)的信息，均僅供參考。本網(wǎng)站將盡力確保所提供信息的準(zhǔn)確性及可靠性，但不保證有關(guān)資料的準(zhǔn)確性及可靠性，讀者在使用前請(qǐng)進(jìn)一步核實(shí)，并對(duì)任何自主決定的行為負(fù)責(zé)。本網(wǎng)站對(duì)有關(guān)資料所引致的錯(cuò)誤、不確或遺漏，概不負(fù)任何法律責(zé)任。
任何單位或個(gè)人認(rèn)為本網(wǎng)站中的網(wǎng)頁或鏈接內(nèi)容可能涉嫌侵犯其知識(shí)產(chǎn)權(quán)或存在不實(shí)內(nèi)容時(shí)，應(yīng)及時(shí)向本網(wǎng)站提出書面權(quán)利通知或不實(shí)情況說明，并提供身份證明、權(quán)屬證明及詳細(xì)侵權(quán)或不實(shí)情況證明。本網(wǎng)站在收到上述法律文件后，將會(huì)依法盡快聯(lián)系相關(guān)文章源頭核實(shí)，溝通刪除相關(guān)內(nèi)容或斷開相關(guān)鏈接。 ）