一括行書き込み

# 一括行書き込み

Catalystでは、{{%link href="/ja/cloud-scale/help/data-store/introduction" %}}Data Store{{%/link%}}の特定のテーブルに対して一括書き込みジョブを実行できます。一括書き込み操作は、{{%link href="/ja/cloud-scale/help/stratus/introduction/" %}}Stratus{{%/link%}}にアップロードされたCSVファイルから数千のレコードを取得し、特定のテーブルに挿入できます。

テーブルは一意の{{%link href="/ja/cloud-scale/help/data-store/tables/" %}}テーブルID{{%/link%}}で参照されます。書き込み操作を実行するカラムは、一意の{{%link href="/ja/cloud-scale/help/data-store/columns/#column-characteristics" %}}カラムID{{%/link%}}で参照されます。

{{%note%}}{{%bold%}}Note:{{%/bold%}} 一括書き込み操作を実行するには、必要なデータをCSVファイルとしてStratusに{{%link href="/ja/cloud-scale/help/stratus/objects/upload-object/" %}}最初にアップロード{{%/link%}}する必要があります。{{%/note%}}

書き込みジョブ中、ファイルは以下の属性を使用して参照されます：

* {{%badge%}}bucketName{{%/badge%}}: オブジェクトが保存されている{{%link href="/ja/cloud-scale/help/stratus/buckets/name-bucket/#ideal-practices-to-name-a-bucket" %}}バケットの名前{{%/link%}}です。
* {{%badge%}}objectKey{{%/badge%}}: 必要なオブジェクトの{{%link href="/ja/cloud-scale/help/stratus/objects/introduction/#path" %}}パス{{%/link%}}または{{%link href="/ja/cloud-scale/help/stratus/objects/introduction/#object-url" %}}Object URL{{%/link%}}を含めることができます。
* {{%badge%}}versionID{{%/badge%}}: バケットで{{%link href="/ja/cloud-scale/help/stratus/stratus-config/general-settings/#versioning" %}}バージョニング{{%/link%}}が有効な場合、ファイルの特定のversionIDがこの属性に保存されます。

これらの詳細は{{%badge%}}objectDetails{{%/badge%}}という名前のJSONオブジェクトとして解決し、{{%badge%}}setObjectDetails(){{%/badge%}}メソッドに渡す必要があります。

CatalystはJava SDKの一括書き込みに対して以下のメソッドをサポートしています：

<table class="content-table">
	<thead>
		<tr>
			<th>使用メソッド</th>
			<th>説明</th>
		</tr>
	</thead>
	<tbody>
		<tr>
			<td>{{%badge%}}createBulkWriteJob(bulkWriteDetails){{%/badge%}}</td>
			<td>特定のテーブルに対して新しい一括書き込みジョブを作成します。</td>
		</tr>
      <td>{{%badge%}}createInsertBulkWriteJob(table ID, objectDetails){{%/badge%}}</td>
      <td>新しい一括書き込み挿入ジョブを作成します。</td>
    <tr>
      <td>{{%badge%}}createUpsertBulkWriteJob(tableId, objectDetails, column ID){{%/badge%}}</td>
      <td>新しい一括書き込みupsertジョブを作成します。</td>
    </tr>
    <tr>
      <td>{{%badge%}}getBulkWriteJobDetails(jobID){{%/badge%}}</td>
      <td>一括書き込みジョブのステータスと結果を取得します。</td>
    </tr>
	</tbody>
</table>

以下のSDKスニペットをコピーして、特定のテーブルに対して一括書き込みジョブを実行します。

#### サンプルコードスニペット
<br>
{{% panel_without_adjustment header="Package Imports" class="language-java line-numbers" %}}import com.zc.component.object.bulk.ZCBulkWriteServices;
import com.zc.component.object.bulk.ZCDataStoreBulk;
import com.zc.component.object.bulk.result.ZCBulkResult;
import com.zc.component.object.bulk.ZCBucketObjectDetails;
import com.zc.component.object.bulk.ZCBulkWriteDetails {{% /panel_without_adjustment %}}

{{%code class="language-java" scroll="set-scroll" %}}ZCBulkWriteServices bulkWrite = ZCDataStoreBulk.getInstance().getBulkWriteInstance(); 
// 一括書き込みインスタンスを作成する
ZCBulkWriteDetails bulkWriteDetails = ZCBulkWriteDetails.getInstance(); 
// 一括書き込み詳細オブジェクトを作成して入力する
bulkWriteDetails.setTableIdentifier(12096000000642178L);  // Table IDを入力してください
bulkWriteDetails.setObjectDetails(objectDetails);
ZCBulkResult bulkWriteResult = bulkWrite.createBulkWriteJob(bulkWriteDetails); 
// 一括書き込みジョブを作成する
bulkWrite.createInsertBulkWriteJob(12096000000642178L, objectDetails);  // Table IDを入力してください
// 一括書き込み挿入ジョブを作成する
bulkWrite.createUpdateBulkWriteJob(12096000000642178L, objectDetails, 12096000000642900L); // Table IDとColumn IDを入力してください
// 一括書き込み更新ジョブを作成する
bulkWrite.createUpsertBulkWriteJob(12096000000642178L, objectDetails, 12096000000642900L);  // Table IDとColumn IDを入力してください
// 一括書き込みupsertジョブを作成する
bulkWrite.getBulkWriteJobStatus(bulkWriteResult.getJobId()); 
// 一括書き込みジョブのステータスと結果を取得する
{{%/code%}}
<br />
{{%note%}}{{%bold%}}Note:{{%/bold%}} {{%badge%}}createBulkWriteJob(){{%/badge%}}メソッドを使用して同時に書き込める行は最大{{%bold%}}100,000行{{%/bold%}}です。{{%/note%}}

<br />

Catalystでは、Data Storeの特定のテーブルに対して一括書き込みジョブを実行できます。一括書き込み操作は、StratusにアップロードされたCSVファイルから数千のレコードを取得し、特定のテーブルに挿入できます。

テーブルは一意のテーブルIDで参照されます。書き込み操作を実行するカラムは、一意のカラムIDで参照されます。

Note: 一括書き込み操作を実行するには、必要なデータをCSVファイルとしてStratusに最初にアップロードする必要があります。

書き込みジョブ中、ファイルは以下の属性を使用して参照されます：

bucketName: オブジェクトが保存されているバケットの名前です。
objectKey: 必要なオブジェクトのパスまたはObject URLを含めることができます。
versionID: バケットでバージョニングが有効な場合、ファイルの特定のversionIDがこの属性に保存されます。

これらの詳細はobjectDetailsという名前のJSONオブジェクトとして解決し、setObjectDetails()メソッドに渡す必要があります。

CatalystはJava SDKの一括書き込みに対して以下のメソッドをサポートしています：

使用メソッド	説明
createBulkWriteJob(bulkWriteDetails)	特定のテーブルに対して新しい一括書き込みジョブを作成します。
createInsertBulkWriteJob(table ID, objectDetails)	新しい一括書き込み挿入ジョブを作成します。
createUpsertBulkWriteJob(tableId, objectDetails, column ID)	新しい一括書き込みupsertジョブを作成します。
getBulkWriteJobDetails(jobID)	一括書き込みジョブのステータスと結果を取得します。

以下のSDKスニペットをコピーして、特定のテーブルに対して一括書き込みジョブを実行します。

サンプルコードスニペット

Package Imports
copy

         import com.zc.component.object.bulk.ZCBulkWriteServices;
import com.zc.component.object.bulk.ZCDataStoreBulk;
import com.zc.component.object.bulk.result.ZCBulkResult;
import com.zc.component.object.bulk.ZCBucketObjectDetails;
import com.zc.component.object.bulk.ZCBulkWriteDetails 
    

copy

         ZCBulkWriteServices bulkWrite = ZCDataStoreBulk.getInstance().getBulkWriteInstance(); 
// 一括書き込みインスタンスを作成する
ZCBulkWriteDetails bulkWriteDetails = ZCBulkWriteDetails.getInstance(); 
// 一括書き込み詳細オブジェクトを作成して入力する
bulkWriteDetails.setTableIdentifier(12096000000642178L);  // Table IDを入力してください
bulkWriteDetails.setObjectDetails(objectDetails);
ZCBulkResult bulkWriteResult = bulkWrite.createBulkWriteJob(bulkWriteDetails); 
// 一括書き込みジョブを作成する
bulkWrite.createInsertBulkWriteJob(12096000000642178L, objectDetails);  // Table IDを入力してください
// 一括書き込み挿入ジョブを作成する
bulkWrite.createUpdateBulkWriteJob(12096000000642178L, objectDetails, 12096000000642900L); // Table IDとColumn IDを入力してください
// 一括書き込み更新ジョブを作成する
bulkWrite.createUpsertBulkWriteJob(12096000000642178L, objectDetails, 12096000000642900L);  // Table IDとColumn IDを入力してください
// 一括書き込みupsertジョブを作成する
bulkWrite.getBulkWriteJobStatus(bulkWriteResult.getJobId()); 
// 一括書き込みジョブのステータスと結果を取得する

    

Note: createBulkWriteJob()メソッドを使用して同時に書き込める行は最大100,000行です。

最終更新日 2026-03-30 13:40:30 +0530 IST

Yes

Thank you for your feedback!

Send your feedback to us

Skip

Submit

Data Store