在气流中,我有两个任务,第一个任务从 API 获取 24x7 数据并将其传递给第二个任务。但在这种情况下,当我的第一个任务连续运行时,它不会正确触发第二个任务。有什么可行的解决办法吗?
我想确保我的第一个任务获取实时数据并传递给第二个任务是否可能?
Airflow 是一个协调器,而不是运行时。任务之间传递的数据需要保存在某个地方,存储第一个任务的输出的结果可能会触发第二个任务。