行の一括読み取り
Catalystでは、Data Storeに存在する特定のテーブルに対して一括読み取りジョブを実行できます。
以下のSDKスニペットでは、一括読み取りジョブが特定のテーブルから数千件のレコードを読み取り、ジョブが成功した場合に読み取り操作の結果を含むCSVファイルを生成します。テーブルは一意のTable IDで参照されます。
以下で使用されているコンポーネントインスタンスdatastore_serviceの詳細については、こちらのヘルプセクションを参照してください。
| パラメータ名 | データ型 | 定義 |
|---|---|---|
| criteria | Array | 必須パラメータです。行を読み取る条件を保持します。 |
| page | Numeric | 必須パラメータです。読み取るページ行数を保持します。 |
| select_columns | Array | 必須パラメータです。読み取る特定のカラムを保持します。 |
特定のテーブルに対して一括読み取りジョブを実行するには、以下のSDKスニペットをコピーしてください。
copy
#一括読み取り
datastore_service = app.datastore()
bulk_read = datastore_service.table("sampleTable").bulk_read()
#一括読み取りジョブを作成する
bulk_read_Job = bulk_read.create_job({
"criteria": {
"group_operator": 'or',
"group": [
{
"column_name": 'Department',
"comparator": 'equal',
"value": 'Marketing'
},
{
"column_name": 'EmpId',
"comparator": 'greater_than',
"value": '1000'
},
{
"column_name": 'EmpName',
"comparator": 'starts_with',
"value": 'S'
}
]
},
"page": 1,
"select_columns": ['EmpId', 'EmpName', 'Department']
})
#一括読み取りステータスを取得する
status = bulk_read.get_status(bulk_read_Job['job_id'])
#一括読み取り結果を取得する
result = bulk_read.get_result(bulk_read_Job['job_id'])
注意： 最大200,000行を同時に読み取ることができます。
情報： 上記の操作を実行するために必要な権限レベルを確認するには、SDKスコープの表を参照してください。
最終更新日 2026-03-30 13:40:30 +0530 IST
Yes
No
Thank you for your feedback!
Send your feedback to us
Skip
Submit