如何按名称将任务发布到 Go 中的 RabbitMQ queue？

Question

我需要按名称发布任务（在 queue 上创建一条消息，任务名称传入 headers，传递一些参数）。

我在 Celery (Python) 中这样做是这样的：

celery_app.send_task("task_name", args=("arg1", "arg2",))

这是我在 Go 中执行相同操作的代码：

headers := make(amqp.Table)
headers["argsrepr"] = []string{"arg1", "arg2"}
headers["task"] = "task_name"

body := ""
jsonBody, _ := json.Marshal(body)

err = ch.Publish(
  "",     // exchange
  "queue_name", // routing key
  false,  // mandatory
  false,  // immediate
  amqp.Publishing {
    DeliveryMode: amqp.Persistent,
    ContentType:  "application/json",
    Body:         jsonBody,
    Headers:      headers,
  })

但是我得到这个错误：

Failed to publish a message: table field "argsrepr" value [%!t(string=arg1) %!t(string=arg2)] not supported

我正在使用 "github.com/streadway/amqp" 库与我的 rabbitmq 节点通信。 "send task by name" 似乎没有在这个库中实现。

Answer 1

这是症状的说明。 fmt 格式字符串显然需要布尔值。

package main

import "fmt"

func main() {
    s := fmt.Sprintf("%t %t", "arg1", "arg2")
    fmt.Println(s)
    t := fmt.Sprintf("%t %t", true, false)
    fmt.Println(t)
}

输出：

%!t(string=arg1) %!t(string=arg2)
true false

如何按名称将任务发布到 Go 中的 RabbitMQ queue？

How to publish task by name to a RabbitMQ queue in Go?

amqp

go

rabbitmq