我想安排一个 Celery 任务，它可以在每个计划中接受动态参数。本质上，参数应该源自数据库查询的结果。有没有办法实现这个目标？
详细来说，我的目标是根据从数据库查询检索的行数并行分配 Celery 任务。我计划将行分成批次，每个批次作为单独的 Celery 任务的参数。
我在 Celery 的节拍时间表中没有找到支持此要求的选项。除了使用 Celery 之外，还有其他有效的替代方法可以实现这一目标吗？或者，我是否缺少任何可以支持此动态参数功能的 Celery 特定配置或功能？
使用 celery 任务调度程序，您可以调用“主”任务，在此任务中，通常在其他文件中，您可以使用 for 循环，获取数据库信息等，并构建您提到的参数。之后，您调用另一个@app.task，并且您可以向该任务发送所有参数，并且它们都开始使用所有处理器以并行方式执行。请注意，您不应从该@app.task 返回数据。致以诚挚的问候。