groovy - Spring XD with Groovy - 实时分析

Question

我们正在使用 Spring XD，获取一些 JSON 数据，需要创建 tap 并需要使用 groovy 脚本对记录求和..

还需要一些聚合函数，如 Min，Max 通过使用 groovy 脚本..

任何有想法的人喜欢如何做到这一点..

Answer 1

这是内置指标无法完成的事情吗？例如，丰富的仪表？

除此之外你可以

1) 将 groovy 脚本绑定到脚本、转换或过滤处理器模块。例如，

http://docs.spring.io/spring-xd/docs/1.0.0.M6/reference/html/#transform

这些模块使用spring-integration-groovy，因此脚本变量 headers 和 payload 会自动绑定到消息内容。

2）编写一个直接使用spring-integration-groovy脚本支持的自定义模块。