Jobsコンポーネントを使用したJob Poolへのジョブの送信
Jobsコンポーネントを使用して、Job Poolにジョブを即座に送信できます。ジョブは、コンソールのBuilderを使用するか、Java、Node.js、またはPython SDKを使用して作成・送信できます。
Job Poolにジョブを送信する前に、以下を確認してください：
- ジョブがFunction Job Poolに送信される場合、ディスパッチ遅延を回避するために、適切なmemory allocationでJob Poolを作成する必要があります。
Job Poolにジョブを送信するには：
-
コンソールのCatalyst Job Schedulingサービスセクションに移動し、Start Exploringをクリックします。
-
サイドバーのJOB EXECUTORの下にあるJobsに移動し、Create Jobをクリックします。
Builderを使用したジョブの作成
-
Job Name入力フィールドにジョブの名前を入力します。
-
Select Job Poolドロップダウンを使用して、このジョブを送信するJob Poolを選択します。
- Job PoolのTarget Typeに基づいて、ジョブの設定手順が異なります。このヘルプドキュメントでは、Function Job Poolのジョブを作成します。
- Target Functionドロップダウンから、トリガーするJob Functionを選択します。
注意:
-
CLIからJob Functionを初期化してコーディングした場合、ドロップダウンに関数が表示されるように、Catalystコンソールにデプロイしてください。
-
Job Functionを作成していない場合は、Create Newをクリックしてください。Catalyst Serverlessセクションに移動します。Job Functionの作成手順はこのセクションをご覧ください。
- ポップアップのトグルを有効にして、ジョブが関数をトリガーする際にJob FunctionにQuery Parametersを渡すこともできます。
-
Show Advanced Optionsをクリックして、再送信の設定を行うことができます。
-
No. of Retriesドロップダウンからリトライ回数を選択し、Retry Intervalドロップダウンから各リトライ間の時間間隔を選択できます。
- 設定を確認し、Createをクリックします。
Createをクリックすると、ジョブはすぐにJob Poolに送信され実行されます。これにより、BuilderオプションはJob Poolのパフォーマンスをテストするための優れたツールとなります。
SDKを使用したジョブの作成
-
SDKタブをクリックします。
-
target typeの要件に基づいて、ドロップダウンから該当するSDKを選択します。
Function Target Type
- 必要なランタイムを選択し、コピーボタンをクリックしてコードスニペットをコピーします。
// FUNCTION JOB
// ジョブスケジューリングインスタンスを取得する
ZCJobScheduling jobScheduling = ZCJobScheduling.getInstance();
ZCJobpool jobpool = jobScheduling.jobpoolInstance(“test”); // testという名前のFunctionジョブプール用のジョブプールインスタンスを作成する
// Functionジョブのメタデータを生成する
ZCJobMetaDetail jobMeta = ZCJobBuilder.functionJobBuilder() // Functionジョブビルダーを取得する
.setJobConfig(2, 15 * 60 * 1000L) // ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
.setTargetName(“target_function”) // ターゲット関数の名前を設定する（オプション）（TargetNameまたはTargetIdは必須）
// .setTargetId(1234567890L) // ターゲット関数のIDを設定する（オプション）（TargetNameまたはTargetIdは必須）
.setParams(new JSONObject() {
{
put(“arg1”, “job”);
put(“arg2”, “test”);
}
}) // ターゲット関数に渡すパラメータを設定する（オプション）
.setJobName(“job_name”) // ジョブ名を設定する
.build(); // ジョブメタデータをビルドする
// Functionジョブを送信する
ZCJobDetails functionJob = jobpool.submitJob(jobMeta);
// FUNCTION JOB
const jobScheduling = app.jobScheduling(); // ジョブスケジューリングインスタンスを作成する
const jobpool = jobScheduling.jobpool({ name: ’test’ }); // testという名前のFunctionジョブプール用のジョブプールインスタンスを作成する
// Functionジョブを作成する
const functionJob = await jobpool.submitJob({
job_name: ’test_job’, // ジョブの名前を設定する
target_type: ‘Function’, // Function用のターゲットタイプをFunctionに設定する
target_name: ’target_function’, // ターゲット関数の名前を設定する（オプション）（target_idまたはtarget_nameは必須）
// target_id: ‘123467890’, // ターゲット関数のIDを設定する（オプション）（target_idまたはtarget_nameは必須）
params: {
arg1: ’test’,
arg2: ‘job’
}, // ターゲット関数に渡すパラメータを設定する（オプション）
job_config: {
number_of_retries: 2, // リトライ回数を設定する
retry_interval: 15 * 60 * 1000 + ’’ // リトライ間隔を設定する
} // ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
});
job_scheduling = app.job_scheduling() # ジョブスケジューリングインスタンスを作成する
jobpool = job_scheduling.jobpool(jobpool_name=“test”) # testという名前のFunctionジョブプール用のインスタンスを作成する
# Functionジョブを作成する
function_job = jobpool.submit_job({
‘job_name’: ’test_job’, # ジョブの名前を設定する
’target_type’: ‘Function’, # Function用のターゲットタイプをFunctionに設定する
’target_name’: ’target_function’, # ターゲット関数の名前を設定する（オプション）（target_idまたはtarget_nameは必須）
# ’target_id’: ‘123467890’, # ターゲット関数のIDを設定する（オプション）（target_idまたはtarget_nameは必須）
‘params’: {
‘arg1’: ’test’,
‘arg2’: ‘job’
}, # ターゲット関数に渡すパラメータを設定する（オプション）
‘job_config’: {
’number_of_retries’: 2, # リトライ回数を設定する
‘retry_interval’: 15 * 60 * 1000 # リトライ間隔を設定する
} # ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
})
Circuit Target Type
- 必要なランタイムを選択し、コピーボタンをクリックしてコードスニペットをコピーします。
// CIRCUIT JOB
// ジョブスケジューリングインスタンスを取得する
ZCJobScheduling jobScheduling = ZCJobScheduling.getInstance();
// ジョブプールインスタンスを作成する
ZCJobpool jobpool = jobScheduling.jobpoolInstance(“test”); // testという名前のCircuitジョブプール用のジョブプールインスタンスを作成する
// Circuitジョブのメタデータを生成する
ZCJobMetaDetail jobMeta = ZCJobBuilder.circuitJobBuilder() // Circuitジョブビルダーを作成する
.setJobConfig(2, 15 * 60 * 1000L) // ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
.setTargetName(“target_circuit”) // ターゲットサーキットの名前を設定する（オプション）（TargetNameまたはTargetIdは必須）
// .setTargetId(1234567890L) // ターゲットサーキットのIDを設定する（オプション）（TargetNameまたはTargetIdは必須）
.setCircuitInput(new JSONObject() {
{
put(“key1”, “value1”);
put(“key2”, “value2”);
}
}) // サーキットのテストケースを設定する
.setJobName(“test_job”) // ジョブ名を設定する
.build(); // Circuitジョブメタデータをビルドする
// Circuitジョブを送信する
ZCJobDetails circuitJob = jobpool.submitJob(jobMeta);
// CIRCUIT JOB
const jobScheduling = app.jobScheduling(); // ジョブスケジューリングインスタンスを作成する
const jobpool = jobScheduling.jobpool({ name: ’test’ }); // testという名前のCircuitジョブプール用のジョブプールインスタンスを作成する
// Circuitジョブを作成する
const circuitJob = await jobpool.submitJob({
job_name: ’test_job’, // ジョブの名前を設定する
target_type: ‘Circuit’, // Circuit用のターゲットタイプをCircuitに設定する
target_name: ’target_circuit’, // ターゲットサーキットの名前を設定する（オプション）（target_idまたはtarget_nameは必須）
// target_id: ‘123467890’, // ターゲットサーキットのIDを設定する（オプション）（target_idまたはtarget_nameは必須）
test_cases: {
arg1: “job”,
arg2: “test”
}, // サーキットのテストケースを設定する
job_config: {
number_of_retries: 2, // リトライ回数を設定する
retry_interval: 15 * 60 * 1000 + ’’ // リトライ間隔を設定する
} // ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
});
job_scheduling = app.job_scheduling() # ジョブスケジューリングインスタンスを作成する
jobpool = job_scheduling.jobpool(jobpool_name=“test”) # testという名前のCircuitジョブプール用のインスタンスを作成する
# Circuitジョブを作成する
circuit_job = jobpool.submit_job({
‘job_name’: ’test_job’, # ジョブの名前を設定する
’target_type’: ‘Circuit’, # Circuit用のターゲットタイプをCircuitに設定する
’target_name’: ’target_circuit’, # ターゲットサーキットの名前を設定する（オプション）（target_idまたはtarget_nameは必須）
# ’target_id’: ‘123467890’, # ターゲットサーキットのIDを設定する（オプション）（target_idまたはtarget_nameは必須）
’test_cases’: {
‘arg1’: ‘job’,
‘arg2’: ’test’
}, # サーキットのテストケースを設定する
‘job_config’: {
’number_of_retries’: 2, # リトライ回数を設定する
‘retry_interval’: 15 * 60 * 1000 # リトライ間隔を設定する
} # ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
})
Webhook Target Type
- 必要なランタイムを選択し、コピーボタンをクリックしてコードスニペットをコピーします。
// WEB HOOK JOB
// ジョブスケジューリングインスタンスを取得する
ZCJobScheduling jobScheduling = ZCJobScheduling.getInstance();
// ジョブプールインスタンスを作成する
ZCJobpool jobpool = jobScheduling.jobpoolInstance(“test”); // testという名前のWebhookジョブプール用のジョブプールインスタンスを作成する
// Webhookジョブのメタデータを生成する
ZCJobMetaDetail jobMeta = ZCJobBuilder.webhookJobBuilder() // Webhookジョブビルダーを作成する
.setJobConfig(2, 15 * 60 * 1000L) // ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
.setRequestMethod(“POST”) // Webhookリクエストのメソッドを設定する
.setUrl(“https://catalyst.zoho.com”) // WebhookリクエストのURLを設定する
.setParams(new JSONObject() {
{
put(“arg1”, “test”);
put(“arg2”, “job”);
}
}) // Webhookリクエストのクエリパラメータを設定する（オプション）
.setHeaders(new JSONObject() {
{
put(“IS_TEST_REQUEST”, “true”);
}
}) // Webhookリクエストのヘッダーを設定する（オプション）
.setRequestBody(“test_request”) // Webhookリクエストのボディを設定する（オプション）
.setJobName(“test_job”) // ジョブ名を設定する
.build(); // Webhookジョブメタデータをビルドする
// Webhookジョブを送信する
ZCJobDetails webHookJob = jobpool.submitJob(jobMeta);
// WEBHOOK JOB
const jobScheduling = app.jobScheduling(); // ジョブスケジューリングインスタンスを作成する
const jobpool = jobScheduling.jobpool({ name: ’test’ }); // testという名前のWebhookジョブプール用のジョブプールインスタンスを作成する
// Webhookジョブを作成する
const webhookJob = await jobpool.submitJob({
job_name: ’test_job’, // ジョブの名前を設定する
target_type: ‘Webhook’, // Webhook用のターゲットタイプをWebhookに設定する
request_method: ‘POST’, // Webhookリクエストのメソッドを設定する
url: ‘https://catalyst.zoho.com’, // WebhookリクエストのURLを設定する
params: {
arg1: ’test’,
arg2: ‘job’
}, // Webhookリクエストのクエリパラメータを設定する（オプション）
headers: {
IS_TEST_REQUEST: ’true’
}, // Webhookリクエストのヘッダーを設定する（オプション）
request_body: ’test_request’, // Webhookリクエストのボディを設定する（オプション）
job_config: {
number_of_retries: 2, // リトライ回数を設定する
retry_interval: 15 * 60 * 1000 + ’’ // リトライ間隔を設定する
} // ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
});
job_scheduling = app.job_scheduling() # ジョブスケジューリングインスタンスを作成する
jobpool = job_scheduling.jobpool(jobpool_name=“test”) # testという名前のWebhookジョブプール用のインスタンスを作成する
# Webhookジョブを作成する
webhook_job = jobpool.submit_job({
‘job_name’: ’test_job’, # ジョブの名前を設定する
’target_type’: ‘Webhook’, # Webhook用のターゲットタイプをWebhookに設定する
‘request_method’: ‘POST’, # Webhookリクエストのメソッドを設定する
‘url’: ‘https://catalyst.zoho.com’, # WebhookリクエストのURLを設定する
‘params’: {
‘arg1’: ’test’,
‘arg2’: ‘job’
}, # Webhookリクエストのクエリパラメータを設定する（オプション）
‘headers’: {
‘IS_TEST_REQUEST’: ’true’
}, # Webhookリクエストのヘッダーを設定する（オプション）
‘request_body’: ’test_request’, # Webhookリクエストのボディを設定する（オプション）
‘job_config’: {
’number_of_retries’: 2, # リトライ回数を設定する
‘retry_interval’: 15 * 60 * 1000 # リトライ間隔を設定する
} # ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
})
AppSail Target Type
- 必要なランタイムを選択し、コピーボタンをクリックしてコードスニペットをコピーします。
// APPSAIL JOB
// ジョブスケジューリングインスタンスを取得する
ZCJobScheduling jobScheduling = ZCJobScheduling.getInstance();
// ジョブプールインスタンスを作成する
ZCJobpool jobpool = jobScheduling.jobpoolInstance(“test”); // testという名前のAppSailジョブプール用のジョブプールインスタンスを作成する
// AppSailジョブのメタデータを生成する
ZCJobMetaDetail jobMeta = ZCJobBuilder.appSailJobBuilder() // AppSailジョブビルダーを作成する
.setJobConfig(2, 15 * 60 * 1000L) // ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
.setTargetName(“test_appsail”) // AppSailの名前を設定する
.setRequestMethod(“POST”) // AppSailリクエストのメソッドを設定する
.setUrl("/test") // AppSailリクエストのURLを設定する
.setParams(new JSONObject() {
{
put(“arg1”, “value1”);
put(“arg2”, “value2”);
}
}) // AppSailリクエストのクエリパラメータを設定する
.setHeaders(new JSONObject() {
{
put(“IS_TEST_REQUEST”, “true”);
}
}) // AppSailリクエストのヘッダーを設定する（オプション）
.setRequestBody(“test_request”) // AppSailリクエストのボディを設定する（オプション）
.setJobName(“test_job”) // ジョブ名を設定する
.build(); // AppSailジョブメタデータをビルドする
// AppSailジョブを送信する
ZCJobDetails appSailJob = jobpool.submitJob(jobMeta);
// APPSAIL JOB
const jobScheduling = app.jobScheduling(); // ジョブスケジューリングインスタンスを作成する
const jobpool = jobScheduling.jobpool({ name: ’test’ }); // testという名前のAppSailジョブプール用のジョブプールインスタンスを作成する
// AppSailジョブを作成する
const appsailJob = await jobpool.submitJob({
job_name: ’test_job’, // ジョブの名前を設定する
target_type: ‘AppSail’, // AppSail用のターゲットタイプをAppSailに設定する
target_name: ’target_appsail’, // ターゲットAppSailの名前を設定する（オプション）（target_idまたはtarget_nameは必須）
// target_id: ‘123467890’, // ターゲットAppSailのIDを設定する（オプション）（target_idまたはtarget_nameは必須）
request_method: ‘POST’, // AppSailリクエストのメソッドを設定する
url: ‘/test’, // AppSailのURLパスを設定する（オプション）
params: {
arg1: ’test’,
arg2: ‘job’
}, // AppSailリクエストのクエリパラメータを設定する（オプション）
headers: {
IS_TEST_REQUEST: ’true’
}, // AppSailリクエストのヘッダーを設定する（オプション）
request_body: ’test_request’, // AppSailリクエストのボディを設定する（オプション）
job_config: {
number_of_retries: 2, // リトライ回数を設定する
retry_interval: 15 * 60 * 1000 + ’’ // リトライ間隔を設定する
} // ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
});
job_scheduling = app.job_scheduling() # ジョブスケジューリングインスタンスを作成する
jobpool = job_scheduling.jobpool(jobpool_name=“test”) # testという名前のAppSailジョブプール用のインスタンスを作成する
# AppSailジョブを作成する
appsail_job = jobpool.submit_job({
‘job_name’: ’test_job’, # ジョブの名前を設定する
’target_type’: ‘AppSail’, # AppSail用のターゲットタイプをAppSailに設定する
’target_name’: ’target_appsail’, # ターゲットAppSailの名前を設定する（オプション）（target_idまたはtarget_nameは必須）
# ’target_id’: ‘123467890’, # ターゲットAppSailのIDを設定する（オプション）（target_idまたはtarget_nameは必須）
‘request_method’: ‘POST’, # AppSailリクエストのメソッドを設定する
‘url’: ‘/test’, # AppSailのURLパスを設定する（オプション）
‘params’: {
‘arg1’: ’test’,
‘arg2’: ‘job’
}, # AppSailリクエストのクエリパラメータを設定する（オプション）
‘headers’: {
‘IS_TEST_REQUEST’: ’true’
}, # AppSailリクエストのヘッダーを設定する（オプション）
‘request_body’: ’test_request’, # AppSailリクエストのボディを設定する（オプション）
‘job_config’: {
’number_of_retries’: 2, # リトライ回数を設定する
‘retry_interval’: 15 * 60 * 1000 # リトライ間隔を設定する
} # ジョブ設定 - リトライ => 15分で2回リトライ（オプション）
})
- スニペットをコードファイルに貼り付け、ロジックを構築します。
プロジェクト用に作成したジョブは、Jobコンポーネントセクションで常に利用可能です。
ジョブが送信されると、Job Definitionセクションで送信されたジョブの一般的な詳細をすべて確認できます。また、Job Execution & Statusセクションでジョブの実行ステータスを確認できます。
ジョブの実行ステータスは、Job Nameの横の上部にもラベルとして表示されます。また、Job DefinitionがJSON形式で提供され、コピーして同じ仕様で新しいジョブを送信するために使用できます。View Logsボタンをクリックして、DevOpsのLogsコンポーネントで生成された実行ログを確認することもできます。
最終更新日 2026-03-30 13:40:30 +0530 IST
Yes
No
Thank you for your feedback!
Send your feedback to us