远程气流Dags

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了远程气流Dags相关的知识,希望对你有一定的参考价值。

我计划在云存储上部署气流dags,并提供与GCS的连接,并从运行在Google Compute Engine实例上的Airflow访问这些dag。

从文档中可以清楚地看到远程日志记录是可行的。

我想在GCS上完全保留Airflow的存储(Logs and Dags)部分,因为我必须管理这些文件以避免在部署后修改VM上的文件。

此外,随着日志的增加,它开始占用云VM磁盘上的大量空间。

是否可以在GCS上存储dags。如果是这样,我怎样才能做到这一点。

提前致谢。

答案

我迟到了,但你可以将一个存储桶作为文件系统安装到你的VM(或任何Linux系统)。

与实际文件系统相比,我的体验可能有点慢,但如果我理解正确,这应该对你有用。

有关此工作的详细信息,请参阅documentation

另一答案

Google Cloud Platform似乎与气流广泛集成,用于数据处理和存储。

有一篇官方的Google Cloud Blog documentation文章解释了如何将Airflow与BigQuery连接起来。此外,在official Airflow documentation中还有一个用于Google Cloud Platform集成的附加部分,可以解释完整集成的其他详细信息。

总而言之,BigQuery似乎是适合您的产品,它是一个专门的Google工具,可管理大量数据库,并使其易于使用外部工具和其他谷歌产品(如虚拟机)进行操作和操作。

另一答案

在GCS中实现保存DAG的一种方法是将它们作为JSON存储在存储桶中。像这样,您可以避免将文件存储在VM中。

显示如何执行此操作的示例是此其他Stackoverflow post

以上是关于远程气流Dags的主要内容,如果未能解决你的问题,请参考以下文章

气流:如何删除 DAG?

气流的 MSSQL 钩子

气流回填不起作用

气流 - 如何仅“填充 DagBag”一次

如何在气流中配置 Google Cloud BigQuery

气流 SSH 操作错误:[Errno 2] 没有这样的文件或目录: