spring-batch

    0

    1답변

    원격 청킹 메커니즘을 통해 배치 처리를 확장하고 싶습니다. 독자는 마스터가 있고, 프로세서와 작성자는 슬레이브입니다. 내 노예 중 하나가 실패하면 다른 노예가 있기 때문에 괜찮을 것입니다. 그러나 주인이 스스로 실패하면 어떻게해야합니까? 새로운 마스터를 선택하는 메커니즘이 있습니까? 감사합니다.

    0

    1답변

    스프링 부트 배치 XML을 Java Config로 변환하기. 아래 코드를 Java Config로 변경하십시오. <batch:job id="batchJob1"> <batch:step id="step"> <batch:tasklet task-executor="taskExecutor" throttle-limit="${throttle.limit}

    -1

    1답변

    나는 rabbitmq 대기열에서 읽어야 만하는 작업을 데이터 저장소에 씁니다. 현재 큐에서 메시지를 읽는 데 AmqpItemReader을 사용하고 있습니다. 읽은 데이터는 Json 형식이며 모든 내 ItemProcessor은 json을 Java 객체로 직렬화합니다. 단일 스레드 솔루션의 성능이 매우 낮습니다. 나는 초당 12ms의 속도로만 소비 할 수있다.

    0

    1답변

    스프링 배치에 문제가 있습니다. 작업에서 두 ​​개의 병렬 단계 흐름을 처리하는 작업 실행자 (simpleAsyncTaskExecutor)를 사용하고 있습니다. 각 단계에서 가 작업 실행을 다른 스레드로 판독기에 의해 반환 된 데이터의 각각의 청크 분할 : 문제는 우리의 투입 간격이 큰 것을 을 (멀티 스레드 단계 개념을 사용하여 https://docs.s

    0

    1답변

    스프링 데이터베이스를 사용하여 DB2 데이터베이스를 읽고 mongoDB로 데이터를 복사해야한다. mongoDB에 데이터를 쓸 것이므로 트랜잭션이 필요 없다. DB2에서만 mongoDB에 메타 데이터 테이블 스크립트를 보관하고 싶지만 mongoDB에 대한 메타 데이터 테이블 스크립트를 찾을 수 없습니다. 서버가 시작될 때 spring boot는 mongoDB

    0

    1답변

    XML 파일을 읽고 MySQL 데이터베이스에 쓰는 스프링 배치를 개발하려고합니다. 내 상황 구성 XML : 여기 에서 문제가되고있는 내 직업-config.xml 파일 :` http://www.springframework.org/schema/batch/spring-batch-2.2.xsd http://www.springframework.org/schema/b

    0

    2답변

    I 현재 스프링 배치 작업에 다음과 같은 처리가 : FlatFileItemReader가 포함 된 CSV 파일을 읽 프로세서는 몇 가지 작업 FlatFileItemWriter는 읽기의 미러를 생성하지 파일을 처리하지만 반영하도록 파일을 업데이트합니다. 새 파일에 쓰고 싶지 않지만 처리 중에 읽히는 동일한 파일을 업데이트하려고합니다. 제 질문은 Spring에서

    0

    1답변

    스프링 배치의 파티션 패턴을 따르고 있습니다. JVM 인수 또는 파일 스프링 application.properties에서 격자 크기를 할당 <batch:step id="master"> <batch:partition step="slave" partitioner="rangePartitioner"> <batch:handler grid-siz

    0

    2답변

    데이터베이스에서 대량 데이터를 읽으려는 경우 테이블을 동적으로 읽을 쿼리가 필요합니다 (테이블 이름은 구성 파일에서 선택됩니다) . 그리고 구분자를 사용하여 플랫 파일에 데이터를 씁니다. 테이블 이름 자체가 동적이기 때문에 어떤 행 매퍼/DTO/VO 클래스로도 이동할 수 없습니다. 맞춤 데이터를 읽고 일부 구분 기호로 플랫 파일에 쓰는 것은 어느 것입니다.

    0

    1답변

    CSV 파일을 읽고 다른 외부 시스템의 일부 데이터로 각 행을 풍부하게하고 새로운 CSHV를 일부 디렉토리에 작성하십시오. 이제 데이터를 가져옵니다. 외부 시스템에서 각 행을 하나씩 전달하고 외부 시스템에서 새 열을 가져와야합니다. 하지만 외부 시스템에서 각 행을 쿼리하려면 perticular 열의 모든 값을 보내 외부 시스템의 값을 전달해야합니다. 예 -