业主参数在气流算子中的作用是什么?



在这里的气流文档中,owner参数描述如下:

owner (str)—任务的所有者,使用unix用户名推荐

我不明白"任务的所有者"是什么意思。

是否为执行该任务的用户名?比如文件的所有者?

如果这真的是一个用户名,为什么我使用了一个不存在的用户名而没有得到任何错误?

Owner可以是任意值。它用于对气流中的dag进行分类。如。你有5个dag,每个dag处理来自SQL server的数据,你可以使用这些dag的所有者名作为SQL server,如果你有2个dag处理来自BigQuery的数据,你可以给所有者名作为BigQuery。通常,您可以假设使用所有者名称来标识DAG所属的对象。甚至可以是你的名字。

最新更新