উদাহরণ সহ Job Monitoring এবং Reporting

Spring Batch একটি শক্তিশালী ফ্রেমওয়ার্ক যা ব্যাচ প্রসেসিংয়ের জন্য ব্যবহৃত হয়। যখন আপনি একটি বড় ডেটাসেট বা ব্যাচ প্রসেসিংয়ের কাজ সম্পন্ন করেন, তখন আপনাকে এই কাজটির স্ট্যাটাস এবং ফলাফল মনিটর করতে এবং রিপোর্ট তৈরি করতে হতে পারে। Job Monitoring এবং Reporting স্প্রিং ব্যাচের গুরুত্বপূর্ণ অংশ, যা আপনাকে ব্যাচের চলমান স্টেটাস, সফলতা বা ব্যর্থতা নির্ণয় করতে সহায়তা করে এবং কাজটির সম্পাদনার পর রিপোর্ট তৈরি করে।

এই লেখায় আমরা স্প্রিং ব্যাচে Job Monitoring এবং Reporting কীভাবে করতে হয়, এবং তার জন্য কীভাবে কনফিগারেশন করতে হয় তা দেখব।

Job Monitoring

Job Monitoring হল একটি প্রক্রিয়া যা ব্যাচের কাজের চলমান অবস্থা পর্যবেক্ষণ করে এবং কাজটি সফল হয়েছে কিনা বা ব্যর্থ হয়েছে কিনা তা নির্ধারণ করতে সহায়তা করে। স্প্রিং ব্যাচে আপনি JobRepository, JobExecution, এবং JobExecutionListener ব্যবহার করে Job মনিটর করতে পারেন।

১. JobExecution এবং JobExecutionListener

স্প্রিং ব্যাচে একটি JobExecution অবজেক্ট ব্যাচ কাজের স্ট্যাটাস ধারণ করে, যেমন কাজের শুরু ও শেষ সময়, সফলতা বা ব্যর্থতার তথ্য এবং ব্যাচ কাজটি চলাকালীন যে কোনো ত্রুটি বা এক্সেপশন।

JobExecutionListener একটি ইন্টারফেস যা একটি Job এর চলমান স্ট্যাটাস মনিটর করার জন্য ব্যবহৃত হয়। আপনি এর মাধ্যমে beforeJob এবং afterJob মেথডে ব্যাচ কাজের আগে এবং পরে কিছু কাজ করতে পারেন।

উদাহরণ: JobExecutionListener ব্যবহার

@Bean
public JobExecutionListener listener() {
    return new JobExecutionListenerSupport() {
        @Override
        public void beforeJob(JobExecution jobExecution) {
            // Job শুরু হওয়ার আগে কিছু কাজ করুন
            System.out.println("Job started...");
        }

        @Override
        public void afterJob(JobExecution jobExecution) {
            // Job সম্পন্ন হওয়ার পর রিপোর্ট তৈরি করুন
            if (jobExecution.getStatus() == BatchStatus.COMPLETED) {
                System.out.println("Job finished successfully!");
            } else {
                System.out.println("Job failed!");
            }
        }
    };
}

@Bean
public Job myJob(JobBuilderFactory jobBuilderFactory, Step step1) {
    return jobBuilderFactory.get("myJob")
        .start(step1)
        .listener(listener()) // Listener যোগ করা হয়েছে
        .build();
}

এখানে, JobExecutionListener এর beforeJob এবং afterJob মেথডগুলির মাধ্যমে কাজ শুরু এবং শেষ হওয়ার সময় লগ করা হয়েছে।

২. JobRepository

JobRepository হল একটি গুরুত্বপূর্ণ কম্পোনেন্ট যা Job এর execution এর সমস্ত তথ্য ট্র্যাক করে, যেমন কোন কাজটি চলছে, কখন শুরু হয়েছে, কখন শেষ হয়েছে, এবং সেটি সফল ছিল কিনা।

স্প্রিং ব্যাচ ডিফল্টভাবে একটি ডেটাবেসে JobRepository সংরক্ষণ করে, যেখানে ব্যাচ কাজের ইতিহাস রাখা হয়। আপনি এই repository এর মাধ্যমে পূর্ববর্তী ব্যাচ কাজের ইতিহাস দেখতে পারবেন।

উদাহরণ: JobRepository কনফিগারেশন

@Bean
public DataSource dataSource() {
    return new DriverManagerDataSource("jdbc:h2:mem:testdb", "sa", "");
}

@Bean
public JobRepository jobRepository() throws Exception {
    JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
    factoryBean.setDataSource(dataSource());
    factoryBean.setTransactionManager(transactionManager());
    factoryBean.setDatabaseType("H2");
    return factoryBean.getObject();
}

এখানে JobRepository কনফিগার করা হয়েছে যাতে ব্যাচ কাজের স্ট্যাটাস এবং ইতিহাস ডেটাবেসে সংরক্ষিত থাকে।

Job Reporting

Job Reporting হল একটি প্রক্রিয়া যা ব্যাচ কাজের ফলাফল এবং কার্যকলাপ সম্পর্কে রিপোর্ট তৈরি করে। Spring Batch আপনাকে বিভিন্ন রিপোর্টিং অপশন প্রদান করে, যাতে আপনি ব্যাচ কাজের পারফরম্যান্স, সফলতা, ব্যর্থতা, এবং অন্যান্য সম্পর্কিত তথ্য জানতে পারেন।

১. JobExecutionStats Reporting

স্প্রিং ব্যাচে, আপনি JobExecution এবং StepExecution এর মাধ্যমে ব্যাচ কাজের স্ট্যাটাস রিপোর্ট তৈরি করতে পারেন। আপনি প্রতিটি Job এবং Step এর জন্য সফলতা, ব্যর্থতা, প্রগ্রেস, এবং অন্যান্য বিস্তারিত তথ্য সংগ্রহ করতে পারেন।

উদাহরণ: JobExecution এবং StepExecution রিপোর্টিং

@Bean
public Job reportJob(JobBuilderFactory jobBuilderFactory, Step step1) {
    return jobBuilderFactory.get("reportJob")
        .start(step1)
        .listener(new JobExecutionListenerSupport() {
            @Override
            public void afterJob(JobExecution jobExecution) {
                // Job রিপোর্ট তৈরি করুন
                System.out.println("Job Execution Status: " + jobExecution.getStatus());
                for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
                    System.out.println("Step: " + stepExecution.getStepName());
                    System.out.println("Status: " + stepExecution.getStatus());
                    System.out.println("Exit Status: " + stepExecution.getExitStatus());
                    System.out.println("Read Count: " + stepExecution.getReadCount());
                    System.out.println("Write Count: " + stepExecution.getWriteCount());
                }
            }
        })
        .build();
}

এখানে, JobExecutionListenerSupport এর মাধ্যমে আমরা ব্যাচ কাজের স্ট্যাটাস এবং প্রতিটি StepExecution এর বিস্তারিত রিপোর্ট তৈরি করেছি, যেমন readCount, writeCount, এবং exitStatus।

২. JobExecutionHistory Reporting

Spring Batch আপনাকে ব্যাচ কাজের ইতিহাস (যেমন, কাজের সফলতা এবং ব্যর্থতা) সংরক্ষণ করতে সহায়তা করে। আপনি এই ইতিহাসের উপর ভিত্তি করে রিপোর্ট তৈরি করতে পারেন এবং বিভিন্ন ধরনের কাস্টম রিপোর্টিং টুলে (যেমন JasperReports, Excel, ইত্যাদি) এই তথ্য সরবরাহ করতে পারেন।

উদাহরণ: Job Execution History Reporting

@Autowired
private JobExplorer jobExplorer;

public void printJobHistory() throws JobExecutionException {
    List<JobExecution> jobExecutions = jobExplorer.getJobExecutions("myJob");
    for (JobExecution jobExecution : jobExecutions) {
        System.out.println("Job Execution Id: " + jobExecution.getId());
        System.out.println("Job Status: " + jobExecution.getStatus());
        System.out.println("Job Exit Status: " + jobExecution.getExitStatus());
        System.out.println("Start Time: " + jobExecution.getStartTime());
        System.out.println("End Time: " + jobExecution.getEndTime());
    }
}

এখানে, JobExplorer ব্যবহার করে আমরা ব্যাচ কাজের ইতিহাসের উপর ভিত্তি করে স্ট্যাটাস এবং টেম্পোরাল তথ্য (যেমন, শুরু এবং শেষ সময়) রিপোর্ট তৈরি করেছি।

Job Monitoring এবং Reporting এর সুবিধা

• প্রসেসিং স্ট্যাটাস ট্র্যাকিং: Job Execution এর মাধ্যমে আপনি ব্যাচ কাজের সফলতা, ব্যর্থতা, এবং প্রগ্রেস ট্র্যাক করতে পারেন।
• এফেক্টিভ ডিবাগিং: কাজের মধ্যে যদি কোনো সমস্যা বা ব্যতিক্রম ঘটে, তবে তা দ্রুত চিহ্নিত করতে পারবেন এবং ত্রুটির বিস্তারিত লগ দেখতে পারবেন।
• ইতিহাস সংরক্ষণ: আপনি পূর্ববর্তী ব্যাচ কাজের ইতিহাসের উপর ভিত্তি করে বিভিন্ন রিপোর্ট তৈরি করতে পারেন।
• স্ট্যাটিস্টিকস: ব্যাচ কাজের বিভিন্ন মেট্রিক্স যেমন রিড, প্রসেস, এবং রাইট কাউন্ট ট্র্যাক করা সম্ভব, যা কাজের কর্মক্ষমতা মূল্যায়ন করতে সহায়ক।

সারাংশ

Spring Batch এ Job Monitoring এবং Reporting অত্যন্ত গুরুত্বপূর্ণ, কারণ এটি ব্যাচ কাজের চলমান অবস্থা এবং ফলাফল সঠিকভাবে ট্র্যাক এবং রিপোর্ট করতে সহায়তা করে। JobExecutionListener, JobRepository, এবং JobExplorer এর মাধ্যমে আপনি ব্যাচ কাজের সম্পাদনা, সফলতা, ব্যর্থতা এবং অন্যান্য কার্যকলাপ সম্পর্কে বিস্তারিত রিপোর্ট তৈরি করতে পারেন। এই তথ্যটি আপনাকে অ্যাপ্লিকেশন মনিটরিং, ডিবাগিং এবং রক্ষণাবেক্ষণে সহায়তা করবে।