#python #airflow
#python #поток воздуха
Вопрос:
Postgreshook в airflow имеет функцию get_record, которая возвращает результат запроса. Результатом является объект tuple . Как мы можем получить результат в форме dict? Кроме того, поскольку в коде упоминается, что мы можем использовать курсор dict, как нам это сделать?
Ответ №1:
Указания, приведенные в вашей ссылке, технически точны, но, к сожалению, не очень понятно, с каким «соединением» вы должны работать.
Измените соответствующее соединение в диспетчере подключений веб-интерфейса Airflow, чтобы его Extra поле содержало следующий JSON : {"cursor": "dictcursor"} .