行の一括書き込み
Catalystでは、Data Storeに存在する特定のテーブルに対して一括書き込みジョブを実行できます。一括書き込み操作は、StratusにアップロードされたCSVファイルから数千件のレコードを取得し、特定のテーブルに挿入します。
テーブルは、作成時にCatalystが生成する一意のtable IDで参照されます。書き込み操作を実行するカラムは、一意のcolumn IDで参照されます。
注意： 一括書き込み操作を実行するには、まず必要なデータをCSVファイルとしてStratusにアップロードする必要があります。
| パラメータ名 | データ型 | 定義 |
|---|---|---|
| tableID | String | 必須パラメータです。データを書き込むテーブルのIDを保持します。 |
| find_by | String | 必須パラメータです。データを書き込むカラムの名前を保持します。 |
| fk_mapping | Array | 必須パラメータです。local_columnとreference_columnの詳細を保持します。 |
| operation | String | 必須パラメータです。このパラメータの値はinsertである必要があります。 |
| object_details | JSON Object |
特定のテーブルに対して一括書き込みジョブを実行するには、以下のSDKスニペットをコピーしてください。以下で使用されているコンポーネントインスタンスdatastore_serviceの詳細については、こちらのヘルプセクションを参照してください。
copy
datastore_service = app.datastore()
bulk_write = datastore_service.table("Sample").bulk_write()
object_details = {
"bucket_name": "zcstratus12345",
"object_key": "sample.csv",
"version_id": "64832huidksnd83"
}
#バルク書き込みジョブを作成する
bulk_write_job = bulk_write.create_job(object_details, {
"find_by": "S1",
"fk_mapping": [
{"local_column": "EmployeeID", "reference_column": "EmpId"},
{"local_column": "DepartmentID", "reference_column": "DepId"}
],
"operation": "insert"
})
#バルク書き込みのステータスを取得する
status = bulk_write.get_status('6759000000167103')
#バルク書き込みの結果を取得する
result = bulk_write.get_result('6759000000167103')
注意： 一度に最大100,000行を書き込むことができます。
情報： 上記の操作を実行するために必要な権限レベルを確認するには、SDKスコープの表を参照してください。
最終更新日 2026-03-30 13:40:30 +0530 IST
Yes
No
Thank you for your feedback!
Send your feedback to us
Skip
Submit