У меня есть приложение rails, которое запускает задачу путем записи в очередь Rabbit-MQ.
В Airflow, который настроен для Celery и Rabbit-MQ, я хочу, чтобы DAG запускалась при появлении сообщенияпопадает в очередь Rabbit-MQ.
Это что-то, что можно сделать таким образом?
Могу ли я писать в очереди Celery / Rabbit-MQ из другого приложения?И если да, то как мне передать параметры.