本文為您介紹如何通過DataWorks的數據集成功能,遷移Oracle數據至MaxCompute。
前提條件
背景信息
本文需要使用DataWorks Oracle Reader讀取Oracle中的測試數據,詳情請參見Oracle Reader。
準備Oracle測試數據
進入Oracle圖形化操作界面,新建表DTSTEST.GOOD_SALE,主要包括create_time、category、brand、buyer_id、trans_num、trans_amount、click_cnt這7列。
插入測試數據,本文中手動插入數據如下。
insert into good_sale values('28-12月-19','廚具','品牌A','hanmeimei','6','80.6','4'); insert into good_sale values('21-12月-19','生鮮','品牌B','lilei','7','440.6','5'); insert into good_sale values('29-12月-19','衣服','品牌C','lily','12','351.9','9'); commit;
插入數據后,執行如下語句查看表數據。
select * from good_sale;
通過DataWorks將數據從Oracle遷移至MaxCompute
登錄DataWorks控制臺,切換至目標地域后,單擊左側導航欄的 ,在下拉框中選擇對應工作空間后單擊進入數據開發。
在數據開發頁面創建目標表,用于接收從Oracle遷移的數據。
右鍵單擊已創建的業務流程,選擇 。
在新建表頁面,配置表的基本信息。
單擊表編輯頁面上方的DDL模式。
在DDL對話框,輸入建表語句,單擊生成表結構。
CREATE TABLE good_sale ( create_time string, category string, brand string, buyer_id string, trans_num bigint, trans_amount double, click_cnt bigint ) ;
在建表過程中,需要考慮Oracle數據類型與MaxCompute數據類型的映射,Oracle Reader支持的數據類型請參見類型轉換列表。
單擊提交到生產環境。
新建Oracle數據源,詳情請參見配置Oracle數據源。
創建離線同步節點。
進入數據開發頁面,右鍵單擊指定業務流程,選擇 。
在新建節點對話框中,配置節點基本信息,并單擊確認。
成功創建數據同步節點后,選擇數據源為您剛剛添加的Oracle數據源,表為您剛剛創建的測試表,選擇同名映射。其它參數保持默認配置。
單擊圖標運行代碼。
您可以在運行日志查看運行結果。
驗證結果
右鍵單擊業務流程,選擇 。
在新建節點對話框中配置節點基本信息,并單擊確認。
在ODPS SQL節點編輯頁面輸入如下語句。
--查看是否成功寫入MaxCompute。 select * from good_sale;
單擊圖標運行代碼。
您可以在運行日志查看運行結果。