Spring XD聚合计数器时间字段格式

Question

我正在从远程服务器获取 http 请求日志流，并希望创建一个聚合计数器来观察流量。我得到 JSON 包含字段 "timestamp" 的字符串 SQL 格式：

{"timestamp": "2015-08-12 23:21:13", ...}

我有一个名为 "tick" 的流，其定义为：

time --fixedDelay=1 | script --script=Puller.groovy | json-to-tuple | null

我正在创建一个聚合计数器：

tap:stream:tick.json-to-tuple > aggregate-counter --name=lcnt --timeField=payload.timestamp

如何将字段值转换为可接受的格式，这是什么格式？

Answer 1

我想，我没有对文档给予应有的关注。 aggregate-counter 有一个带有 SimpleDateFormat 语法的 dateFormat 参数。所以，最终的解决方案是这样的：

tap:stream:tick.json-to-tuple > aggregate-counter --name=lcnt --timeField=payload.timestamp --dateFormat='yyyy-MM-dd HH:mm:ss'

Spring XD aggregate counter timeField format