不知怎的,我不能通过代理服务器下载文件,我不知道我做错了什么.我只是暂停了.有什么建议?
import urllib.request
urllib.request.ProxyHandler({"http" : "myproxy:123"})
urllib.request.urlretrieve("http://myfile", "file.file")
Run Code Online (Sandbox Code Playgroud) 我写了一个 Django 项目,它通过my_task.delay(). 问题是随着项目越来越大,正确路由任务真的很困难 - 我开始编写任务的唯一目的是组合不同的任务,这使得一段时间后代码变得混乱。
当我阅读一些 RabbitMQ 文档时,我找到了一个解决方案,它可以更好地构建我的项目,它依赖于Exchanges。Exchange可以将消息发布到Cosumer可以在其上消费它的多个队列,简而言之:

所述的RabbitMQ-文档描述了与鼠兔的溶液,其是用于RabbitMQ的比芹菜更低水平的客户端。
芹菜,文档描述了此方案在其文档,但没有说明如何创建一个生产者产生的消息被发送到一个交易所就其分配到不同的队列如上面图片中看到。它只描述了如何向队列发送消息和发送任务- 但我希望由 Exchange 处理。
我发现 celery 所依赖的 Kombu 具有通过生产者将消息发送到 Exchange 的功能,但我找不到任何有关如何在 celery-django 中使用它的文档。
我如何能够在芹菜中归档所描述的程序?
PS:在 StackOverflow 上已经有一个类似的问题,它建议使用像 Chain 和 Group of Celery 这样的原语,但这与我理解的 Exchange 范式相矛盾。