我已经使用 Airflow UI 设置了 Big Query Connection。气流 --> 管理员 --> 连接 --> bigquery_default。
我正在使用 kubernetespodoperator 来执行 python 代码。我的问题是如何将大查询连接传递给这个可调用的 python 模块。在这个 python 模块中，我有几个需要执行的 sql 查询。我不能使用大查询运算符，因为基于 python 中的代码，它需要执行所有这些 sql 查询。
谢谢
我已经使用 Airflow UI 设置了 Big Query Connection。气流 --> 管理员 --> 连接 --> bigquery_default。
我正在使用 kubernetespodoperator 来执行 python 代码。我的问题是如何将大查询连接传递给这个可调用的 python 模块。在这个 python 模块中，我有几个需要执行的 sql 查询。我不能使用大查询运算符，因为基于 python 中的代码，它需要执行所有这些 sql 查询。
谢谢