spring-cloud-dataflow

2열

1답변

Spring Cloud Stream JMS ActiveMQ를 만드는 방법

최근 Spring에 jms (ActiveMQ 가상 대상)를 활용하는 스프링 클라우드 스트림 공급자의 알파 버전이 있음을 발견했습니다. 이것은 절대적으로 매력적이며 그것을 테스트하고 싶습니다. 내가 사용할 수 있거나 올바른 github 프로젝트를 생성하고 빌드 할 수있는 종속성의 스냅 샷을 찾는 데 어려움을 겪고 있으므로 로컬 저장소에 종속성이 있습니다. 이

0열

3답변

PCFDev Spring Cloud Data Server 앱 가져 오기 실패

프록시가있는 회사 환경에 PCFDev를 설치했습니다. 모든 프록시 환경이 설정되어 있고 명령 줄에서 maven repos를 얻을 수 있습니다. 그러나 SCDF 서버에서는 Maven Repo에 도달하지 못하는 것 같습니다. 시스템 제공 환경 변수가 올바르게 { "staging_env_json": { "HTTP_PROXY": "XXX",

0열

1답변

spring-cloud-dataflow-kubernetes 앱 메모리 한도

배포 속성을 spring.cloud.deployer.kubernetes.limits.memory=300Mi으로 설정했습니다. 그러나 스트림을 배포 한 후 메모리 제한을 docker stats으로 확인했지만 여전히 xxx/640Mi을 반환했습니다. source code을 조사한 결과 코드에서 일부 디버그 로그가 인쇄 될 수 있음을 알았습니다. 그러나 LOGG

0열

1답변

Spring Cloud 데이터 흐름 애그리 게이터 예제

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

0열

1답변

봄 구름의 흐름 응용 프로그램 HTTP 내가 배치 된 홍채 PA 예제를 SCDF을 테스트입니다 (401) 무단

반환 "HTTP를 | PMML | 로그인"예를 하지만 서버에 요청을 게시 할 때, 나는 항상 가지고 : :이 구성 application.properties 파일을 추가 { "timestamp": 1484718462061, "status": 401, "error": "Unauthorized", "message": "Full

0열

1답변

Spring Cloud Dataflow 로컬 서버를 배포 할 수 있습니까?

나는 잠시 동안 SCDF를 사용 해왔고 XD와 SCDF 사이의 주요 차이점은 XD가 배포되기 위해 태어 났음을 깨닫지 만 SCDF는 SC 스트림 응용 프로그램을위한 플랫폼처럼 작동하는 것 같습니다. 적어도 로컬 서버는 그렇게 작동합니다. 제 질문은 scdf 로컬 서버를 배포 할 수 있습니까? 로컬 서버가 배포되는 추세가 없습니다. 이것에 대한 아이디어가 있

0열

1답변

기존 스트림의 집계 카운터

설정 한 다양한 스트림에 대한 집계 카운터를 만들려고합니다. SpringXD에서는 다음과 같이 보입니다 : "tap : stream : MyCustomStream> aggregate-counter". Spring Cloud Dataflow에서는 지금까지 "MyKafkaTopic> aggregate-counter"를 수행했는데, 이는 Kafka 소비자를 생성

0열

1답변

Spring Cloud Dataflow 서버용 Redis datasource

Spring Cloud Dataflow Service는 문서에 따라 RDBMS를 사용하여 스트림/태스크 정의, 애플리케이션 등록 및 작업 리포지토리를 저장합니다. RDBMS를 사용하는 대신 Redis를 사용하여이 정보를 저장하는 방법이 있습니다.

0열

1답변

Spring Cloud DataFlow - 작업 실행 후 실행 ID 얻기

현재 스프링 XD에서 내 워크 플로 및 런타임 환경으로 Spring Cloud DataFlow 및 Apache Airflow로 이동 중입니다. Airflow에서 워크 플로를 만들고 맞춤식 Airflow 연산자를 사용하여 Spring Cloud DataFlow 서버에서 Spring Cloud Tasks를 REST-API로 실행하려고합니다. 이 사용 가능 :

0열

1답변

Spring Cloud Dataflow가 버퍼링 된 메시지를 출력 채널에 보냅니다.

거부 된 메시지를 버퍼링하는 필터가 있습니다. 내 조건부가 만족되면 출력 된 채널에 버퍼링 된 메시지를 보내고 싶습니다. public class MyFilter implements MessageSelector { private Buffer buff; ... @Override public boolean accept