Tablestore:オフラインデータのバッチ書き込み

前提条件

• OTSClientインスタンスが初期化されていること。詳細については、OTSClientインスタンスの初期化を参照してください。

• データテーブルが作成されていること。詳細については、データテーブルの作成を参照してください。

パラメーター

例

次のサンプルコードは、オフラインデータをデータテーブルにバッチ書き込みする方法の例を示しています。

private static void bulkImport(SyncClient client, String start, String end){
    // bulkImportRequestを作成します。
    // データテーブルの名前を指定します。
    String tableName = "<TABLE_NAME>"; 
    BulkImportRequest bulkImportRequest = new BulkImportRequest(tableName);

    // データテーブルに書き込むデータを指定するために、rowChangesを作成します。
    List<RowChange> rowChanges = new ArrayList<RowChange>();
    for (Integer i = Integer.valueOf(start); i <= Integer.valueOf(end); i++){
        PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
        primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(String.valueOf(i)));
        PrimaryKey primaryKey = primaryKeyBuilder.build();
        RowPutChange rowChange = new RowPutChange(tableName,primaryKey);
        rowChange.addColumn(new Column("DC1", ColumnValue.fromString(i.toString())));
        rowChange.addColumn(new Column("DC2", ColumnValue.fromString(i.toString())));
        rowChange.addColumn(new Column("DC3", ColumnValue.fromString(i.toString())));
        rowChanges.add(rowChange);
    }

    bulkImportRequest.addRowChanges(rowChanges);
    // bulkImportResponseを取得します。
    BulkImportResponse bulkImportResponse = client.bulkImport(bulkImportRequest);
  
    List<BulkImportResponse.RowResult> succeedRows = new ArrayList<BulkImportResponse.RowResult>();
    List<BulkImportResponse.RowResult> failedRows = new ArrayList<BulkImportResponse.RowResult>();
    bulkImportResponse.getResult(succeedRows, failedRows);

    for (int i = 0; i < succeedRows.size(); i++){
        System.out.println(succeedRows.get(i).getConsumedCapacity().getCapacityDataSize().jsonize());
    }
    for (int i = 0; i < failedRows.size(); i++){
        System.out.println(failedRows.get(i).getError().getCode());
        System.out.println(failedRows.get(i).getError().getMessage());
    }
}

FAQ

• SDKを使用しているときに「Validate PK size fail」例外が発生した場合はどうすればよいですか？

• SDKを使用しているときに「Validate PK name fail」例外が発生した場合はどうすればよいですか？

• プライマリキー列でサポートされているデータ型に関連するエラーが発生した場合はどうすればよいですか？

関連情報

• API操作の詳細については、BulkImportを参照してください。

• オフラインデータをバッチインポートするための操作の呼び出し方法の詳細については、BulkImportRequest.javaおよびBulkImportResponse.javaを参照してください。

• データテーブルにデータを書き込んだ後、ビジネス要件に基づいてテーブル内のデータを読み取ったり削除したりできます。

  • データテーブル内のデータを読み取る場合は、オフラインデータをバッチ読み取りしたり、基本データを読み取ったりできます。詳細については、オフラインデータのバッチ読み取りおよびデータの読み取りを参照してください。

  • データテーブル内のデータを削除する場合は、DeleteRowまたはBatchWriteRow操作を呼び出すことができます。詳細については、データの削除を参照してください。

• 次の方法を使用して、データテーブルにデータを書き込むこともできます。

  • PutRow、UpdateRow、またはBatchWriteRow操作を呼び出します。詳細については、データの書き込みを参照してください。

  • DataWorksやDataXなどのツールを使用して、他のデータソースからTablestoreにデータを同期します。詳細については、データ統合を参照してください。