Logstash JDBC - 如何处理json字段？

Question

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

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

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

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

它有value和type属性.

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

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

我一定错过了一些非常明显的东西吗？

Answer 1

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

SELECT travelers_json::TEXT from xxx

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