Spring Cloud Data Flow是用于构建数据集成和实时数据处理管道的工具包。管道由Spring Boot应用程序组成,使用Spring Cloud Stream或Spring Cloud Task微服务框架构建。这使得Spring Cloud Data Flow适用于各种数据处理用例,从导入/导出到事件流和预测分析。
spring-cloud-dataflow是否提供对任务的本地调度的支持?
您好,我想将调度程序添加到SCDF任务吗?在本地计算机服务器上可以吗?
我正在尝试了解有哪些可能的工具包/框架可用于实现以下目标。开发人员通常应在其中将数据流(一系列步骤)配置为...
我已经开发了一些Spring Boot项目,并且通过在我尝试使用的application.properties中使用spring.datasource.username和spring.datasource.password来启动数据库连接。
关于如何在多个专用服务器中创建部署spring-cloud-dataflow应用程序以创建流的建议
我正在尝试使用spring-cloud-dataflow在一组现有服务器上创建流。这不是生产环境,我知道“本地”部署程序的容错问题。我...
我如何将Spring Cloud Task与模块化Spring Batch作业一起使用?
我已经在Spring Boot Web应用程序中开发了几个Spring Batch作业。为了简化维护,我像这样使用@EnableBatchProcessing(modular = true):@Configuration @EnableBatchProcessing(...
是否限制Spring Cloud数据流中同时运行的任务总数?
每次我们启动一个spring cloud任务时,它都会启动一个新的jvm(java.exe),因此,如果启动了25个任务,那么它将启动25个jvm。我想知道如何限制所有任务的总数(...
无法将Message从Json String转换为Object。 ClassCastException
我正在使用SpringXD,其中我的Rabbit源具有outputType application / json。下一个模块将其接收并将其转换为Java Object。 RabbitMq是我的运输巴士。我的配置很漂亮...
Spring Dataflow流文件接收器-需要写入单独的文件
我一直在使用Spring Cloud Dataflow。我已经编写了一个定制的Cloud Stream Processor应用程序,该应用程序接收特定类型的XML文档,并将其拆分为较小的XML文档。 ...
我的项目基于Maven,如何使用Spring Boot将src \ main \ resources目录中的.xml文件包含到最终的jar包中
我想通过Spring Cloud数据流运行Maven项目,它说缺少项目中src \ main \ resources文件夹中存在的文件。请帮我如何包含src \ main \ ...的.xml文件?
Spring Cloud Data Flow:是否可以在没有任何消息传递中间件(kafka /兔子)的情况下运行,或者可以使用db而不是队列来运行?
我是Spring Cloud Data Flow的新手,我一直在阅读教程,尝试在本地设置项目。 (https://dataflow.spring.io/docs/installation/local/manual/)我是否正确假设...
我使用以下docker-compose -f ./docker-compose.yml \ -f ./docker-compose-rabbitmq.yml \ -f ./docker-compose-postgres.yml \ ..启动了spring-cloud数据流。 。
如何在Spring Cloud Data Flow中注册Spring批处理
我不知道如何注册应用程序。我遵循了很多指南,他们使用此示例进行了解释:dataflow:> app register --name fileIngest --type task --uri file:/// path / to / target / ...
如何在Spring Cloud Data Flow中使用过滤器?
我想在Spring Cloud Data Flow(SCDF)中添加一个过滤器进行调试,并查看它在接收某些请求时如何工作。我尝试实现javax.servlet.Filter并重写doFilter方法...
Http到定制处理器的流程抛出org.springframework.expression.spel.SpelEvaluationException:EL1004E
我有一个流http | customprocessor自定义处理器(UsageProcessor)的代码如下:public class UsageProcessor {private double ratePerSecond = 0.1;私人双人间...
在部署流应用程序之后(保持状态除外),数据流服务器和跳过程序是否具有任何活动角色。提出不同的要求,例如说我是否有http来源和...
如何在Spring Cloud Data Flow中保留日志文件?
我停止后,我的Spring Cloud Data Flow删除了文件夹中的日志文件。为什么SCDF会这样做,以及如何保留这些日志文件?
Spring cloud dataflow kubernetes部署通过属性
我有在kubernetes中运行的spring cloud dataflow应用程序。现在我需要传递新属性,例如模板元数据标签enableIdentityHelper作为流部署的一部分。下面是部署yaml ...
在minikube中安装后的Spring Cloud Dataflow UI异常
[嗨,我是Spring Cloud Dataflow的新手,正在尝试使用文档https://dataflow.spring.io/docs/installation/kubernetes/kubectl/在minikube中安装scdf,但是访问仪表板时,“ ...
Google Pub / Sub上的Spring cloud数据流
我已经使用过Spring Cloud数据流,rabbitmq和kafka,但我想知道是否可以在Google pub / sub中安装scdf。我不想创建一个流(新的应用程序春天...
无法正确设置httpclient的Spring Cloud Data Flow urlExpression
我使用Spring Cloud Data Flow解析了Twitter产生的JSON图像的URL,我想使用httpclient下载图像。这是管道:twitterstream --twitter.credentials.consumerKey = ...