Go 如何过滤来自 fsnotify 的重复系统消息

我使用了"githeb.com/fsfy/fstify"来监听文件的更改，但我应该如何过滤某些消息太多次？

func Listener() {
    watcher, err := fsnotify.NewWatcher()
    if err != nil {
        log.Fatal(err)
    }
    defer watcher.Close()
    done := make(chan bool)
    go func() {
        for {
            select {
            case event, ok := <-watcher.Events:
                if !ok {
                    return
                }
                log.Println("event:", event.Name, event.Op)

                // Writing in this way reduces some messages:
                if event.Op&fsnotify.Rename == fsnotify.Rename {
                    // do ...
                } else if event.Op&fsnotify.Create == fsnotify.Create {
                    // do ...
                } else if event.Op&fsnotify.Write == fsnotify.Write {
                    // do ...
                } else if event.Op&fsnotify.Remove == fsnotify.Remove {
                    // do ...
                }
            case _, ok := <-watcher.Errors:
                if !ok {
                    return
                }
            }
        }
    }()
    
    err = watcher.Add("e:/.../demo")
    if err != nil {
        log.Fatal(err)
    }
    <-done
}

例如，写、创建事件发生了几次，我发现官方的错误已经修复了，但似乎并没有完全解决

2022/12/12 21:00:55 event: e:\...\demo\a.bbb CREATE
2022/12/12 21:00:55 event: e:\...\demo\a.bbb CREATE
2022/12/12 21:00:55 event: e:\...\demo\a.bbb CREATE


2022/12/12 21:01:57 event: e:\...\demo\2.md WRITE
2022/12/12 21:01:57 event: e:\...\demo\2.md WRITE
2022/12/12 21:01:57 event: e:\...\demo\2.md WRITE
2022/12/12 21:01:57 event: e:\...\demo\2.md WRITE
2022/12/12 21:01:57 event: e:\...\demo\2.md WRITE
2022/12/12 21:01:57 event: e:\...\demo\2.md WRITE
2022/12/12 21:01:57 event: e:\...\demo\2.md WRITE

我应该如何过滤邮件？

####

var syncMap sync.Map
go func() {
    for {
        select {
        case event, ok := <-watcher.Events:
            if !ok {
                return
            }
            fPath := strings.ReplaceAll(event.Name, "\\", "/")
            pathKey, _ := syncMap.Load(fPath)
            if pathKey != 1 {
                // ...
                syncMap.Store(fPath, 1)

                go func() {
                    time.Sleep(time.Second * 2)
                    syncMap.Delete(fPath)
                }()
            }
        case _, ok := <-watcher.Errors:
            if !ok {
                return
            }
        }
    }
}()