Tablestore:OSS への完全データのエクスポート

コードレス 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 の自動シャーディングポリシーが効果的でない場合は、カスタムシャーディングルールを使用することをお勧めします。カスタムシャーディングルールを使用すると、プライマリキー範囲内でシャードキーを指定できます。すべてのプライマリキーではなく、シャードキーのみを設定する必要があります。

• データ宛先: [テキストタイプ] を選択し、対応するパラメーターを設定します。

  • テキストタイプ: 有効値は csv、text、orc、および parquet です。

  • ファイル名 (パスを含む): OSS バケット内のファイルの完全なパス。例: tablestore/resource_table.csv。

  • 列区切り文字: デフォルト値は , です。区切り文字が印刷不可能な文字の場合は、\u001b や \u007c などの Unicode エンコーディングを入力します。

  • ファイルパス: OSS バケット内のファイルのパス。このパラメーターは parquet ファイルタイプの場合にのみ必要です。

  • ファイル名: OSS バケット内のファイルの名前。このパラメーターは parquet 形式のファイルの場合にのみ必要です。

• 宛先フィールドマッピング: ソーステーブルのフィールドを宛先ファイルにマッピングします。各行は JSON 形式のフィールドを表します。

  • ソースフィールド: ソーステーブルのプライマリキーフィールドと属性列。

    プライマリキーに id という名前の int 列と name という名前の string 列が含まれ、属性列に age という名前の int フィールドが含まれている場合、次の設定が例です。

    {"name":"id","type":"int"}
    {"name":"name","type":"string"}
    {"name":"age","type":"int"}

  • 宛先フィールド: ソーステーブルのプライマリキーフィールドと属性列。

    プライマリキーに id という名前の int 列と name という名前の string 列が含まれ、属性列に age という名前の int フィールドが含まれている場合、次の設定が例です。

    {"name":"id","type":"int"}
    {"name":"name","type":"string"}
    {"name":"age","type":"int"}

設定を保存するには、ページの上部にある [保存] をクリックします。

コードエディタ

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

次の例は、宛先ファイルタイプが CSV である設定を示しています。ソーステーブルには、id という名前の int 列と name という名前の string 列を含むプライマリキーがあります。属性列は age という名前の int フィールドです。スクリプトを設定するときは、サンプルスクリプトの datasource、テーブル名 table、および宛先ファイル名 object を実際の値に置き換えてください。

{
    "type": "job",
    "version": "2.0",
    "steps": [
        {
            "stepType": "ots",
            "parameter": {
                "datasource": "source_data",
                "column": [
                    {
                        "name": "id",
                        "type": "int"
                    },
                    {
                        "name": "name",
                        "type": "string"
                    },
                    {
                        "name": "age",
                        "type": "int"
                    }
                ],
                "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": "oss",
            "parameter": {
                "dateFormat": "yyyy-MM-dd HH:mm:ss",
                "datasource": "target_data",
                "writeSingleObject": false,
                "column": [
                    {
                        "name": "id",
                        "type": "int"
                    },
                    {
                        "name": "name",
                        "type": "string"
                    },
                    {
                        "name": "age",
                        "type": "int"
                    }
                ],
                "writeMode": "truncate",
                "encoding": "UTF-8",
                "fieldDelimiter": ",",
                "fileFormat": "csv",
                "object": "tablestore/source_table.csv"
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "setting": {
        "errorLimit": {
            "record": "0"
        },
        "speed": {
            "concurrent": 2,
            "throttle": false
        }
    },
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    }
}

スクリプトを編集した後、ページの上部にある [保存] をクリックします。