spring batch: reprise d'un travail achevé, avec les mêmes paramètres

Est-il possible de redémarrer un emploi dans spring batch avec le même travail params, qui a terminé avec succès?

Dire que j'ai un emploi avec une étape qui lit un fichier et écrit de l'autre.

À des fins de test, j'en ai besoin pour exécuter le travail, encore et encore. Cependant, je ne veux pas le travail param (qui est la date d'aujourd'hui dont je suis la lecture à partir d'un tableau) pour changer encore et encore.

Un tel scénario est possible ?

OriginalL'auteur Vicky | 2012-02-01

  1. 4
    Long startNextInstance(String jobName) 
      throws NoSuchJobException, JobParametersNotFoundException, JobRestartException, 
             JobExecutionAlreadyRunningException, JobInstanceAlreadyCompleteException;

    Cette méthode de la JobOperator classe avec un JobParameterIncrementer peuvent être utilisées pour redémarrer un emploi, soit échoué ou ont été achevés.

    http://static.springsource.org/spring-batch/apidocs/org/springframework/batch/core/launch/support/SimpleJobOperator.html#startNextInstance(java.lang.String)

    Je ne peux toujours pas comprendre, pourquoi une certaine logique est situé dans JobOperator et certains dans JobLauncher. Comme pour moi, ces deux devraient être fusionnés. Enfin, j'ai créé l'équivalent sémantiquement code de startNextInstance() en mon projet.
    Je peux totalement se rapportent à votre frustration avec le fonctionnement de l'Api sont dispersés dans plusieurs classes. Je ne peux vraiment pas comprendre comment ces Api jamais réussi à s'en sortir sans raison valable de le faire.
    href="https://docs.spring.io/spring-batch/trunk/reference/html/spring-batch-intro.html#springBatchBackground" >docs.printemps.io/spring-batch/trunk/de référence/html/... Citation: Accenture a contribué déjà propriétaire traitement par lot des cadres d'architecture, basée sur des décennies d'expérience dans la construction de lot architectures avec les dernières générations de plates-formes, (c, COBOL/Mainframe, C++/Unix, et maintenant Java/n'importe où) pour le Spring Batch projet de committer de ressources à la prise en charge du lecteur, des améliorations, et de la future feuille de route.
    Le JobOperator interface est un JSR-352 exigence. Nous savons tous que Spring batch précède la JSR et beaucoup de chevauchement fonctionnel est inévitable

    OriginalL'auteur user1201659

  2. 4

    Spring Batch exige unique de paramètres de travail pour son exécution.ainsi, vous pouvez ajouter l'heure actuelle comme un paramètre de travail

    Map<String, JobParameter> confMap = new HashMap<String, JobParameter>();
confMap.put("time", new JobParameter(System.currentTimeMillis()));
JobParameters jobParameters = new JobParameters(confMap);
jobLauncher.run(springCoreJob, jobParameters);

    OriginalL'auteur Jijo

  3. 3

    Spring Batch exige unique de paramètres de travail pour son exécution.
    Dans votre cas, si vous souhaitez exécuter le même travail avec le même paramètre de date, que vous devriez "ajouter" un autre paramètre de travail pour le rendre unique. Vous pouvez penser qu'il est unique paramètre de travail.

    org.springframework.batch.core.JobParametersIncrementer interface peut être utilisée dans ce scénario, il suffit de donner votre JobParameter et il va ajouter une course.id qui le rendent unique. 

    public class SampleIncrementer implements JobParametersIncrementer {  

    public JobParameters getNext(JobParameters parameters) { 
        if (parameters==null || parameters.isEmpty()) {
            return new JobParametersBuilder().addLong("run.id", 1L).toJobParameters();
        }
        long id = parameters.getLong("run.id",1L) + 1;
        return new JobParametersBuilder().addLong("run.id", id).toJobParameters();
    } }

    Vous pouvez vérifier un exemple simple de l'utiliser

    Spring Batch est une classe qui fait déjà cela: org.springframework.lot.de base.de lancement.de soutien.RunIdIncrementer
    "Spring Batch exige unique de paramètres de travail pour son exécution" => cette exigence n'a pas de sens pour moi

    OriginalL'auteur Serkan Arıkuşu

  4. 0

    J'ai cette fonction 

    public void run()
{
    LOG.info("Processing batch...");
    try
    {
        Job job = createNewJob();
        JobParameters jobParameters = new JobParameters();
        Optional<JobInstance> existingInstance = jobExplorer.getJobInstances(job.getName(), 0, 1).stream().findFirst();
        if (existingInstance.isPresent())
        {
            jobParameters = job.getJobParametersIncrementer().getNext(jobParameters);
            LOG.warn("Trying to restart task \"{}\" with the parameters [{}]", job, jobParameters);
        }
        jobLauncher.run(job, jobParameters);
    }
    catch (JobExecutionAlreadyRunningException ex)
    {
        LOG.warn("The task \"{}\" is already running", BillingBatchConfig.QUALIFIER);
    }
    catch (JobRestartException ex)
    {
        LOG.warn("The task \"{}\" cannot be restarted", BillingBatchConfig.QUALIFIER);
    }
    catch (JobInstanceAlreadyCompleteException ex)
    {
        LOG.warn("The task \"{}\" cannot be restarted cause its finished", BillingBatchConfig.QUALIFIER);
    }
    catch (JobParametersInvalidException ex)
    {
        LOG.warn("The task \"{}\" cannot be excecuted cause the parameters are invalid", BillingBatchConfig.QUALIFIER);
    }
    catch (Exception ex)
    {
        LOG.warn("Unexpected error running the task \"{}\"", BillingBatchConfig.QUALIFIER);
    }
}

    La clé est de vérifier d'abord s'il existe une instance de org.springframework.batch.core.explore.JobExplorer dans la base de données de la recherche d'emploi. Si son si, le travail doit être démarré à l'aide des paramètres obtenus par job.getJobParametersIncrementer().getNext(jobParameters). C'est tout.

    OriginalL'auteur EliuX