SchedulerX:Parameter JobContext

Penggunaan dasar

Akses parameter JobContext melalui metode getter dalam penanganan pekerjaan Anda:

public class SampleJobProcessor extends JavaProcessor {
    @Override
    public ProcessResult process(JobContext context) throws Exception {
        // Pengidentifikasi pekerjaan dan instans
        long jobId = context.getJobId();
        long instanceId = context.getJobInstanceId();

        // Metadata penjadwalan
        DateTime scheduledTime = context.getScheduleTime();
        DateTime dataTime = context.getDataTime();

        // Parameter statis yang dikonfigurasi di Konsol SchedulerX
        String params = context.getJobParameters();

        // Parameter dinamis yang diteruskan melalui panggilan API
        String dynamicParams = context.getInstanceParameters();

        // Status retry
        int currentAttempt = context.getAttempt();
        int maxRetries = context.getMaxAttempt();

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

        return new ProcessResult(true);
    }
}

Pengidentifikasi pekerjaan dan instans

Waktu penjadwalan

Parameter pekerjaan

Parameter retry

Parameter sharding

Hanya tersedia ketika Execution mode diatur ke Broadcast run atau Shard run.

Contoh:

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);
    }
}

Parameter alur kerja

Tersedia ketika pekerjaan dijalankan sebagai bagian dari alur kerja.