我有一个现有的RabbitMQ部署,一些Java应用程序使用发送日志消息作为各种通道上的字符串JSON对象.我想使用Celery来使用这些消息并将它们写到各个地方(例如DB,Hadoop等).
我可以看到Celery被设计为RabbitMQ消息的生产者和消费者,因为它试图隐藏这些消息的传递机制.反正有没有让Celery消费由另一个应用程序创建的消息并在它们到达时运行作业？
python rabbitmq celery
celery ×1
python ×1
rabbitmq ×1