相关疑难解决方法(0)

如何读取气流云作曲家存储桶中的文件?

要将 bigquery 查询与实际代码分开,我想将 sql 存储在一个单独的文件中,然后从 python 代码中读取它。我试图将文件添加到与 DAG 相同的存储桶中,也添加到子文件夹中,但是当气流使用 sql 文件运行我的 python 脚本时,我似乎无法读取该文件。

我想要的是这个:

gs://my-bucket/dags -> store dags
gs://my-bucket/dags/sql -> store sql files
Run Code Online (Sandbox Code Playgroud)

sql 文件可能是我需要先阅读以注入 jinja 模板不支持的内容的文件。

我可以做以上吗?

google-cloud-composer

2
推荐指数
1
解决办法
3837
查看次数

标签 统计

google-cloud-composer ×1