【文件属性】：
文件名称：Go异步任务队列GoMachinery.zip
文件大小：135KB
文件格式：ZIP
更新时间：2022-08-06 05:13:04
开源项目
Machinery 是一个 Go 语言的异步任务队列和作业队列，基于分布式消息传递。类似 Python 的 Celery 框架。Machinery 中的任务（或者作业）可通过多个 worker 在很多服务器上并发的执行，或者可在单个服务器上利用 Go 的协程运行多个 worker 进程。任务的定义：type AddTask struct{}
func (t AddTask) Run(args []interface{}) (interface{}, error) {
parsedArgs, err := machinery.ParseNumberArgs(args)
if err != nil {
return nil, err
}
add := func(args []float64) float64 {
sum := 0.0
for _, arg := range args {
sum = arg
}
return sum
}
return add(parsedArgs), nil
}
type MultiplyTask struct{}
func (t MultiplyTask) Run(args []interface{}) (interface{}, error) {
parsedArgs, err := machinery.ParseNumberArgs(args)
if err != nil {
return nil, err
}
multiply := func(args []float64) float64 {
sum := 1.0
for _, arg := range args {
sum *= arg
}
return sum
}
return multiply(parsedArgs), nil
}
// ... more tasks任务注册：tasks := map[string]machinery.Task{
"add": AddTask{},
"multiply": MultiplyTask{},
}
app.RegisterTasks(tasks)
标签：GoMachinery
【文件预览】：
machinery-master
----go.mod(1KB)
----Dockerfile.gcppubsub(254B)
----instruction-notes()
--------dynamodb.md(1KB)
----go.sum(23KB)
----docker-compose.test.yml(2KB)
----Dockerfile.test(692B)
----.travis.yml(161B)
----example()
--------tasks()
--------config.yml(446B)
--------machinery.go(11KB)
--------tracers()
----LICENSE(16KB)
----v1()
--------server_test.go(2KB)
--------common()
--------backends()
--------log()
--------factories.go(8KB)
--------package.go(18B)
--------factories_test.go(10KB)
--------tasks()
--------brokers()
--------config()
--------tracing()
--------server.go(9KB)
--------worker.go(12KB)
--------retry()
----README.md(27KB)
----Makefile(1KB)
----wait-for-it.sh(4KB)
----integration-tests()
--------redis_mongodb_test.go(707B)
--------amqp_redis_test.go(776B)
--------sqs_amqp_test.go(730B)
--------amqp_mongodb_test.go(821B)
--------redis_memcache_test.go(683B)
--------worker_only_consumes_registered_tasks_test.go(5KB)
--------sqs_mongodb_test.go(667B)
--------redis_redis_test.go(565B)
--------amqp_amqp_test.go(642B)
--------amqp_memcache_test.go(800B)
--------gcppubsub_redis_test.go(2KB)
--------eager_eager_test.go(3KB)
--------redis_socket_test.go(598B)
--------suite_test.go(10KB)
--------redis_get_pending_tasks_test.go(724B)
----.gitignore(51B)