行の一括書き込み
Catalyst では、Data Store 内の特定のテーブルに対して一括書き込みジョブを実行できます。一括書き込み操作は、Stratus にアップロードされた CSV ファイルから数千のレコードを取得し、特定のテーブルに挿入します。
テーブルは、作成時に Catalyst によって生成される一意のtable IDで参照されます。書き込み操作を実行するカラムは、一意のcolumn IDで参照されます。
Note: 一括書き込み操作を実行するには、まず必要なデータを CSV ファイルとして Stratus にアップロードする必要があります。
書き込みジョブ中、ファイルは以下の属性を使用して参照されます:
- bucketName: オブジェクトが格納されているバケットの名前です。
- objectKey: 必要なオブジェクトのパスまたはオブジェクト URLを含めることができます。
- versionID: バケットでバージョニングが有効になっている場合、ファイルの特定の versionID がこの属性に格納されます。
| 使用メソッド | 説明 |
|---|---|
| bulkWrite.createJob(objectDetails, {find_by,fk_mapping,operation}) | 特定のテーブルに新しい一括書き込みジョブを作成します。 | bulkWrite.status(job ID) | 一括書き込み操作のステータスを取得します。 |
| bulkWrite.result(job ID) | 一括書き込み操作の結果を取得します。 |
以下の SDK スニペットをコピーして、特定のテーブルに対して一括書き込みジョブを実行します。
copy
let datastore = app.datastore(); // datastoreインスタンスを取得
const bulkWrite = datastore.table('sampleTable').bulkJob('write');
const objectDetails = {
"bucket_name": "zylker14266",
"object_key": "emp_records.csv",
"version_id": "64832huidksnd83"
};
// 一括書き込みジョブを作成する
const bulkWriteJob = await bulkWrite.createJob(objectDetails, {
find_by: 'EmpID',
fk_mapping: [
{ local_column: 'EmployeeID', reference_column: 'EmpID' },
{ local_column: 'DepartmentID', reference_column: 'DeptID' }
],
operation: 'insert'
});
// 一括書き込みステータスを取得する
await bulkWrite.getStatus(bulkWriteJob.job_id);
// 一括書き込み結果を取得する
await bulkWrite.getResult(bulkWriteJob.job_id);
Note: 一度に最大 100,000 行を書き込むことができます。
最終更新日 2026-03-30 13:40:30 +0530 IST
Yes
No
Thank you for your feedback!
Send your feedback to us
Skip
Submit