Spring Batch Execution এর Status এবং Logs

Spring Batch একটি শক্তিশালী ফ্রেমওয়ার্ক, যা বড় আকারের ডেটা প্রসেসিং এবং ব্যাচ কাজের জন্য ব্যবহৃত হয়। যখন একটি ব্যাচ প্রসেস সম্পাদিত হয়, তখন Execution Status এবং Logs এর মাধ্যমে আপনি কাজের অবস্থা এবং অ্যাপ্লিকেশনের পারফরম্যান্স মনিটর করতে পারেন। এই সিস্টেমটি বিশেষভাবে গুরুত্বপূর্ণ কারণ এটি ব্যাচ প্রসেসিংয়ের ট্র্যাকিং, ডিবাগিং এবং ফেইলওয়ারের সমস্যা চিহ্নিত করতে সহায়তা করে।

এখানে আমরা Spring Batch Execution Status এবং Logs ব্যবস্থাপনা সম্পর্কে বিস্তারিতভাবে আলোচনা করব।

1. Spring Batch Execution Status

Spring Batch এর মাধ্যমে একটি Job বা Step চলার সময় তার Execution Status জানা অত্যন্ত গুরুত্বপূর্ণ, কারণ এটি ব্যাচ কাজের সফলতা বা ব্যর্থতা নির্ধারণ করে।

1.1 Execution Status এর ধরণ

Spring Batch এ একটি Job বা Step এর জন্য সাধারণত নিম্নলিখিত Execution Status ব্যবহৃত হয়:

• COMPLETED: কাজ সফলভাবে সম্পন্ন হয়েছে।
• FAILED: কাজটি ব্যর্থ হয়েছে।
• STOPPED: কাজটি ম্যানুয়ালি থামানো হয়েছে।
• STARTED: কাজটি চলছে।
• UNKNOWN: কাজের অবস্থা অজানা (যখন কোনো ত্রুটি থাকে এবং সঠিক অবস্থান নির্ধারণ করা যায় না)।

1.2 JobExecution এবং StepExecution

JobExecution এবং StepExecution ক্লাসগুলো Spring Batch এ কাজের কার্যক্রম এবং অবস্থা ট্র্যাক করতে ব্যবহৃত হয়। JobExecution একটি ব্যাচ জবের সার্বিক অবস্থা দেখায় এবং StepExecution প্রতিটি স্টেপের অবস্থা এবং ফলাফল সংক্রান্ত তথ্য দেয়।

উদাহরণ: JobExecution এর Status চেক করা

package com.example.batch;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.launch.support.RunIdIncrementer;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobExecutionException;
import org.springframework.batch.core.JobParameters;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class BatchApplication {

    public static void main(String[] args) throws JobExecutionException {
        ApplicationContext context = new AnnotationConfigApplicationContext(BatchConfig.class);
        JobLauncher jobLauncher = context.getBean(JobLauncher.class);
        Job job = context.getBean("userJob", Job.class);

        // Run the job
        JobExecution execution = jobLauncher.run(job, new JobParameters());
        
        // Get job status
        System.out.println("Job Status: " + execution.getStatus());
    }
}

এখানে:

• JobExecution ব্যাচ জবের সম্পূর্ণ অবস্থা প্রদান করে। আমরা execution.getStatus() ব্যবহার করে COMPLETED, FAILED, STOPPED ইত্যাদি স্টেটাস পেতে পারি।

1.3 StepExecution এর Status চেক করা

package com.example.batch;

import org.springframework.batch.core.StepExecution;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.StepExecutionException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class StepStatusExample {

    public static void main(String[] args) {
        ApplicationContext context = new AnnotationConfigApplicationContext(BatchConfig.class);
        JobLauncher jobLauncher = context.getBean(JobLauncher.class);
        Job job = context.getBean("userJob", Job.class);
        
        try {
            JobExecution jobExecution = jobLauncher.run(job, new JobParameters());
            
            // Get Step Execution Status
            for (StepExecution stepExecution : jobExecution.getStepExecutions()) {
                System.out.println("Step " + stepExecution.getStepName() + " Status: " + stepExecution.getStatus());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

এখানে, StepExecution এর মাধ্যমে প্রতিটি স্টেপের স্টেটাস পাওয়ার উদাহরণ দেখানো হয়েছে। getStepExecutions() মেথডটি ব্যাচ জবের সকল স্টেপের অবস্থা প্রদান করে।

2. Spring Batch Logs

Spring Batch এ Logs ব্যাচ প্রসেসিংয়ের কার্যক্রম ট্র্যাক করতে সহায়তা করে। যখন একটি Job বা Step চলতে থাকে, তখন তার কার্যক্রম এবং ত্রুটি সম্পর্কে বিস্তারিত তথ্য লগে 기록 করা হয়। Logs এর মাধ্যমে আপনি ব্যাচ প্রসেসিংয়ের সমস্যা চিহ্নিত করতে এবং পারফরম্যান্স বিশ্লেষণ করতে পারবেন।

2.1 Logs কনফিগারেশন

Spring Batch এর জন্য সঠিকভাবে লগ কনফিগার করতে আপনি Logback অথবা Log4j ব্যবহার করতে পারেন। Spring Boot সাধারণত Logback ব্যবহার করে এবং এটি SLF4J API এর মাধ্যমে লগিং সমর্থন করে।

application.properties ফাইলে লগ লেভেল কনফিগারেশন করা যেতে পারে:

logging.level.org.springframework.batch=DEBUG
logging.level.com.example.batch=DEBUG

এখানে, org.springframework.batch এবং com.example.batch প্যাকেজের জন্য লগ লেভেল DEBUG সেট করা হয়েছে। এটি ব্যাচ প্রসেসিং সম্পর্কিত সকল ডিবাগ তথ্য দেখাবে।

2.2 Logs Example

Spring Batch এ ব্যাচ প্রসেসিংয়ের লগ সাধারণত JobExecution এবং StepExecution সম্পর্কিত তথ্য ধারণ করে। যখন একটি ব্যাচ কাজ শুরু হয়, শেষ হয়, অথবা কোনো ত্রুটি ঘটে, তখন তা লগে প্রিন্ট করা হয়।

উদাহরণ: ব্যাচ কাজের লগ

package com.example.batch.writer;

import com.example.batch.model.User;
import org.springframework.batch.item.ItemWriter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;

public class UserItemWriter implements ItemWriter<User> {

    private static final Logger logger = LoggerFactory.getLogger(UserItemWriter.class);

    @Override
    public void write(List<? extends User> items) throws Exception {
        for (User user : items) {
            logger.info("Writing user: {}", user);  // Log user data
        }
    }
}

এখানে, SLF4J লগিং লাইব্রেরি ব্যবহার করে, UserItemWriter ক্লাসে ইউজার ডেটা কনসোলে লগ করা হয়েছে। লগ ইনফরমেশন দেখতে, আপনি DEBUG লেভেল ব্যবহার করতে পারেন।

3. Spring Batch Logs-এ Error Handling

Spring Batch এ Error Handling গুরুত্বপূর্ণ, কারণ ব্যাচ প্রসেসিংয়ে ত্রুটি ঘটলে তা সঠিকভাবে লগ করা প্রয়োজন। ত্রুটির কারণ জানা থাকলে পরবর্তী ব্যাচ প্রসেসের জন্য সেই তথ্য ব্যবহার করা যেতে পারে।

3.1 Step-Level Error Handling

package com.example.batch.processor;

import com.example.batch.model.User;
import org.springframework.batch.item.ItemProcessor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class UserItemProcessor implements ItemProcessor<User, User> {

    private static final Logger logger = LoggerFactory.getLogger(UserItemProcessor.class);

    @Override
    public User process(User item) throws Exception {
        try {
            // Process item
            if (item.getName() == null) {
                throw new IllegalArgumentException("User name is null");
            }
            return item;
        } catch (Exception e) {
            logger.error("Error processing user: {}", item, e);  // Log the error
            throw e;  // Rethrow the exception
        }
    }
}

এখানে, ItemProcessor এর মধ্যে যদি কোনো ত্রুটি ঘটে, তবে তা লগ করা হচ্ছে এবং ত্রুটির পরে ব্যাচ প্রসেসটি থামানো হচ্ছে।

4. Spring Batch Monitoring and Alerts

Spring Batch এর মধ্যে যেকোনো ধরনের ত্রুটি বা ব্যাচ প্রসেসের স্টেটাস মনিটর করতে আপনি বিভিন্ন ধরনের monitoring tools এবং alerting systems ব্যবহার করতে পারেন। কিছু জনপ্রিয় টুল হল:

• Spring Batch Admin: এটি Spring Batch জব এবং স্টেপের পরিচালনা ও মনিটরিং এর জন্য ব্যবহৃত হয়।
• Prometheus & Grafana: ব্যাচ প্রসেসের স্ট্যাটিস্টিক্স মনিটর করতে এবং alerting সিস্টেম তৈরি করতে।
• Elastic Stack (ELK): লগ বিশ্লেষণ এবং পর্যবেক্ষণ করতে।

সারাংশ

Spring Batch এ Execution Status এবং Logs ব্যাচ প্রসেসিংয়ের কার্যক্রম এবং ফলাফল ট্র্যাক করতে অত্যন্ত গুরুত্বপূর্ণ। JobExecution এবং StepExecution এর মাধ্যমে ব্যাচ কাজের স্টেটাস জানা যায়, যেমন COMPLETED, FAILED, STOPPED ইত্যাদি। Spring Batch Logs ব্যবস্থাপনা আপনাকে ব্যাচ কাজের কার্যক্রম এবং ত্রুটি পর্যবেক্ষণ করতে সহায়তা করে। লগিং এবং স্টেটাস মনিটরিংয়ের মাধ্যমে ব্যাচ প্রসেসিংয়ের সমস্যাগুলি দ্রুত চিহ্নিত এবং সমাধান করা সম্ভব হয়।