DataWorks:SQL Server データソース

単一テーブルのオフライン同期タスクの構成

• 手順については、「コードレス UI でのタスクの構成」および「コードエディタでのタスクの構成」をご参照ください。

• コードエディタのすべてのパラメーターとスクリプトデモの一覧については、「付録：スクリプトデモとパラメーター」をご参照ください。

データベース全体のオフライン読み取り同期タスクの構成

手順については、「データベース全体のリアルタイム同期タスクの構成」をご参照ください。

コードエディタを使用したバッチ同期タスクの構成

コードエディタを使用してバッチ同期タスクを構成する場合、統一されたスクリプトフォーマット要件に基づいて、スクリプト内の関連パラメーターを構成する必要があります。詳細については、「コードエディタでのタスクの構成」をご参照ください。以下の情報は、コードエディタを使用してバッチ同期タスクを構成する際に、データソースに対して構成する必要があるパラメーターについて説明しています。

Reader スクリプトデモ

{
    "type":"job",
    "version":"2.0",// バージョン番号。
    "steps":[
        {
            "stepType":"sqlserver",// プラグイン名。
            "parameter":{
                "datasource":"",// データソース。
                "column":[// フィールド。
                    "id",
                    "name"
                ],
                "where":"",// フィルター条件。
                "splitPk":"",// splitPk を指定すると、指定されたフィールドに基づいてデータがシャーディングされます。
                "table":""// データテーブル。
            },
            "name":"Reader",
            "category":"reader"
        },
        {
            "stepType":"stream",
            "parameter":{},
            "name":"Writer",
            "category":"writer"
        }
    ],
    "setting":{
        "errorLimit":{
            "record":"0"// エラーレコード数。
        },
        "speed":{
            "throttle":true,// throttle を false に設定すると、mbps パラメーターは有効にならず、レート制限は課されません。throttle を true に設定すると、レート制限が課されます。
            "concurrent":1, // 同時ジョブ数。
            "mbps":"12"// レート制限。1 mbps は 1 MB/s に相当します。
        }
    },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
            }
        ]
    }
}

`querySql` パラメーターを使用してクエリを実行する場合は、Reader セクションに次のサンプルスクリプトを使用できます。この例では、SQL Server データソースは `sql_server_source`、クエリ対象のテーブルは `dbo.test_table`、クエリ対象の列は `name` です。

{
    "stepType": "sqlserver",
    "parameter": {
        "connection": [
            {
                "querySql": ["select name from dbo.test_table"],
                "datasource": "sql_server_source"
            }
        ],
        "datasource": "sql_server_source",
        "column": ["name"],
        "where": "",
        "splitPk": "id"
    },
    "name": "Reader",
    "category": "reader"
}

Reader スクリプトパラメーター

• 構成した table、column、および where 情報については、SQL Server Reader がそれらを SQL 文に組み立て、その文を SQL Server データベースに送信します。

• 構成した querySql 情報については、SQL Server がそれを直接 SQL Server データベースに送信します。

Writer スクリプトデモ

{
    "type":"job",
    "version":"2.0",// バージョン番号。
    "steps":[
        {
            "stepType":"stream",
            "parameter":{},
            "name":"Reader",
            "category":"reader"
        },
        {
            "stepType":"sqlserver",// プラグイン名。
            "parameter":{
                "postSql":[],// データ同期タスクの後に実行される SQL 文。
                "datasource":"",// データソース。
                "column":[// フィールド。
                    "id",
                    "name"
                ],
                "table":"",// テーブル名。
                "preSql":[]// データ同期タスクの前に実行される SQL 文。
            },
            "name":"Writer",
            "category":"writer"
        }
    ],
    "setting":{
        "errorLimit":{
            "record":"0"// エラーレコード数。
        },
        "speed":{
            "throttle":true,// throttle を false に設定すると、mbps パラメーターは有効にならず、レート制限は課されません。throttle を true に設定すると、レート制限が課されます。
            "concurrent":1, // 同時ジョブ数。
            "mbps":"12"// レート制限。1 mbps は 1 MB/s に相当します。
        }
    },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
            }
        ]
    }
}

Writer スクリプトパラメーター