airflow.providers.snowflake.utils.openlineage¶
模組內容¶
函數¶
|
修正帳戶名稱，使其具有以下格式：<account_id>.<region>.<cloud>。 |
修正 Snowflake sqlalchemy 連線 URI 以符合 OpenLineage 結構。 |
- airflow.providers.snowflake.utils.openlineage.fix_account_name(name)[原始碼]¶
修正帳戶名稱，使其具有以下格式：<account_id>.<region>.<cloud>。
- airflow.providers.snowflake.utils.openlineage.fix_snowflake_sqlalchemy_uri(uri)[原始碼]¶
修正 Snowflake sqlalchemy 連線 URI 以符合 OpenLineage 結構。
Snowflake sqlalchemy 連線 URI 具有以下結構：'snowflake://<user_login_name>:<password>@<account_identifier>/<database_name>/<schema_name>?warehouse=<warehouse_name>&role=<role_name>' 我們想要標準化帳戶識別碼。它可以有兩種形式：- 較新的形式，為 <organization>-<id>。在這種情況下，我們不想做任何事情。- 較舊的形式，由 <id>-<region>-<cloud> 組成，其中 region 和 cloud 在某些情況下是可選的。如果省略 <cloud>，則為 AWS。如果省略 region 和 cloud，則為 AWS us-west-1