python - 带有 Python 引擎的 Nifi ExecuteScript 处理器未记录信息
问题描述
我用 Python 引擎实现了 Nifi ExecuteScript 处理器,我在 ExecuteScript 处理器中将脚本文件属性指向了我的 python 文件。在我的 python 代码中,我使用了 log.error('Error') 和 log.info('Hello') ,我只能在 nifi-app.log 文件中看到 log.error 并且 log.info 没有显示。
flowFile = session.get()
if flowFile != None:
try:
log.info('Info >> Python processor started') #1
log.error('Python processor started') #2
applicationId = flowFile.getAttribute('http.param.applicationId')
flowFile = session.write(flowFile, ModJSON())
flowFile = session.putAttribute(flowFile, "filename",
flowFile.getAttribute('filename').split('.')[0] + '_translated_response.json')
flowFile = session.putAttribute(flowFile,"http.param.applicationId",applicationId)
session.transfer(flowFile, REL_SUCCESS)
log.error('Python processor completed')
except:
log.error('Error while sequencing ')
session.transfer(flowFile, REL_FAILURE)
session.commit()
从上面的代码行 #2 显示日志文件中的错误,但行 #1 没有被记录
解决方案
请检查日志级别/<nifi installation path>/conf/logback.xml
。我认为您的处理器日志级别warn
不是info
。
推荐阅读
- python - 使用 VBA/Python 在 Excel 中格式化和修改字符串
- android - 与底层屏幕/路由通信
- pdf - 没有页面树的pdf结构
- android - 如何使用 OKHttp3 库将 JSON 数据发送到 android 中的服务器
- javascript - Angular 6 服务未能通过单元测试 (NullInjectorError: No provider for HttpClient!)
- javascript - 无法从“for”语句中获取修改后的数组
- java - 我如何实现限制对 REST API 的访问速率
- python - PYTHON:删除某些行后将一列拆分为多列
- node.js - nodejs获取来自控制台但未分配给变量的响应
- html - 自定义允许在弹性矩阵中展开一行的弹性项目