logstash - Logstash JDBC - 如何处理 json 字段？

Question

我有 postgresql，它将一些数据存储为 json 字段，例如：

{"adults":2,"children":{"total":0,"ages":[]}}

我正在使用 logstash-input-jdbc 插件来处理数据
我如何解析来自 jdbc 的 json？从日志中我看到这些字段作为 PGObject 到达：

"travelers_json" => #<Java::OrgPostgresqlUtil::PGobject:0x278826b2>

其中有 avalue和type属性。

我尝试过使用 json 过滤器，但我不知道如何访问该value属性以提供给 json 过滤器？我试过的：

 source => "[travelers_json][value]"
 source => "travelers_json.value"
 source => "%{travelers_json.value}"

我必须在这里遗漏一些非常明显的东西？

score 0 · Accepted Answer

好的，所以最简单的方法是在 postgresql 中将 json 转换为文本：

SELECT travelers_json::TEXT from xxx

但我仍然想知道如何访问那个 PGobject

1 回答 1