Запустите процессор NIFI, используя Python SDK Apache Nifi. ⇐ Python
Запустите процессор NIFI, используя Python SDK Apache Nifi.
У меня есть код Python, который пытается пройти аутентификацию на моем сервере Nifi, используя имя пользователя и пароль, чтобы запустить внутри него процессор. Ниже мой код:
из фляги импорта Flask импорт нипьяпи запросы на импорт приложение = Колба(__name__) @app.route('/') защита дома(): nifi_url = "https://mynifiinstance:port/nifi-api/access" идентификатор_процессора = nifi_general = "https://mynifiinstance/nifi-api" start_processor_url = f"{nifi_general}/processors/{processor_id}/run-status" заголовки = {'Content-Type': 'application/x-www-form-urlencoded'} имя пользователя = "имя пользователя" пароль = "пароль" данные = { "имя пользователя": имя пользователя, «пароль»: пароль } ответ = запросы.post(url=nifi_url, data=data,verify=False, headers=headers) если ответ.код_статуса == 200: # если аутентификация прошла успешно, то запускаем процессор start_processor = Requests.put(url=start_processor_url, headers=headers) печать (start_processor.status_code) если start_processor.status_code == 200: return("Процессор успешно запущен.") еще: return(f"Ошибка запуска процессора. Код состояния: {start_processor.status_code}") еще: return(f"Не удалось запустить процессор. Код состояния: {response.status_code}") если __name__ == '__main__': приложение.run() Однако я не могу пройти аутентификацию и получаю в ответ код 201. Примечание: я не вносил никаких изменений в файл nifi.properties. Нужно ли его менять? Ждем ваших ответов.
У меня есть код Python, который пытается пройти аутентификацию на моем сервере Nifi, используя имя пользователя и пароль, чтобы запустить внутри него процессор. Ниже мой код:
из фляги импорта Flask импорт нипьяпи запросы на импорт приложение = Колба(__name__) @app.route('/') защита дома(): nifi_url = "https://mynifiinstance:port/nifi-api/access" идентификатор_процессора = nifi_general = "https://mynifiinstance/nifi-api" start_processor_url = f"{nifi_general}/processors/{processor_id}/run-status" заголовки = {'Content-Type': 'application/x-www-form-urlencoded'} имя пользователя = "имя пользователя" пароль = "пароль" данные = { "имя пользователя": имя пользователя, «пароль»: пароль } ответ = запросы.post(url=nifi_url, data=data,verify=False, headers=headers) если ответ.код_статуса == 200: # если аутентификация прошла успешно, то запускаем процессор start_processor = Requests.put(url=start_processor_url, headers=headers) печать (start_processor.status_code) если start_processor.status_code == 200: return("Процессор успешно запущен.") еще: return(f"Ошибка запуска процессора. Код состояния: {start_processor.status_code}") еще: return(f"Не удалось запустить процессор. Код состояния: {response.status_code}") если __name__ == '__main__': приложение.run() Однако я не могу пройти аутентификацию и получаю в ответ код 201. Примечание: я не вносил никаких изменений в файл nifi.properties. Нужно ли его менять? Ждем ваших ответов.
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение