小编Dyl*_*ine的帖子

通过apache气流检查谷歌存储桶中是否存在文件?

我有一个 DAG,它获取 Google 云存储桶中脚本的结果,将其加载到 Google BigQuery 中的表中,然后删除存储桶中的文件。

我希望 DAG 在周末每小时检查一次。现在,我正在使用 GoogleCloudStoragetoBigQueryOperator。如果该文件不存在,则 DAG 失败。有没有办法将 DAG 设置为即使文件不存在也不会失败?也许尝试/捕获?

python airflow

3
推荐指数
1
解决办法
6411
查看次数

标签 统计

airflow ×1

python ×1