我正在尝试编写一个管道,postgres db应该使用csv的内容进行更新,当它被带到文件夹时。我已经编写了一个dag,它创建了表,并在从web中触发csv内容时推送它。下面是代码:from airflow import DAG
from airflow.utils.trigger_rule import TriggerRulefrom airflow.operators.postgres_operator import Po
我使用气流,我有一个由文件传感器开始的数据,它工作得很好,但是我需要一个条件来匹配文件的某种模式。我看到了OmegaFileSensor,但我不能导入它(可能不推荐?)。有人已经在用我想要的东西了吗?我的爸爸:from airflow import DAG
from airflow.operators.bash_operator import BashOperatorimport