logstash filter内如何对多个相似字段做数据类型转换

Logstash | 作者 linxiao | 发布于5 天前 | 阅读数:64

mysql内有个流水表,内含d1,d2,d3...d365字段,因为字段值存储的是金额,是mysql的float类型,所以想在filter内对这300+的字段进行由float类型转换为string类型。但是不知道filter内该如何实现,求大神们能指点一二,自当感激不尽。
已邀请:

Ombres

赞同来自:

logstash并不能决定es中数据的存储类型
 
如果想要实现这种功能,我的建议是在es中自定义mapping,将这些字段定义为text或者keyword类型,下为示例
 
PUT test_index
{
"mappings": {
"dynamic_templates": [
{
"full_name": {
"path_match": "d*",
"mapping": {
"type": "text"
}
}
}
]
}
}
POST test_index/_doc
{
  "d11":11111
}

最终,d11这个字段为text

要回复问题请先登录注册