使用属性时 QueryRecord returns 错误 (Apache NiFi)

Question

我有一个简单的 FlowFile，其中包含 JSON:

{
  "name" : "ga:sessions",
  "val" : "0"
}

还有一些属性：

account.login = "some_email@gmail.com"
account.id = "123456789"

我想使用 QueryRecord 处理器来准备 JSON 以保存到数据库中。

但是我得到一个错误：

QueryRecord 从属性成功设置 account_login 但 returns 错误。问题是什么？如果我不在 QueryRecord SQL 语句中使用属性，我不会得到错误：

[{
  "metric_name" : "ga:sessions",
  "metric_value" : "0"
}]

如何解决？

Answer 1

为了让 QueryRecord 识别查询中的文字字符串值，您应该使用撇号。

您的查询应如下所示：

SELECT name AS metric_name,
val AS metric_value,
'${account.login}' as account_login
FROM FLOWFILE

QueryRecord returns error while using attributes (Apache NiFi)