Обмен данными между двумя задачами в потоке воздуха - PullRequest
0 голосов
/ 22 октября 2019

Я хочу выполнить запрос улья, используя HiveOperator, и вывод этого запроса должен быть перенесен в скрипт python, используя PythonOperator. Возможно ли это и как?

1 Ответ

0 голосов
/ 23 октября 2019

Один из подходов к решению подобных проблем в целом заключается в использовании xcoms от Airflow - см. документацию

Однако я бы использовал это экономно и только там, где это строго необходимо. В противном случае вы рискуете оказаться в итоге запутанными и взаимозависимыми вашими операторами.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...