Job Functions

import java.util.logging.Level;
import java.util.logging.Logger;
import com.catalyst.Context;
import com.catalyst.job.JOB_STATUS;
import com.catalyst.job.JobRequest;
import com.catalyst.job.CatalystJobHandler;
import com.zc.common.ZCProject;
import com.zc.component.cache.ZCCache;
public class Sample implements CatalystJobHandler {
private static final Logger LOGGER = Logger.getLogger(Sample.class.getName());
@Override
public JOB_STATUS handleJobExecute(JobRequest request, Context arg1) throws Exception {
try {
ZCProject.initProject();
Object eventData = request.getAllJobParams();
if (eventData != null) {
LOGGER.log(Level.SEVERE, "Data is" + eventData.toString());
}
LOGGER.log(Level.SEVERE, "Project Details " + request.getProjectDetails().toString());
ZCCache.getInstance().putCacheValue("JobSample", "Working", 1 l);
LOGGER.log(Level.SEVERE, "Inserted SucessFully:)");
} catch (Exception e) {
LOGGER.log(Level.SEVERE, "Exception in Job Function", e);
return JOB_STATUS.FAILURE;
}
return JOB_STATUS.SUCCESS;
}

}

/**
*


@param {import("./types/job").JobRequest} jobRequest


@param {import("./types/job").Context} context
*/
module.exports = (jobRequest, context) => {
console.log(‘Hello from index.js’);
// function input: { job_details: { job_meta_details: { params: { key: ‘value’ } } } }
/**

JOB REQUEST FUNCTIONALITIES
*/

const projectDetails = jobRequest.getProjectDetails(); // 現在のプロジェクト詳細を取得する
const jobDetails = jobRequest.getJobDetails(); // 現在のジョブ詳細を取得する
const jobMetaDetails = jobRequest.getJobMetaDetails(); // 現在のジョブのメタデータ詳細を取得する
const jobpoolDetails = jobRequest.getJobpoolDetails(); // 現在のFunctionジョブプールの詳細を取得する
const getJobCapacityAttributes = jobRequest.getJobCapacityAttributes(); // 現在のジョブのキャパシティを取得する
const allJobParams = jobRequest.getAllJobParams(); // ジョブ関数に渡されたすべてのパラメータを取得する
const jobParam = jobRequest.getJobParam(‘key’); // ジョブ関数に渡された特定のパラメータの値を取得する
/**

CONTEXT FUNCTIONALITIES
*/
context.closeWithSuccess(); //end of application with success
// context.closeWithFailure(); //end of application with failure
};

import logging
def handler(job_request, context):
logger = logging.getLogger()
logger.info(‘Hello from main.py’)
# function input: { job_details: { job_meta_details: { params: { key: 'value' } } } }
‘‘‘JobRequest Functionalities’’’
job_details = job_request.get_job_details() # 現在のジョブの詳細を取得する
project_details = job_request.get_project_details() # 現在のプロジェクトの詳細を取得する
job_meta_details = job_request.get_job_meta_details() # 現在のジョブのメタデータを取得する
job_pool_details = job_request.get_job_pool_details() # 現在のFunctionジョブプールの詳細を取得する
job_capacity_attributes = job_request.get_job_capacity_attributes() # 現在のジョブのキャパシティを取得する
all_job_params = job_request.get_all_job_params() # ジョブ関数に渡されたすべてのパラメータを取得する
job_param = job_request.get_job_param(‘key’) # ジョブ関数に渡された特定のパラメータの値を取得する
‘‘‘Context Functionalities’’’
remaining_execution_time_ms = context.get_remaining_execution_time_ms() # ジョブ関数の最大許容実行時間を取得する
max_execution_time_ms = context.get_max_execution_time_ms() # このジョブ関数の残り実行時間を取得する


context.close_with_success() # 成功レスポンスで関数の実行を終了する