文件名称：django-rabbitmq-celery-docker-example:django在docker上使用Rabbitmq和celery的示例pubsub消息队列实现
文件大小：15KB
文件格式：ZIP
更新时间：2024-05-20 20:11:16
Python
django-rabbitmq-celery-docker-example 使用rabbitmq和celery在django中实现dockerized示例pub / sub类型消息队列的示例。 有关中型故事的详细解释，请参见： 发布/订阅角色定义 发布者：声明了一个单独的RabbitMQ队列生成器，并将其添加到Celery的默认producer_pool中，该默认生成器被拉出并用于在Celery任务中将新消息发布到该队列。 消费者：定义了自定义消费者类别并将其附加到Celery。 该类订阅了使用上面单独的队列生成器创建/声明的自定义队列。 在自定义使用者类中定义了handle_message回调函数，以便每次将消息发布到该特定队列时，都会调用使用者的回调，该回调使用该消息并将确认发送给RabbitMQ。 安装 需要安装docker和docker-compose才能运行此项目。 可以通过
【文件预览】：
django-rabbitmq-celery-docker-example-master
----Dockerfile(599B)
----api()
--------models.py(57B)
--------apps.py(81B)
--------__init__.py(0B)
--------migrations()
--------views.py(170B)
--------admin.py(63B)
--------tests.py(60B)
--------tasks.py(351B)
--------urls.py(145B)
----LICENSE(11KB)
----requirements.txt(86B)
----docker-compose.yml(1KB)
----manage.py(628B)
----.gitignore(13B)
----README.md(2KB)
----mypubsub()
--------wsgi.py(393B)
--------__init__.py(232B)
--------settings.py(3KB)
--------urls.py(798B)
--------celery.py(2KB)
----wait-for(1KB)