go asynq 怎么取消任务?

Question

用过 asynq 的小伙伴帮忙看下怎么根据任务ID取消任务

https://github.com/hibiken/asynq

Answer 1

找到解决办法了，应该使用 inspector。

var err error
inspector := asynq.NewInspector(asynq.RedisClientOpt{Addr: "localhost:6379"})

err = inspector.CancelProcessing(id)
if err != nil {
    log.Fatalln("cancel task failed", err)
}

err = inspector.ArchiveTask("default", id)
if err != nil {
    log.Fatalln("archive task failed", err)
}

Answer 2

用任务的ID来取消任务。每个任务都有一个唯一的ID，可以在新建建任务时获取。或者直接从 Redis 里删除任务