DejaVud

celery:
task = signature("xxx.task_name", options={"queue":"queue_name"})
task.apply_async((args,), expires=expires)

rq:
job = q.enqueue("module_xxx.task_fucname", args=[a, b,])
"module_xxx.task_fucname"是 rq worker 启动的项目目录包函数相对路径

dramatiq:
broker = XXXBroker(...)
msg = Message(queue_name="queue_aaa", actor_name="task_name”, args=...)
broker.enqueue(msg)

结贴了，为了之后来到这里搜索答案的人：

@alexsz 好的好的，还是看文档不仔细了，我这就去试试。

@pollux 但是 rpc 和消息队列还是有点使用场景区别（同步 vs 异步），我想要消息队列一些特性：异步、解耦、流量削锋。当然，不是说 rpc 不能做。

@ospider 哈啊，是的，我就在想要不自己封装一下

补充一下，我之所以有这样的需求是因为，存在一种这样的场景：
main.py 是一个 web 后端应用，worker.py 是一个计算任务如 AI 推理，在我的理解里 web 后端代码和 AI 推理代码本应属于不同的 2 个项目，代码不应当糅合在一起，web 代码就不需要知道任务函数是如何实现的。

@nicevar 是的!当年在看雪上看到大佬把 Sandboxie 逆向重写出来,真的是把我幼小的心灵震给撼到了.

语义化吧

[av71874993]( https://www.bilibili.com/video/av71874993)
上期睡前消息督工说过非全的事,可以看看