NIFI Executescript UT C Ошибка для неподдерживаемого типа операнда "+" в java. sql .Timestamp и timedelta

Question

Я пытаюсь разделить потоковый файл на несколько потоковых файлов на основе добавления месяца к дате, которую я получаю в следующем потоковом файле.

например. {"to": "2019-12-31T00: 00: 00Z", "from": "2019-03-19T15: 36: 48Z"} даты, которые я получаю в файле потока. поэтому я должен разделить этот единственный файл потока на 11 потоковых файлов с диапазонами дат, таких как

{"to":"2019-04-19","from":"2019-03-19"}
{"to":"2019-05-19","from":"2019-04-19"} 
{"to":"2019-06-19","from":"2019-05-19"}
....... and so till
{"to":"2019-12-31","from":"2019-12-19"} .

. 1008 *

 begin = '2018-02-15'
 end = '2018-04-23'
 dt_start = datetime.strptime(begin, '%Y-%m-%d')
 dt_end = datetime.strptime(end, '%Y-%m-%d')
 one_day = timedelta(days = 1)
 start_dates = [dt_start]
 end_dates = []
 today = dt_start
 while today <= dt_end:
     tomorrow = today + one_day
 print(tomorrow)

`

, но я получаю ошибку в моем обработчике сценария выполнения. скриншот потока nifi

Answer 1

Поскольку вы используете Jython, вам может потребоваться привести today к некоторой переменной времени Jython / Python или вызвать today.getTime() для выполнения арифметических c операций над ней.