DataWorks：ApsaraDB For OceanBase資料來源

離線讀

• ApsaraDB For OceanBase包括Oracle和MySQL兩種租戶模式，您在配置where資料過濾條件、column中的函數列時，需要符合對應租戶模式的SQL文法約束，否則SQL語句可能執行失敗。

• 支援閱讀檢視表。

• 在離線讀取OceanBase資料的過程中，請避免對正在同步的資料進行修改操作，否則可能會導致資料品質問題（如資料重複或資料丟失）。

• 若資料來源配置為按分區讀取，則訪問該資料來源的帳號需要system許可權。

離線寫

• 建議您使用batch的方式批量寫入資料，當行數累計到預定閾值時，再發起寫入請求。

• ApsaraDB For OceanBase包括Oracle和MySQL兩種租戶模式，您在配置preSql、postSql時，需要符合對應租戶模式的SQL文法約束，否則SQL語句可能執行失敗。

即時讀

OceanBase為Distributed Relational Database Service，可以將物理分布不同的多個資料庫上的資料整合為一個完整的邏輯資料庫。但即時同步OceanBase的資料至AnalyticDB for MySQL，目前僅支援同步單個物理庫的資料，不支援同步邏輯庫資料。

配置白名單

將Serverless資源群組或獨享Data Integration資源群組所在的VPC網段添加至OceanBase的白名單中，詳情請參見添加白名單。

建立帳號並配置帳號許可權

您需要規劃一個資料庫的登入賬戶用於後續執行操作，此帳號需要擁有OceanBase的相關操作許可權，詳情請參見建立帳號。

單表離線同步任務配置指導

• 操作流程請參見嚮導模式配置、指令碼模式配置。

• 指令碼模式配置的全量參數和指令碼Demo請參見下文的附錄：指令碼Demo與參數說明。

整庫即時同步任務配置指導

操作流程請參見DataStudio側即時同步任務配置。

單表或整庫全增量（即時）讀同步配置指導

操作流程請參見整庫即時同步任務配置。

離線任務指令碼配置方式

如果您配置離線任務時使用指令碼模式的方式進行配置，您需要按照統一的指令碼格式要求，在任務指令碼中編寫相應的參數，詳情請參見指令碼模式配置，以下為您介紹指令碼模式下資料來源的參數配置詳情。

Reader指令碼Demo

{
    "type": "job",
    "steps": [
        {
            "stepType": "apsaradb_for_OceanBase", //外掛程式名
            "parameter": {
                "datasource": "", //資料來源名
                "where": "",
                "column": [ //欄位
                    "id",
                    "name"
                ],
                "splitPk": ""
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "stream",
            "parameter": {
                "print": false,
                "fieldDelimiter": ","
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "version": "2.0",
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    },
    "setting": {
        "errorLimit": {
            "record": "0" //錯誤記錄數
        },
        "speed": {
            "throttle": true, //當throttle值為false時，mbps參數不生效，表示不限流；當throttle值為true時,表示限流。
            "concurrent": 1, //作業並發數
            "mbps":"12"//限流，此處1mbps = 1MB/s。
        }
    }
}

Reader指令碼參數

Writer指令碼Demo

{
    "type":"job",
    "version":"2.0",//版本號碼。
    "steps":[
        {
            "stepType":"stream",
            "parameter":{},
            "name":"Reader",
            "category":"reader"
        },
        {
            "stepType":"apsaradb_for_OceanBase",//外掛程式名。
            "parameter":{
                "datasource": "資料來源名",
                "column": [//欄位。
                    "id",
                    "name"
                ],
                "table": "apsaradb_for_OceanBase_table",//表名。
                "preSql": [ //執行資料同步任務之前率先執行的SQL語句。
                    "delete from @table where db_id = -1"
                ],
                "postSql": [//執行資料同步任務之後率先執行的SQL語句。
                    "update @table set db_modify_time = now() where db_id = 1"
                ],
                "obWriteMode": "insert",
            },
            "name":"Writer",
            "category":"writer"
        }
    ],
    "setting":{
        "errorLimit":{
            "record":"0"//錯誤記錄數。
        },
        "speed":{
            "throttle":true,//當throttle值為false時，mbps參數不生效，表示不限流；當throttle值為true時,表示限流。
            "concurrent":1, //作業並發數。
            "mbps":"12"//限流，此處1mbps = 1MB/s。
        }
    },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
            }
        ]
    }
}

Writer指令碼參數