推荐学习书目 Learn Python the Hard Way Python Sites PyPI - Python Package Index http://diveintopython.org/toc/index.html Pocoo 值得关注的项目 PyPy Celery Jinja2 Read the Docs gevent pyenv virtualenv Stackless Python Beautiful Soup 结巴中文分词 Green Unicorn Sentry Shovel Pyflakes pytest Python 编程 pep8 Checker Styles PEP 8 Google Python Style Guide Code Style from The Hitchhiker's Guide
这是一个创建于 608 天前的主题，其中的信息可能已经有所发展或是发生改变。
一个典型的 rq 使用示例如下：
import requests def count_words_at_url(url): resp = requests.get(url) return len(resp.text.split()) from redis import Redis from rq import Queue from worker import count_words_at_url q = Queue(cOnnection=Redis()) result = q.enqueue(count_words_at_url, 'http://nvie.com') 但是我希望生产者（ main.py ）和消费者（ worker.py ）代码是解耦的，就是不要在 main.py 中 from worker import count_words_at_url ，生产者只知道要调用函数名和参数，比如类似下面这样的形式：
result = q.send_task(task_name="count_words_at_url", args=["http://nvie.com",]) 这样，我就可以把 worker 的代码项目单独独立出去，而 main.py 项目里完全不会有 count_words_at_url 函数的相关实现。
我知道 celery 是可以这样实现的，我的问题是 rq 、huey 、dramatiq 这三个库可以实现出这样吗？
 | 1 DejaVud OP |
 | 2 Zhuzhuchenyan 2024-02-21 23:23:32 +08:00 Celery 可以实现类似的需求，参考 https://docs.celeryq.dev/en/latest/userguide/canvas.html#signatures 可以将 Worker 部分完全解耦到另一个项目，只要保持 Celery 配置一致即可 |
 | 3 4BVL25L90W260T9U 2024-02-22 00:12:51 +08:00 redis lpush/rpop 解君愁，这些工具基本都是过度封装。 |
 | 4 pollux 2024-02-22 07:16:07 +08:00 借助 gRPC 与任何语言做 rpc 调用 |
 | 5 alexsz 2024-02-22 08:28:25 +08:00 rq 本身就支持: result = q.send_task(task_name="worker.count_words_at_url", args=["http://nvie.com",]) |
| 7 DejaVud OP @pollux 但是 rpc 和消息队列还是有点使用场景区别（同步 vs 异步），我想要消息队列一些特性：异步、解耦、流量削锋。当然，不是说 rpc 不能做。 |
 | 9 kice 2024-02-23 14:01:40 +08:00 本质上入队的时候都是把函数名转成字符串。但是把函数放在一起的话，按理是可以提供类型提示（例如 Tab 自动完成）。 目前看的话 taskiq 做得比较好，其他的任务队列一般般。┑(￣Д ￣)┍ |
| 10 DejaVud OP 结贴了，为了之后来到这里搜索答案的人： |
| 11 DejaVud OP 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) |
Select Language