如题所示,我利用logstash从mysql同步数据至es, 发现同字段es中的时间比mysql提前了5个小时,我先后在logstash的配置文件中input加入jdbc_default_timezone => "Asia/Shanghai" ,以及利用filter插件ruby更改时间戳字段,重新导入之后更仍然相差5小时,部分配置如下:
filter{
date {
match => ["add_time","UNIX_MS"]
target => "@timestamp"
}
ruby {
code => "event.set('timestamp', event.get('@timestamp').time.localtime - 5*60*60)"
}
ruby {
code => "event.set('@timestamp',event.get('timestamp'))"
}
mutate {
remove_field => ["timestamp"]
}
}
目前我是暂时在导入时的sql里边处理的
请问大家知道是怎么回事吗?我该如何解决这个问题?求指导
filter{
date {
match => ["add_time","UNIX_MS"]
target => "@timestamp"
}
ruby {
code => "event.set('timestamp', event.get('@timestamp').time.localtime - 5*60*60)"
}
ruby {
code => "event.set('@timestamp',event.get('timestamp'))"
}
mutate {
remove_field => ["timestamp"]
}
}
目前我是暂时在导入时的sql里边处理的
请问大家知道是怎么回事吗?我该如何解决这个问题?求指导
1 个回复
rochy - rochy_he
赞同来自: json_111