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