spring-xd

0열

1답변

스플리터와 애그리 게이터를 작성하는 방법에 대해 String Cloud Data Flow (Stream XD 제외)와 관련된 몇 가지 예제를 가리킬 수 있습니까? 특히 사소한 메시지 분리 및 결합. 복잡하지 않은 스트림의 예입니다. 분할 후 메시지를 집계하는 스트림을 어떻게 정의합니까? 생성 된 메시지에 대해 라우터와 다른 처리가있는 경우, 나중에 어떻게

1열

1답변

RabbitMQ를 통해 전송되는 json 문자열의 Spring XD 필드 값 카운터를 가져올 수 없습니다.

json 문자열의 필드 값 카운터를 사용하는 Spring XD 스트림을 작성하려고합니다. Json 문자열은 application/json의 Content-Type 헤더가있는 RabbitMQ 대기열을 통해 메시지로 전송됩니다. Spring XD는 메시지 (Json 문자열)를 기록하고 파일에 기록하지만 필드 값 카운터를 반환하지 않으며 스프링 xd 쉘 (xd

0열

1답변

Spring XD : 스트림 배포를 취소 할 때 처리중인 메시지를 처리하는 방법

스트림 배포 취소 작업이 진행되는 동안 메시지를 다시 큐에 추가 할 수 있습니까? 배포가 진행되는 동안 프로세서가 느린 RabbitMQ에서 처리되지 않은 메시지가 10 개 있다고 가정 해 봅시다. 디스패처에 구독자가 없어서 메시지가 DLQ로 전달되지 않도록하려면 어떻게해야합니까? 입력 프로세서 큐에서 대기 중입니까?

0열

1답변

Spring-XD 작업 메일 알림

우리는 Spring-XD를 사용하여 매일 거의 작업을 수행하지 않고 작업이 실패 할 수도 있습니다. Spring-XD에는 작업의 세부 정보를 보여주는 대시 보드가 있으며 작업의 세부 정보를 가져 오는 데 사용할 수있는 REST API도 있습니다. 우리는 작업 실패 또는 모든 작업의 상태가 포함 된 메일의 발송이있을 때 메일 알림을 보내이 프로세스를 자동

0열

1답변

Spring-XD에서 인라인 속성을 읽는 법

아래 스트림을 사용하고 있습니다. 아래에 표시된대로 --properties 값을 전달하고 있습니다. stream create myFirstStream --definition "file --dir=C:\\\\input --outputType=text/plain | splitter --expression=payload.split('\\n') > sample-a

0열

1답변

SpringXD : seprate 줄에서 작업 정의를 만드는 방법

매우 긴 작업 정의가 있습니다. 쉽게 읽을 수 있도록 여러 줄로 구분하는 방법이 있는지 궁금합니다. 나는 '\'로 시도 또는 '\ n'을하지만 그들은 모두 예를 들어, 일자리 창출에 실패한 : xd:>job create --name myHttpJob --definition "httpJob \n job create --name myHttpJob

0열

1답변

봄 XD 동적 모듈 클래스 로더 문제

우리가 .properties 파일의 속성module.classloader을 이용하여 동적 모듈 작성시 항아리를로드 할 수있는 문서에 따르면 http://docs.spring.io/spring-xd/docs/1.3.1.RELEASE/reference/html/#module-class-loading 이틀 동안 이 기능을 테스트하려고합니다. 작동하지 않습니다.

0열

1답변

Bigdata 용 Spring-XD 스프링 응용 프로그램

저는 Spring-XD에 익숙하지 않으며 거대한 데이터를 파일로 저장하는 데 도움이된다는 기본적인 아이디어 만 가지고 있습니다. hadoop에 Spring-XD를 사용하여 소켓에 들어오는 데이터를 저장하는 애플리케이션을 개발하고 싶습니다. 이것이 가능합니까? 그렇다면 누구나 어디서 몇 가지 예를들 수 있습니까? 나를 https://github.com/spr

0열

1답변

Spring-xd-batch 작업 잠금

배치 작업을 통해 데이터를 처리하기 위해 spring-xd를 사용하고 있습니다. 좋은 수의 작업이 4 개의 컨테이너에서 병렬로 실행됩니다. 10 ~ 40 개의 직업이있는 곳. 이 중 대부분은 1 분 안에 완료됩니다. 데이터 저장소에 redis (rabbitmq 아님)와 mysql을 사용하고 있습니다. Spring-xd-batch는 작업/스텝 통계를 위해 다

0열

1답변

springxd - [클래스 이름]을 직렬화 할 수 없습니다. 클래스가 없습니다.

springxd를 사용하는 avro에서 ESB JMS 대기열에서 HDFS로 데이터를 저장하는 중에이 문제가 발생합니다. JMS Queue에서 인바운드 XML을 구문 분석하고 avro로 변환하고 springxd 스트림을 사용하여 HDFS에 저장하는 사용자 정의 프로세서를 만들었습니다. 여기 stream create --name NewStream --defin