main.go 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. package main
  2. import (
  3. "fmt"
  4. "path/filepath"
  5. "sync"
  6. "sync/atomic"
  7. "time"
  8. "git.wecise.com/wecise/cgimport/cgf"
  9. "git.wecise.com/wecise/util/cfg"
  10. "git.wecise.com/wecise/util/filewalker"
  11. "git.wecise.com/wecise/util/rc"
  12. )
  13. // 获取配置信息
  14. //
  15. // 默认配置:
  16. // 当前工作目录下 与应用同名的 .conf 文件
  17. // 环境变量
  18. // 命令行参数
  19. var mcfg = cfg.MConfig()
  20. func main() {
  21. st := time.Now()
  22. filescount := int64(0)
  23. recordscount := int64(0)
  24. // 文件目录
  25. datapath := mcfg.GetStrings("datapath", "data")
  26. // 并发数
  27. parallel := mcfg.GetInt("parallel", 10)
  28. // 遍历文件目录
  29. var cgirc = rc.NewRoutinesController("", parallel)
  30. var wg sync.WaitGroup
  31. var err error
  32. fw, e := filewalker.NewFileWalker(datapath, ".*")
  33. if e != nil {
  34. panic(e)
  35. }
  36. e = fw.List(func(basedir string, fpath string) bool {
  37. if err != nil {
  38. return false
  39. }
  40. filename := filepath.Join(basedir, fpath)
  41. wg.Add(1)
  42. cgirc.ConcurCall(1,
  43. func() {
  44. defer wg.Done()
  45. records, e := cgf.Import(filename)
  46. if e != nil {
  47. err = e
  48. return
  49. }
  50. atomic.AddInt64(&filescount, 1)
  51. atomic.AddInt64(&recordscount, int64(records))
  52. },
  53. )
  54. return true
  55. })
  56. wg.Wait()
  57. if e != nil {
  58. panic(e)
  59. }
  60. if err != nil {
  61. panic(err)
  62. }
  63. fmt.Println("total import", filescount, "files", recordscount, "records", "in", time.Since(st))
  64. }