Я новичок в apache nifi и использую графический редактор для создания потока данных. Я пытаюсь прочитать данные из Dynamodb и обработать эти данные. Мой поток выглядит так:
Итак, для целей тестирования я пытаюсь записать запись Dynamodb в putFile, если запросы выполнены успешно, в противном случае вывод будут отправлены в узлы вывода.
У меня есть следующие вопросы:
- Почему GetDynamoDB нуждается во входном узле, когда мы пытаемся читать данные из DynamoDB внутри процессора, насколько я понимаю. И как мне его настроить?
- Когда я запускаю поток, все записи запускаются без ошибок или, по крайней мере, я не вижу ошибки, но всегда есть чтение / запись 0 байтов, а также In вход. Когда я обновляю sh страницу, я иногда вижу, что в некоторых узлах выполняется поток, но больше ничего не происходит.
Есть ли правильный способ отладки потока и как определить, что происходит не так, если во время выполнения потока не возникает исключения.