2016-07-13 5 views
0

Я пытаюсь извлечь данные из базы данных oracle через Nifi. В холсте я поставил процессор «GenerateFlowFile» с размером файла 0 КБ, который должен запускаться каждые 5 мин. Это просто для успешного запуска процессора ExecuteSQL. Для «ExecuteSQL» я установил Службу объединения пулов DB DBCConnectionPool. Я ввожу SQL-запрос «SELECT * FROM SOMETABLE». Моя конфигурация DBCPConnectionPool выглядит следующим образом:ExecuteSQL ничего не делает

URL = jdbc:oracle:thin:@hostname:port:sid 
Driver = oracle.jdbc.driver.OracleDriver 
Jar URL = file:///somelocation/ojdbc6.jar 
User = someuser 
Password = somepassword 

Когда я пытался бежать, ничего не происходит. Красное поле становится зеленым, а в верхнем правом углу процессора «ExecuteSQL» есть номер 1. Но ничего не происходит. Затем, когда я его останавливаю, все еще активные темы - 1.
Можете ли посоветуете мне, потому что я новичок в этом? Спасибо.

+0

Вы проверили файлы журнала NiFi? –

+0

Какая версия NiFi? и насколько велика таблица, которую вы выбираете? Похоже, он висит на соединении или занимает очень много времени. Как долго вы ждали, чтобы проверить, завершено ли это? –

+0

Извините, я выбирал из очень большого стола, поэтому я думал, что ничего не происходит. Я попытался выполнить запрос из маленькой таблицы, и это работает, но дело в том, что он продолжает запрашивать один и тот же набор записей. как я могу остановить его для запроса, если это только тот же набор записей? – iPhoneJavaDev

ответ

1

Поскольку исходное сообщение ответа, я отвечу на этот вопрос в своих комментариях:

Вы можете установить процессор GenerateFlowFile для запуска каждые 30 секунд или около того, а затем начать и немедленно остановить его. Это заставит ExecuteSQL работать ровно один раз, извлекая все строки.

В качестве альтернативы (в NiFi 0.6.0+) вы можете использовать процессор QueryDbTable, который будет извлекать все строки в первый раз, но затем (на основе столбца максимального значения, такого как увеличивающий первичный ключ) возвращает только строки, поскольку они добавлены.

Смежные вопросы