我们有事务日志文件,其中每个事务都是 JSON 格式的一行。我们经常需要选取数据的选定部分,执行一次转换,然后将结果以特定格式输入另一个系统。我写了一个 Python 脚本来满足我们的需求,但我希望 Go 会更快,并让我有机会开始学习 Go。所以,我写了以下内容:
package main
import "encoding/json"
import "fmt"
import "time"
import "bufio"
import "os"
func main() {
sep := ","
reader := bufio.NewReader(os.Stdin)
for {
data, _ := reader.ReadString('\n')
byt := []byte(data)
var dat map[string]interface{}
if err := json.Unmarshal(byt, &dat); err != nil {
break
}
status := dat["status"].(string)
a_status := dat["a_status"].(string)
method := dat["method"].(string)
path := dat["path"].(string)
element_uid := dat["element_uid"].(string)
time_local := dat["time_local"].(string)
etime, _ := time.Parse("[02/Jan/2006:15:04:05 -0700]", time_local)
fmt.Print(status, sep, a_status, sep, method, sep, path, sep, element_uid, sep, etime.Unix(), "\n")
}
}
编译时没有抱怨,但我对缺乏性能改进感到惊讶。为了测试,我将 2,000,000 行日志放入 tmpfs(以确保磁盘 I/O 不会成为限制)并比较脚本的两个版本。我的结果:
$ time cat /mnt/ramdisk/logfile | ./stdin_conv > /dev/null
real 0m51.995s
$ time cat /mnt/ramdisk/logfile | ./stdin_conv.py > /dev/null
real 0m52.471s
$ time cat /mnt/ramdisk/logfile > /dev/null
real 0m0.149s
怎样才能更快地做到这一点?我已经做了一些初步的努力。例如,ffjson 项目建议创建静态函数,使反射变得不必要;但是,到目前为止,我未能使其正常工作,出现错误:
Error: Go Run Failed for: /tmp/ffjson-inception810284909.go
STDOUT:
STDERR:
/tmp/ffjson-inception810284909.go:9:2: import "json_parse" is a program, not an importable package
:
此外,我上面的内容不会被认为是静态类型的吗?可能不是——我对 Go 的关注点在耳后。我曾尝试在 Go 代码中有选择地禁用不同的属性,以查看某个属性是否特别有问题。没有一个对性能产生明显影响。关于提高性能的任何建议,或者这仅仅是编译语言没有比其他语言有实质性好处的情况吗?
慕桂英4014372
胡子哥哥
九州编程
相关分类