Я получаю поток журналов HTTP-запросов с удаленного сервера и хочу создать совокупный счетчик для наблюдения за трафиком. Я получаю строку JSON, содержащую поле «отметка времени» в формате SQL:
{"timestamp": "2015-08-12 23:21:13", ...}
У меня есть поток под названием «тик» с определением:
time --fixedDelay=1 | script --script=Puller.groovy | json-to-tuple | null
Я создаю совокупный счетчик:
tap:stream:tick.json-to-tuple > aggregate-counter --name=lcnt --timeField=payload.timestamp
Как я могу преобразовать значение поля в приемлемый формат и какой это формат?
