childe / gohangout

使用 golang 模仿的 Logstash。用于消费 Kafka 数据,处理后写入 ES、Clickhouse 等。
MIT License
1.01k stars 234 forks source link

输入到clickhouse时,如何指定字段的值输入 #162

Closed jieshier closed 2 years ago

jieshier commented 2 years ago

--日志例子: { "http_host":"www.baidu.com", "fields":{ "log_source":"www.baidu.com", }, }

--现在我要指定 http_host 值等于 ”www.baidu.com“ 的数据才插入到clickhouse中

--我的gohangout配置测试: outputs:

--以上测试都试过了不行,请问应该怎么编写,感谢🙏

childe commented 2 years ago

'EQ($.http_host,"www.baidu.com")'