Tablestore:MaxCompute への全量データのエクスポート

コードレス UI (デフォルト)

コードレス UI で次の項目を設定します。

• データソース：ソースと宛先のデータソースを選択します。

• [実行中のリソース]：リソースグループを選択します。 システムは自動的にデータソースの接続性をテストします。

• [データソース]：

  • [テーブル]：ドロップダウンリストからソースデータテーブルを選択します。

  • [プライマリキー範囲分布 (開始)]：データの読み取りを開始するプライマリキー範囲の開始点です。 値は JSON 配列形式である必要があります。 inf_min は負の無限大を表します。

    たとえば、プライマリキーが id という名前の int 型の列と name という名前の string 型の列で構成されている場合、サンプル設定は次のようになります。

    特定のプライマリキー範囲	全量データ
    [ { "type": "int", "value": "000" }, { "type": "string", "value": "aaa" } ]	[ { "type": "inf_min" }, { "type": "inf_min" } ]

  • [プライマリキー範囲分布 (終了)]：データの読み取りを終了するプライマリキー範囲の終点です。 値は JSON 配列形式である必要があります。 inf_max は正の無限大を表します。

    たとえば、プライマリキーが id という名前の int 型の列と name という名前の string 型の列で構成されている場合、サンプル設定は次のようになります。

    特定のプライマリキー範囲	全量データ
    [ { "type": "int", "value": "999" }, { "type": "string", "value": "zzz" } ]	[ { "type": "inf_max" }, { "type": "inf_max" } ]

  • [チャンク構成情報]：JSON 配列形式のカスタム分割設定。 ほとんどの場合、このパラメーターを設定する必要はありません ([] に設定します)。

    Tablestore インスタンスでデータホットスポットが発生し、Tablestore Reader の自動分割ポリシーが効果的でない場合は、カスタム分割ルールを使用することを推奨します。 分割では、プライマリキー範囲内の分割点を指定します。 すべてのプライマリキーではなく、シャードキーのみを設定する必要があります。

• [データ転送先]：次の項目を設定します。 他のパラメーターはデフォルト値のままにするか、必要に応じて変更できます。

  • [本番プロジェクト名]：宛先データソースに関連付けられている MaxCompute プロジェクトの名前が表示されます。

  • [Tunnel リソースグループ]：デフォルトでは、MaxCompute の無料クォータである [共通の転送リソース] が選択されています。 必要に応じて、専用のトンネルリソースグループを選択できます。

  • [テーブル]: 宛先テーブルを選択します。ワンクリックでターゲットテーブルスキーマを生成 をクリックして、宛先テーブルを自動的に生成できます。

  • [パーティション]：同期されたデータは、指定された日付のパーティションに保存されます。 これは、日次増分同期に使用できます。

  • [書き込みモード]：既存のデータをクリアするか、新しいデータを追記するかを選択します。

• [宛先フィールドマッピング]：ソースから宛先テーブルへのフィールドをマッピングします。 システムはソーステーブルのフィールドに基づいてデフォルトのマッピングを提供しますが、必要に応じて変更できます。

設定を完了したら、ページ上部の保存をクリックします。

コードエディター

スクリプトを編集するには、ページの上部にある コードエディタ をクリックします。

次のサンプルスクリプトは、プライマリキーが id という名前の int 型の列と name という名前の string 型の列で構成されているソースデータテーブルを対象としたものです。 属性列は age という名前の int 型のフィールドです。 スクリプトでは、datasource と table パラメーターの値を実際の値に置き換えてください。

{
    "type": "job",
    "version": "2.0",
    "steps": [
        {
            "stepType": "ots",
            "parameter": {
                "datasource": "source_data",
                "column": [
                    {
                        "name": "id",
                        "type": "INTEGER"
                    },
                    {
                        "name": "name",
                        "type": "STRING"
                    },
                    {
                        "name": "age",
                        "type": "INTEGER"
                    }
                ],
                "range": {
                    "begin": [
                        {
                            "type": "inf_min"
                        },
                        {
                            "type": "inf_min"
                        }
                    ],
                    "end": [
                        {
                            "type": "inf_max"
                        },
                        {
                            "type": "inf_max"
                        }
                    ],
                    "split": []
                },
                "table": "source_table",
                "newVersion": "true"
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "odps",
            "parameter": {
                "partition": "pt=${bizdate}",
                "truncate": true,
                "datasource": "target_data",
                "tunnelQuota": "default",
                "column": [
                    "id",
                    "name",
                    "age"
                ],
                "emptyAsNull": false,
                "guid": null,
                "table": "source_table",
                "consistencyCommit": false
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "setting": {
        "errorLimit": {
            "record": "0"
        },
        "speed": {
            "concurrent": 2,
            "throttle": false
        }
    },
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    }
}

スクリプトの編集が完了したら、ページ上部の保存をクリックします。