putelasticsearchhttprecord:封装的令牌和分隔符之间的字符无效

xu3bshqb  于 2021-06-20  发布在  Mysql
关注(0)|答案(1)|浏览(227)

我正在尝试使用querydatabasetable->updateattribute->putelasticsearchhttprecord从数据库中获取特定记录
es处理器在封装的令牌和分隔符之间抛出错误java.io.exception invalid char。
请找到附件我的配置。如何解决这个问题?在“updateattribute”之后,我在队列中得到了正确的结果,但无法将其推入es。我已将schema.name属性添加到相应的schema中。以下是updateattribute processor之后我在队列中得到的正确结果。如何修复标记和分隔符之间的无效字符错误?

[ {
  "TimeOfDay" : "2018-09-20T18:10:36.941",
  "BMU_Debug_Pack_BlkVolt_Max2" : 4114.0,
  "BMU_Debug_Pack_BlkVolt_Max1" : 4114.0,
  "BMU_Debug_Pack_BlkVolt_Max3" : 4114.0,
  "BMU_Debug_Pack_BlkVolt_Max0" : 4116.0,
  "BMU_Debug_Pack_CTemp_Min" : 21.0,
  "BMU_Debug_Pack_CurrVolt_Curr" : 2.0,
  "BMU_Debug_Pack_Blk_Volt_Delta" : 6.0,
  "total_Difference" : 15.0
} ]

谢谢您!请帮忙我该换什么?




7hiiyaii

7hiiyaii1#

您需要配置avro reader而不是 CSV Reader 在putelasticsearchhttprecord中 Querydatabase 表处理器以avro格式输出flowfile。
使用 embedded avro schema 在avro读控制器服务中。

相关问题