GCP Airflow - подключение к Big Query
Я настроил подключение к Big Query с помощью пользовательского интерфейса Airflow. Воздушный поток -> Админ -> Соединение -> bigquery_default.
Я использую kubernetespodoperator для выполнения кода Python. мой вопрос в том, как передать соединение большого запроса этому вызываемому модулю python. В этом модуле python у меня есть несколько SQL-запросов, которые необходимо выполнить. Я не могу использовать большой оператор запроса, поскольку, исходя из кода в Python, он должен выполнять все эти запросы sql.
Благодарность