AIRFLOW_CONN_を使用して気流環境変数にアクセスし、Pythonコードで使用する方法を知っている人はいませんか。パスワードを取得するためにフックを使うことはできますが、pythonでAIRFLOW_CONNを使用してデータベースに接続しようとしています。 Airflow UIとそのドキュメントに接続を保存しました。彼らはconn_idにAIRFLOW_CONN_接頭辞を使用して使用すると述べました。 os.environ ['AIRFLOW_CONN_REDSHIFT']を使用してPythonコードで使用しましたが、環境変数を識別しません。助けてください。Pythonコードの環境変数として気流接続を使用する方法
1
A
答えて
0
データベースへの接続を保存し、AIRFLOW_CONN_
環境変数を設定することは、接続を追加する2つの方法です。接続IDの下に格納しない限り、一方向のみを選択してください。
PythonOperator
のような演算子でPythonコードを実行していると仮定すると、BaseHookのように接続をフェッチすることができます。
は、データベースに格納された:
環境変数に格納され@classmethod
def _get_connections_from_db(cls, conn_id):
session = settings.Session()
db = (
session.query(Connection)
.filter(Connection.conn_id == conn_id)
.all()
)
session.expunge_all()
session.close()
if not db:
raise AirflowException(
"The conn_id `{0}` isn't defined".format(conn_id))
return db
:私はこのコードの重複を避けるためにフックを経由して、それを取り出す推薦が
@classmethod
def _get_connection_from_env(cls, conn_id):
environment_uri = os.environ.get(CONN_ENV_PREFIX + conn_id.upper())
conn = None
if environment_uri:
conn = Connection(conn_id=conn_id, uri=environment_uri)
return conn
!
関連する問題
- 1. 環境変数の気流設定が動作しない
- 2. 環境変数をPythonの環境変数としてDataflowワーカーに届ける方法
- 3. 環境変数としてpowershell変数を使用する
- 4. 気流DBセッションが気になる環境を提供していない
- 5. #!でPythonのバージョンを特定する方法環境変数を使用する
- 6. Pythonと環境変数
- 7. Cコードを使用して環境変数を取得
- 8. 環境変数perlを使用して
- 9. JenkinsのNode.jsを環境変数として使用する
- 10. 使用して環境変数
- 11. IISでphp.iniのシステム環境変数を使用する方法
- 12. PyCharmを使ってリモートPythonインタプリタの環境変数を保持する方法
- 13. 環境変数nodejsとしてconfig jsonをロードする方法
- 14. mockitoを使用してAWS環境変数を設定する別の方法
- 15. logstash:入力ホストで環境変数を使用する方法
- 16. SUDO使用時に環境変数を保持する方法
- 17. MinGwシェルで%JAVA_HOME%環境変数を使用する方法
- 18. アイデア設定で環境変数を使用する方法
- 19. JenkinsfileでJenkins環境変数を使用する方法ステートメント
- 20. AWS Elastic Beanstalk:ebextensionsで環境変数を使用する方法は?
- 21. (node.js)JSONファイルで環境変数を使用する方法
- 22. eclipse.iniで環境変数を使用する方法は?
- 23. Pythonの環境変数をチェックする方法
- 24. getFilesDir()に環境変数としてアクセスする方法は?
- 25. WindowsのPython環境変数?
- 26. Anaconda Python 2.7環境でpython 2.7パッケージを使用する方法
- 27. Antを使用して環境変数を設定する方法
- 28. Fabricを使用して環境変数を設定する方法
- 29. 環境変数を使用してkubectlを認証する方法は?
- 30. InstallScript InstallShieldを使用してPATH(環境変数)を設定する方法
接続オブジェクトを環境変数として保存しますか? – Chengzhi
Airflow UIに接続オブジェクトを保存しました。今私はコードでそれらを使用したいと思います。 – NNN