NiFi执行PutSQL Delete时日期转Timestamp失败求助

核心原因 #

NiFi的ConvertJsonToSQL处理器默认的日期/时间戳解析格式与你的'2023-03-28 15:54:28'字符串不匹配，导致它无法将该字符串正确转换为JDBC能识别的timestamp类型；而手动执行时MySQL会自动兼容该格式，因此不会报错。

解决方案 #

• 显式配置ConvertJsonToSQL的日期格式
  打开ConvertJsonToSQL处理器的配置界面，找到Date Format和Timestamp Format属性，将两者都设置为yyyy-MM-dd HH:mm:ss。这样处理器会按照你提供的时间字符串格式解析，正确映射到MySQL的datetime类型参数。

• 绕过自动转换，手动构造SQL语句
  放弃使用ConvertJsonToSQL，改用ReplaceText或ExecuteScript（比如Groovy/Python脚本）从JSON中提取时间值，直接拼接成完整的Delete语句。示例SQL拼接逻辑：

  DELETE FROM your_target_table WHERE your_datetime_column = '${json:path("$.your_date_key")}'
  

  拼接完成后直接传给PutSQL执行，避免NiFi的参数类型自动转换逻辑干扰。

• 调整JDBC连接的时区配置
  在PutSQL处理器的JDBC URL末尾添加时区参数，确保NiFi与MySQL的时区一致，示例：

  jdbc:mysql://your_host:3306/your_db?useSSL=false&serverTimezone=Asia/Shanghai
  

  时区不匹配也可能导致日期解析异常，统一时区后能避免这类问题。

• 提前格式化日期字符串
  如果JSON中的日期格式本身没问题，但NiFi仍解析失败，可以先用UpdateAttribute处理器提取日期字符串并强制格式化：

  formatted_date = ${json:path("$.your_date_key"):format("yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm:ss")}
  

  将格式化后的formatted_date传入ConvertJsonToSQL，确保处理器能识别格式。

内容的提问来源于stack exchange，提问作者santhosh