NiFi QueryRecord处理器 Select 可选的JSON属性

发布于12月13日

我有几个JSON对象通过一个QueryRecord处理器.我想从中提取一些属性，包括一些可选的.问题是 Select 一个可选属性会导致一个错误，指出该列在表中不存在.

我try 了一个使用100的解决方案，看起来像这样:

SELECT is_answered,
       view_count,
       answer_count,
       score,
       last_activity_date,
       creation_date,
       question_id,
       title,
       CASE
         WHEN HAS_PATH(flowfile, '/last_edit_date') THEN
          RPATH(flowfile, '/last_edit_date')
         ELSE
          NULL
       END AS last_edit_date
  FROM flowfile

在这种情况下，100是一个可选属性.但是，这会抛出一个错误，即101列不存在.我试图找到另一种解决方法，它不会在select语句中包含101，但是我找不到任何东西.对于如何解决这个问题有什么 idea 吗

推荐答案

QueryRecord的SQL部分使用FlowFile的内容，因此HAS_PATH在记录中查找该字段，而不是属性.相反，使用表达式语言(可能是isEmpty()函数)来生成查询的该部分，可能如下所示:

SELECT is_answered, 
  view_count, 
  answer_count, 
  score, 
  last_activity_date, 
  creation_date, 
  question_id, 
  title,
  CAST("${last_edit_date:isEmpty():ifElse(null,${last_edit_date})}" AS DATE) AS last_edit_date
FROM FLOWFILE

我没有对此进行测试，但它应该会让您大致了解如何使用表达式语言获取属性并将值注入到查询中.