python - 我可以将条件逻辑放入 Celery 中吗？

Question

我正在看 Celery + RabbitMQ 来管理任务队列。

输入数据将是多个任务分组的集合，即：

InputCollection{paramters}
    TaskGrouping{paramters}
        Task{paramters}
        Task{paramters}
        Task{paramters}
        Task{paramters}
    TaskGrouping{paramters}
        Task{paramters}
        Task{paramters}
        Task{paramters}
        Task{paramters}

我希望这些进入任务调度程序，它将InputCollection所有子元素解析为单个任务，根据任务元调度到两个队列之一。

将这么多逻辑放入 Celery 代码中是否可以，还是应该 Celery 只接收单个任务？