2024-05-13 23:00:48 发布
网友
我读过官方的Celery的docs,DigitalOcean的tutorial,运行得很好examples。但我不明白我的应用程序是如何像Resque Ruby那样进行通信的。例如,我在docker容器中有一个主python应用程序,它必须为其他容器中的另外两个python应用程序生成任务。在Resque我的应用程序只需监听一些队列并接收任务,然后做一些工作并推后响应。在
Celery还需要一个队列/代理来在应用程序进程和工作进程之间进行通信。请参见http://docs.celeryproject.org/en/latest/getting-started/brokers/index.html了解受支持的代理(RabbitMQ通常用于此)。在
应用程序进程将一个新任务发布到代理上的队列,工作进程将在工作进程有可用容量时立即从队列中获取该任务。在
你说你需要将任务传递给另外两个python应用程序。这些python应用程序可以监听两个不同的队列并对它们进行处理。在
Celery还需要一个队列/代理来在应用程序进程和工作进程之间进行通信。请参见http://docs.celeryproject.org/en/latest/getting-started/brokers/index.html了解受支持的代理(RabbitMQ通常用于此)。在
应用程序进程将一个新任务发布到代理上的队列,工作进程将在工作进程有可用容量时立即从队列中获取该任务。在
你说你需要将任务传递给另外两个python应用程序。这些python应用程序可以监听两个不同的队列并对它们进行处理。在
相关问题 更多 >
编程相关推荐