SchedulerX:JobContext パラメーター

基本的な使用方法

ジョブハンドラ内で getter メソッドを通じて JobContext パラメーターにアクセスします。

public class SampleJobProcessor extends JavaProcessor {
    @Override
    public ProcessResult process(JobContext context) throws Exception {
        // ジョブおよびインスタンス識別子
        long jobId = context.getJobId();
        long instanceId = context.getJobInstanceId();

        // スケジューリングメタデータ
        DateTime scheduledTime = context.getScheduleTime();
        DateTime dataTime = context.getDataTime();

        // SchedulerX コンソールで設定された静的パラメーター
        String params = context.getJobParameters();

        // API 呼び出し経由で渡された動的パラメーター
        String dynamicParams = context.getInstanceParameters();

        // リトライ状態
        int currentAttempt = context.getAttempt();
        int maxRetries = context.getMaxAttempt();

        System.out.println("Job " + jobId + ", instance " + instanceId
            + ", attempt " + currentAttempt + "/" + maxRetries);

        return new ProcessResult(true);
    }
}

ジョブおよびインスタンス識別子

スケジューリング時刻

ジョブパラメーター

リトライパラメーター

シャーディングパラメーター

実行モード が ブロードキャスト実行 または シャード実行 に設定されている場合にのみ利用可能です。

例：

public class ShardJobProcessor extends JavaProcessor {
    @Override
    public ProcessResult process(JobContext context) throws Exception {
        Long shardId = context.getShardingId();
        int totalShards = context.getShardingNum();
        String shardParam = context.getShardingParameter();

        System.out.println("Processing shard " + shardId + " of " + totalShards);

        return new ProcessResult(true);
    }
}

ワークフローパラメーター

ジョブがワークフローの一部として実行される場合に利用可能です。