spring-batch

0열

1답변

내 데이터가 에 있고 Mysql에있는 유스 케이스가 있습니다. MySQL의 새로운 행 삽입마다 새로운 데이터에 대한 분석을 수행해야합니다. 나는 현재이 문제를 해결하고 어떻게하면입니다 : 내 응용 프로그램은 모든 후 데이터베이스 에 입력 된 새 행을 검사 내가 스케줄러을 사용하고있는 봄 부팅 응용 프로그램입니다 2 초. 현재의 접근 방식의 문제는입니다 :

2열

1답변

Spring 배치의 JdbcPagingItemReader에서 limit 및 offset 절을 사용하는 방법은 무엇입니까?

테이블에 2 억 개가 넘는 레코드가 있지만 상위 5 백만 레코드를 선택해야합니다. 나는 jdbcCursorItemReader를 사용하여 2-3 시간을 선택하여 처리하고 청크 처리로 단일 단계를 사용하여 CSV 파일에 쓰려고 했으므로이 봄은 일괄 처리로 처리되도록 선택했다. 나는 taskExecutor 및 JdbcPagingItemReader를 각각 백만개의

0열

1답변

예외를 얻기

내 데이터 소스의 구성은 다음과 같습니다 dataSource.setUrl("jdbc:redshift://spx....redshift.amazonaws.com:5439/spx"); dataSource.setUsername("spx"); dataSource.setPassword("*****"); 얻기 예외 : - 2017-10-06 15:58:58.67

0열

1답변

파일 판독기에서 파일 작성기 스프링 배치로 파일 이름 전달

폴더에서 여러 파일을 읽습니다. 파일 이름이 test1.txt, test2.txt, test3.txt와 같다고 가정하십시오. 이 파일 이름을 작성자에게 전달하고 'test1.xml' 'test2.xml' 'test3.xml과 같은 출력 파일 이름을 생성하려고합니다. 이에 어떤 도움을 주셔서 감사합니다. @Autowired public StepBuilder

0열

1답변

어떻게 방지합니까? ListenerExecutionFailedException : 리스너가 예외를 던졌습니다.

RabbitMQ에 의해 아마도 throw되는 다음 예외를 방지하려면 어떻게해야합니까? 내가 병렬로 다음 코드는 스프링 배치 작업을 실행하려면 실행 둘 다 봄 부팅 응용 프로그램의 두 인스턴스가 org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listene

0열

1답변

일괄 처리의 대기열 작업 인스턴스

다른 시스템에서 트리거 된 요일마다 일괄 처리 작업이 실행됩니다. 때로는 같은 날에 실행해야 할 작업의 인스턴스가 여러 개 있습니다. 각각은 다른 시스템에서 트리거되었습니다. 모든 작업은 약 한 시간 동안 실행되며 실행할 작업 인스턴스가 여러 개인 경우 데이터에 몇 가지 문제가 발생합니다. 작업 인스턴스가 실행 중이 아닌 경우이 인스턴스를 실행중인 작업 인

0열

1답변

Spring 배치에서 ItemWriter의 매개 변수를 SkipListener로 전달하는 방법은 무엇입니까?

스프링 일괄 작업에서 itemWriter가 오류를 작성하는 동안 건너 뛴 경우 그리고 ItemSkipListener가 그것을 수신하고 항목을 파일에 기록합니다. 내 항목에는 목록 데이터가 하나 있으며 목록의 어떤 요소가 오류인지 확인하고 싶습니다. 그러나 ItemSkipListener에서 항목 및 throwable 만 알 수 있습니다. (목록의 어떤 요소인

0열

1답변

스프링 통합 : 여러 sftp 서버를 연결하는 데 필요한 솔루션/팁?

내 스프링 배치 프로젝트는 여러 SFTP 서버에서 파일을 다운로드해야합니다. sftp host/port/filePath는 application.properties 파일에서 구성됩니다. 나는이 서버와 파일을 연결하기 위해 스프링 통합 'sftp 아웃 바운드 게이트웨이'를 사용하는 것을 고려한다. 하지만 나는 이런 종류의 구성 (나는 자바 설정을 사용하고있다)

0열

2답변

자바 8 병렬 스트림과 스프링 배치 사이의 비교

다른 응용 프로그램에서 메시지를 넣을 대기열이 하나 있는데 응용 프로그램에서 대기열을 폴링하고 모든 메시지를 가져 와서 다른 객체로 변환하고 데이터베이스에 보관합니다. 그래서이 두 가지 접근 방법이 있습니다 1. 스프링 스케줄러를 사용하고 모든 메시지를 5 초마다 폴링 한 다음 java 8의 병렬 스트림을 사용하여 모든 스트림이 독립적 인 데이터베이스를 유

0열

2답변

스프링 배치에서 입력으로 수천 개의 jpeg 파일 이름 읽기

스프링 배치를 사용하고 일괄 처리에 대한 작업을 정의하고 있지만 문제는 입력으로 특정 디렉토리에서 80.000 jpeg 파일의 이름을 읽어야한다는 것입니다. 청크 당 1000을 읽으 려합니다. 나는 Spring integration에 대해서도 들었지만, 이것이 올바른지 아닌지는 모른다. 제가 올바른 접근 방식을 취하고 있는지 확인하려면 안내해주십시오. 감사