spring-xd

    1

    1답변

    예를 들어, I '는 myprocessor'로서 구성 모듈 만들려 : xd> module compose myprocessor --definition "processor1 | processor2 | processor3". 또한, 난은 또한 프로세서 1, processor2 수 있도록하고자 할 processor3를 4 : 2 : 1 작성된 모듈에서 모든 통

    1

    1답변

    분산 설치에서 프로그래밍 방식으로 컨테이너를 시작하려면 어떻게해야합니까? 더 구체적으로, 컨테이너를 설치 및 해제하기 위해 스트림 배포 및 배포 취소와 유사한 API가 있습니까?

    0

    1답변

    Redis LIST에서 읽은 Spring XD 실패 메시지를 읽고 일괄 처리 워크 플로를 통해 다시 처리하려고합니다. Redis ItemReader를 사용할 수 있습니까? 배치에 대한 GitHub 레포를 확인했는데 찾을 수 없습니다. 감사합니다

    1

    2답변

    HTTP 소스와 HDFS 싱크 사이에 스트림을 만들려고합니다. 내 springXD와 HDFS는 다른 컴퓨터 **에 설치되었지만 hadoop fs ls / 명령을 성공적으로 실행할 수 있습니다. http post --target http://{ipaddressofhdfsmachine:8020} -- data"hello" 그것은 오류를 던지고있다 : fai

    1

    1답변

    Sring Xd가 분산 모드로 실행 중이며 이제는 몇 가지 JMeter 테스트를 실행하기 시작했습니다. 제 질문은 생성 된로드가 분산 모드에서 컨테이너간에 분산되도록하는 방법에 관한 것입니다. 100 명의 사용자에 대해 각각 1000 개의 메시지를 생성하는 경우 두 개 이상의 컨테이너 사이에서 트래픽을 나누고 싶습니다. 이것이 가능합니까? 또는 한 컨테이너

    1

    1답변

    스프링 XD를 테스트하려면 프로젝트 웹 페이지에서 간단한 트위터 스트림 자습서를 따르십시오. 튜토리얼은 단일 코드 스프링 XD를 실행하고 파일을 스트림 정의에서 싱크 (sink)로 사용합니다. 문제없이 튜토리얼을 실행할 수있었습니다. XD 버전은 1.0.0.M7입니다. 나중에 rabbitmq를 사용하기로 결정하여 동일한 기계에 rabbitmq (Rabbit

    2

    1답변

    나는 센서 데이터를 지속적으로 섭취하기 위해 Spring XD를 사용하고 있으며 완벽하게 작동합니다. 내가 가진 새로운 요구 사항은 해당 데이터의 일부를 "재생"하는 것입니다. 특정 경우에 MongoDB에서 (특정 쿼리와 함께) 읽는 것입니다, 항목의 특정 분야와 UDP 패킷을 생성하고 시간의 고정 된 간격으로 SocketAddress로 보냅니다. 내가 구

    2

    1답변

    스프링 XD 문서 (http://docs.spring.io/spring-xd/docs/1.0.0.RC1/reference/html/)는 사육사가 높은 이용도를 유지할 수 있도록 사육사가 앙상블로 운영되도록 권장합니다. 고 가용성에 대한 Redis에 대한 자세한 내용은 많지 않습니다. 나는 2 개 XD 관리자 인스턴스를 실행하고 4 컨테이너 인스턴스를 말한다

    2

    1답변

    시나리오 : 스프링 xd의 스트림 정의의 구조는 다음과 같습니다. jms | 필터 | 변형 | hdfs 필터 모듈에서 데이터베이스에 쿼리를 실행하여 현재 메시지가 추가 처리에 적용 가능한지 확인합니다. 조건이 충족되면 메시지는 변환 모듈로 전달됩니다. 변환 모듈에서 필터 모듈의 쿼리 결과에 액세스하고 싶습니다. 현재 같은 결과 집합에 액세스하기 위해 변환

    4

    1답변

    스프링 XD 문서를 상당히 많이 읽었으므로 하둡 원사와 관련하여 달성하고자하는 두 가지 사항을 실제로 파악할 수 없습니다. 은 어쩌면 그들은 아직 지원되지 않거나 적 지원되지 않습니다 - 나는 그것이 ApplicationMaster 가능하다 하둡 YARN에서 내 시나리오가 아닌 sensical하게 뭔가 ... 을 잃었 가능성이 있기 때문에 컨테이너를 특정