mysql - 在NIFI中使用putdatabaserecord将数据放入MySQL

Question

我有一个流程 Getfile -> PutDatabaseRecord 并且我有一个 CSV 字段如下:

模块编号、位置、机器名称、机器类型

我想在我的数据库表“测试”中提取这些字段的值，该表的字段描述为:

模组编号、位置、机器名称、机器类型

这里是字段名称的更改。在 Putdatabaserecord 中设置什么设置才能成功地将数据提取到 mysql 表中。

现在我收到错误消息，因为模块号不能为空。如何修复原始 CSV 和 MySQL 表中 header 名称的更改。谢谢!

Answer 1

在 PutDatabaseRecord 中，您可以将架构配置为使用数据库中出现的字段名称，并忽略 header 名称(略有不同)。如果您使用 Get String Fields From Header 作为架构访问策略，请将其更改为 Use Schema Text 并将以下内容放入 Schema Text 属性中:

{
 "namespace": "nifi",
 "name": "machine",
 "type": "record",
 "fields": [
  {"name": "Module_No","type": "string"},
  {"name": "Pos","type": "string"},
  {"name": "Machine_Name","type": "string"},
  {"name": "Machine_Type","type": "string"}
 ]
}

然后将 Treat First Line As Header 设置为 true 并将 Ignore CSV Header Column Names 设置为 true。然后将使用与数据库中的列匹配的显式字段名称读取记录，并且处理器应该可以正常工作。