Enviar un Job instantáneo al Job Pool

// FUNCTION JOB
// obtener instancia de job scheduling
ZCJobScheduling jobScheduling = ZCJobScheduling.getInstance();
ZCJobpool jobpool = jobScheduling.jobpoolInstance(“test”); // crear una instancia de job pool para el function job pool llamado test
// generar metadatos del function job
ZCJobMetaDetail jobMeta = ZCJobBuilder.functionJobBuilder() // obtener el builder de function job
.setJobConfig(2, 15 * 60 * 1000L) // configurar job - reintentos => 2 reintentos en 15 min (opcional)
.setTargetName(“target_function”) // establecer el nombre de la función destino (opcional) (TargetName o TargetId es obligatorio)
// .setTargetId(1234567890L) // establecer el Id de la función destino (opcional) (TargetName o TargetId es obligatorio)
.setParams(new JSONObject() {
{
put(“arg1”, “job”);
put(“arg2”, “test”);
}
}) // establecer parámetros a pasar a la función destino (opcional)
.setJobName(“job_name”) // establecer nombre del job
.build(); // construir metadatos del job
// enviar function job
ZCJobDetails functionJob = jobpool.submitJob(jobMeta);

// FUNCTION JOB
const jobScheduling = app.jobScheduling(); // crear instancia de job scheduling
const jobpool = jobScheduling.jobpool({ name: ’test’ }); // crear instancia de job pool para el function job pool llamado test
// crear function job
const functionJob = await jobpool.submitJob({
job_name: ’test_job’, // establecer un nombre para el job
target_type: ‘Function’, // establecer el tipo de destino como Function para function jobs
target_name: ’target_function’, // establecer el nombre de la función destino (opcional) (target_id o target_name es obligatorio)
// target_id: ‘123467890’, // establecer el Id de la función destino (opcional) (target_id o target_name es obligatorio)
params: {
arg1: ’test’,
arg2: ‘job’
}, // establecer parámetros a pasar a la función destino (opcional)
job_config: {
number_of_retries: 2, // establecer el número de reintentos
retry_interval: 15 * 60 * 1000 + ’’ // establecer el intervalo de reintento
} // configurar job - reintentos => 2 reintentos en 15 min (opcional)
});

job_scheduling = app.job_scheduling() # crear instancia de job scheduling
jobpool = job_scheduling.jobpool(jobpool_name=“test”) # crear instancia de jobpool para el function jobpool llamado test
# crear function job

function_job = jobpool.submit_job({
‘job_name’: ’test_job’, # establecer un nombre para el job
’target_type’: ‘Function’, # establecer el tipo de destino como Function para function jobs
’target_name’: ’target_function’, # establecer el nombre de la función destino (opcional) (target_id o target_name es obligatorio)
# ’target_id’: ‘123467890’, # establecer el Id de la función destino (opcional) (target_id o target_name es obligatorio)
‘params’: {
‘arg1’: ’test’,
‘arg2’: ‘job’
}, # establecer parámetros a pasar a la función destino (opcional)
‘job_config’: {
’number_of_retries’: 2, # establecer el número de reintentos
‘retry_interval’: 15 * 60 * 1000 # establecer el intervalo de reintento
} # configurar job - reintentos => 2 reintentos en 15 min (opcional)
})

// WEB HOOK JOB
// obtener instancia de job scheduling
ZCJobScheduling jobScheduling = ZCJobScheduling.getInstance();
// crear una instancia de job pool
ZCJobpool jobpool = jobScheduling.jobpoolInstance(“test”); // crear una instancia de job pool para el webhook job pool llamado test
// generar metadatos del webhook job
ZCJobMetaDetail jobMeta = ZCJobBuilder.webhookJobBuilder() // crear builder de webhook job
.setJobConfig(2, 15 * 60 * 1000L) // configurar job - reintentos => 2 reintentos en 15 min (opcional)
.setRequestMethod(“POST”) // establecer el método de solicitud del webhook
.setUrl(“https://catalyst.zoho.com”) // establecer la URL de solicitud del webhook
.setParams(new JSONObject() {
{
put(“arg1”, “test”);
put(“arg2”, “job”);
}
}) // establecer los query params de la solicitud del webhook (opcional)
.setHeaders(new JSONObject() {
{
put(“IS_TEST_REQUEST”, “true”);
}
}) // establecer los headers de la solicitud del webhook (opcional)
.setRequestBody(“test_request”) // establecer el body de la solicitud del webhook (opcional)
.setJobName(“test_job”) // establecer nombre del job
.build(); // construir metadatos del webhook job
// enviar webhook job
ZCJobDetails webHookJob = jobpool.submitJob(jobMeta);

// WEBHOOK JOB
const jobScheduling = app.jobScheduling(); // crear instancia de job scheduling
const jobpool = jobScheduling.jobpool({ name: ’test’ }); // crear instancia de job pool para el webhook job pool llamado test
// crear webhook job
const webhookJob = await jobpool.submitJob({
job_name: ’test_job’, // establecer un nombre para el job
target_type: ‘Webhook’, // establecer el tipo de destino como Webhook para webhook jobs
request_method: ‘POST’, // establecer el método de solicitud del webhook
url: ‘https://catalyst.zoho.com’, // establecer la URL de solicitud del webhook
params: {
arg1: ’test’,
arg2: ‘job’
}, // establecer los query params de la solicitud del webhook (opcional)
headers: {
IS_TEST_REQUEST: ’true’
}, // establecer los headers de la solicitud del webhook (opcional)
request_body: ’test_request’, // establecer el body de la solicitud del webhook (opcional)
job_config: {
number_of_retries: 2, // establecer el número de reintentos
retry_interval: 15 * 60 * 1000 + ’’ // establecer el intervalo de reintento
} // configurar job - reintentos => 2 reintentos en 15 min (opcional)
});

job_scheduling = app.job_scheduling() # crear instancia de job scheduling
jobpool = job_scheduling.jobpool(jobpool_name=“test”) # crear instancia de jobpool para el webhook jobpool llamado test
# crear webhook job

webhook_job = jobpool.submit_job({
‘job_name’: ’test_job’, # establecer un nombre para el job
’target_type’: ‘Webhook’, # establecer el tipo de destino como Webhook para webhook jobs
‘request_method’: ‘POST’, # establecer el método de solicitud del webhook
‘url’: ‘https://catalyst.zoho.com’, # establecer la URL de solicitud del webhook
‘params’: {
‘arg1’: ’test’,
‘arg2’: ‘job’
}, # establecer los query params de la solicitud del webhook (opcional)
‘headers’: {
‘IS_TEST_REQUEST’: ’true’
}, # establecer los headers de la solicitud del webhook (opcional)
‘request_body’: ’test_request’, # establecer el body de la solicitud del webhook (opcional)
‘job_config’: {
’number_of_retries’: 2, # establecer el número de reintentos
‘retry_interval’: 15 * 60 * 1000 # establecer el intervalo de reintento
} # configurar job - reintentos => 2 reintentos en 15 min (opcional)
})

// CIRCUIT JOB
// obtener instancia de job scheduling
ZCJobScheduling jobScheduling = ZCJobScheduling.getInstance();
// crear una instancia de job pool
ZCJobpool jobpool = jobScheduling.jobpoolInstance(“test”); // crear una instancia de job pool para el circuit job pool llamado test
// generar metadatos del circuit job
ZCJobMetaDetail jobMeta = ZCJobBuilder.circuitJobBuilder() // crear builder de circuit job
.setJobConfig(2, 15 * 60 * 1000L) // configurar job - reintentos => 2 reintentos en 15 min (opcional)
.setTargetName(“target_circuit”) // establecer el nombre del circuit destino (opcional) (TargetName o TargetId es obligatorio)
// .setTargetId(1234567890L) // establecer el Id del circuit destino (opcional) (TargetName o TargetId es obligatorio)
.setCircuitInput(new JSONObject() {
{
put(“key1”, “value1”);
put(“key2”, “value2”);
}
}) // establecer los casos de prueba para el circuit
.setJobName(“test_job”) // establecer nombre del job
.build(); // construir metadatos del circuit job
// enviar circuit job
ZCJobDetails circuitJob = jobpool.submitJob(jobMeta);

// CIRCUIT JOB
const jobScheduling = app.jobScheduling(); // crear instancia de job scheduling
const jobpool = jobScheduling.jobpool({ name: ’test’ }); // crear instancia de job pool para el circuit job pool llamado test
// crear circuit job
const circuitJob = await jobpool.submitJob({
job_name: ’test_job’, // establecer un nombre para el job
target_type: ‘Circuit’, // establecer el tipo de destino como Circuit para circuit jobs
target_name: ’target_circuit’, // establecer el nombre del circuit destino (opcional) (target_id o target_name es obligatorio)
// target_id: ‘123467890’, // establecer el Id del circuit destino (opcional) (target_id o target_name es obligatorio)
test_cases: {
arg1: “job”,
arg2: “test”
}, // establecer los casos de prueba del circuit
job_config: {
number_of_retries: 2, // establecer el número de reintentos
retry_interval: 15 * 60 * 1000 + ’’ // establecer el intervalo de reintento
} // configurar job - reintentos => 2 reintentos en 15 min (opcional)
});

job_scheduling = app.job_scheduling() # crear instancia de job scheduling
jobpool = job_scheduling.jobpool(jobpool_name=“test”) # crear instancia de jobpool para el circuit jobpool llamado test
# crear circuit job

circuit_job = jobpool.submit_job({
‘job_name’: ’test_job’, # establecer un nombre para el job
’target_type’: ‘Circuit’, # establecer el tipo de destino como Circuit para circuit jobs
’target_name’: ’target_circuit’, # establecer el nombre del circuit destino (opcional) (target_id o target_name es obligatorio)
# ’target_id’: ‘123467890’, # establecer el Id del circuit destino (opcional) (target_id o target_name es obligatorio)
’test_cases’: {
‘arg1’: ‘job’,
‘arg2’: ’test’
}, # establecer los casos de prueba del circuit
‘job_config’: {
’number_of_retries’: 2, # establecer el número de reintentos
‘retry_interval’: 15 * 60 * 1000 # establecer el intervalo de reintento
} # configurar job - reintentos => 2 reintentos en 15 min (opcional)
})

// APPSAIL JOB
// obtener instancia de job scheduling
ZCJobScheduling jobScheduling = ZCJobScheduling.getInstance();
// crear una instancia de job pool
ZCJobpool jobpool = jobScheduling.jobpoolInstance(“test”); // crear una instancia de job pool para el appsail job pool llamado test
// generar metadatos del appsail job
ZCJobMetaDetail jobMeta = ZCJobBuilder.appSailJobBuilder() // crear builder de appsail job
.setJobConfig(2, 15 * 60 * 1000L) // configurar job - reintentos => 2 reintentos en 15 min (opcional)
.setTargetName(“test_appsail”) // establecer nombre de appsail
.setRequestMethod(“POST”) // establecer método de solicitud de appsail
.setUrl("/test") // establecer URL de solicitud de appsail
.setParams(new JSONObject() {
{
put(“arg1”, “value1”);
put(“arg2”, “value2”);
}
}) // establecer query params de solicitud de appsail
.setHeaders(new JSONObject() {
{
put(“IS_TEST_REQUEST”, “true”);
}
}) // establecer los headers de la solicitud de appsail (opcional)
.setRequestBody(“test_request”) // establecer el body de la solicitud de appsail (opcional)
.setJobName(“test_job”) // establecer nombre del job
.build(); // construir metadatos del appsail job
// enviar appsail job
ZCJobDetails appSailJob = jobpool.submitJob(jobMeta);

// APPSAIL JOB
const jobScheduling = app.jobScheduling(); // crear instancia de job scheduling
const jobpool = jobScheduling.jobpool({ name: ’test’ }); // crear instancia de job pool para el appsail job pool llamado test
// crear appsail job
const appsailJob = await jobpool.submitJob({
job_name: ’test_job’, // establecer un nombre para el job
target_type: ‘AppSail’, // establecer el tipo de destino como AppSail para appsail jobs
target_name: ’target_appsail’, // establecer el nombre del appsail destino (opcional) (target_id o target_name es obligatorio)
// target_id: ‘123467890’, // establecer el Id del appsail destino (opcional) (target_id o target_name es obligatorio)
request_method: ‘POST’, // establecer el método de solicitud de appsail
url: ‘/test’, // establecer la ruta URL de appsail (opcional)
params: {
arg1: ’test’,
arg2: ‘job’
}, // establecer los query params de la solicitud de appsail (opcional)
headers: {
IS_TEST_REQUEST: ’true’
}, // establecer los headers de la solicitud de appsail (opcional)
request_body: ’test_request’, // establecer el body de la solicitud de appsail (opcional)
job_config: {
number_of_retries: 2, // establecer el número de reintentos
retry_interval: 15 * 60 * 1000 + ’’ // establecer el intervalo de reintento
} // configurar job - reintentos => 2 reintentos en 15 min (opcional)
});

job_scheduling = app.job_scheduling() # crear instancia de job scheduling
jobpool = job_scheduling.jobpool(jobpool_name=“test”) # crear instancia de jobpool para el appsail jobpool llamado test
 # crear appsail job

appsail_job = jobpool.submit_job({
‘job_name’: ’test_job’, # establecer un nombre para el job
’target_type’: ‘AppSail’, # establecer el tipo de destino como AppSail para appsail jobs
’target_name’: ’target_appsail’, # establecer el nombre del appsail destino (opcional) (target_id o target_name es obligatorio)
# ’target_id’: ‘123467890’, # establecer el Id del appsail destino (opcional) (target_id o target_name es obligatorio)
‘request_method’: ‘POST’, # establecer el método de solicitud de appsail
‘url’: ‘/test’, # establecer la ruta URL de appsail (opcional)
‘params’: {
‘arg1’: ’test’,
‘arg2’: ‘job’
}, # establecer los query params de la solicitud de appsail (opcional)
‘headers’: {
‘IS_TEST_REQUEST’: ’true’
}, # establecer los headers de la solicitud de appsail (opcional)
‘request_body’: ’test_request’, # establecer el body de la solicitud de appsail (opcional)
‘job_config’: {
’number_of_retries’: 2, # establecer el número de reintentos
‘retry_interval’: 15 * 60 * 1000 # establecer el intervalo de reintento
} # configurar job - reintentos => 2 reintentos en 15 min (opcional)
})