Получить дополнительные параметры из Airflow Connection
У меня есть соединение Snowflake, определенное в Airflow.
Я выбираю пользователя, пароль и схему, используя приведенное ниже:
conn = BaseHook.get_connection("snowflake_conn")
conn.login
вернуть логин (в данном случае ПРИМЕР)
Если я попытаюсь получить доступ к «дополнительным» параметрам, это не сработает.
conn = BaseHook.get_connection("snowflake_conn")
conn.role
возвращает AttributeError: объект «Соединение» не имеет атрибута «роль»
Есть ли другой способ получить дополнительные параметры из настроек Airflow Connection?
Почему в Python есть оператор "pass"?
Оператор pass в Python - это простая концепция, которую могут быстро освоить даже новички без опыта программирования.
Некоторые методы, о которых вы не знали, что они существуют в Python
Python - самый известный и самый простой в изучении язык в наши дни. Имея широкий спектр применения в области машинного обучения, Data Science,...
Основы Python Часть I
Вы когда-нибудь задумывались, почему в программах на Python вы видите приведенный ниже код?
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
Алиса и Боб имеют неориентированный граф из n узлов и трех типов ребер:
Оптимизация кода с помощью тернарного оператора Python
И последнее, что мы хотели бы показать вам, прежде чем двигаться дальше, это
Советы по эффективной веб-разработке с помощью Python
Как веб-разработчик, Python может стать мощным инструментом для создания эффективных и масштабируемых веб-приложений.
1
0
252
1
Перейти к ответу
Данный вопрос помечен как решенный
Ответы 1
Ответ принят как подходящий
Дополнительные параметры хранятся в поле extra. Для доступа к этим параметрам вам необходимо сначала преобразовать их из строки в словарь Python с помощью свойства Connection.extra_dejson.
conn = BaseHook.get_connection("snowflake_conn")
conn.extra_dejson.get("role")
Другие вопросы по теме
Как сохранить дату в дате выполнения Airflow и преобразовать время в 00:00
Ограничить даги в экземпляре MWAA в учетной записи потребителя с помощью предполагаемой роли
MWAA (2.8.1) Невозможно установить снежинку-коннектор-python
«ValueError: аргумент, отличный от значения по умолчанию, следует за аргументом по умолчанию» при обновлении с Airflow 2.2.2 до 2.8.1
Разветвление воздушного потока: задача, которая лишь иногда зависит от вышестоящей задачи
Для запуска файла Python, который импортируется из пакета Airflow, требуется экземпляр airflow?
Остановка следующего выполнения Airflow DAG, пока текущее выполнение еще выполняется
Ошибка воздушного потока при настройке и ресурсах Tear_down. объект не имеет атрибута as_teardown
Воздушный поток: выполните все задачи в TaskGroup перед переходом к следующей и избегайте зависимостей между TaskGroup
GCP: Bigquery для экспорта данных с CRLF в качестве завершения строки
Похожие вопросы
Как я могу более эффективно выбрать один элемент массива объектов по одной объектной переменной?
Pydantic V2 @field_validator не выполняется
Как повысить эффективность случайного выбора и назначения столбцов в Pandas DataFrame?
Класс данных Python Frozen Nessed с __call__ = replace
Как установить индекс строки и столбца как широту/долготу в фрейме данных в Python? а затем создать набор данных xarray с широтой, долготой и значениями в качестве переменных
Количество акций в обращении по запросу
Я получаю сообщение «ValueError: HydraConfig не установлен», когда использую «hydra.initialize»
Эквивалент jq в python
Воспроизведение фазового спектра при использовании np.fft.fft2 и cv2.dft. Почему результаты не похожи?
AKS — Cronjob использует файл сценария внутри PVC