airflow.providers.amazon.aws.utils.connection_wrapper

類

AwsConnectionWrapper

AWS 連線包裝器類助手。

模組內容

class airflow.providers.amazon.aws.utils.connection_wrapper.AwsConnectionWrapper(context=None)[source]

Bases: airflow.utils.log.logging_mixin.LoggingMixin

AWS 連線包裝器類助手。

用於驗證和解析 AWS 連線引數。

conn 引用一個 Airflow 連線物件或 AwsConnectionWrapper

如果設定為 None，則使用預設值。

region_name 的優先順序規則

  1. 顯式設定（在 Hook 中）region_name。

  2. Airflow 連線額外引數 ‘region_name’。

botocore_config 的優先順序規則

  1. 顯式設定（在 Hook 中）botocore_config。

  2. 從 Airflow 連線額外引數 ‘botocore_kwargs’ 構建。

  3. 包裝器的預設值

conn: dataclasses.InitVar[airflow.models.connection.Connection | AwsConnectionWrapper | _ConnectionMetadata |None][source]
region_name: str | None = None[source]
botocore_config: botocore.config.Config | None = None[source]
verify: bool | str | None = None[source]
conn_id: str | airflow.utils.types.ArgNotSet |None[source]
conn_type: str | None = None[source]
login: str | None = None[source]
password: str | None = None[source]
schema: str | None = None[source]
extra_config: dict[str, Any][source]
aws_access_key_id: str | None = None[source]
aws_secret_access_key: str | None = None[source]
aws_session_token: str | None = None[source]
profile_name: str | None = None[source]
endpoint_url: str | None = None[source]
role_arn: str | None = None[source]
assume_role_method: str | None = None[source]
assume_role_kwargs: dict[str, Any][source]
service_config: dict[str, dict[str, Any]][source]
property conn_repr[source]
get_service_config(service_name)[source]

獲取 AWS 服務相關的配置字典。

引數:

service_name (str) – botocore/boto3 服務的名稱。

get_service_endpoint_url(service_name, *, sts_connection_assume=False, sts_test_connection=False)[source]
__post_init__(conn)[source]

例項化後初始化 AwsConnectionWrapper 物件。

classmethod from_connection_metadata(conn_id=None, login=None, password=None, extra=None)[source]

從連線元資料建立配置。

引數:

  • conn_id (str | None) – 自定義連線 ID。

  • login (str | None) – AWS Access Key ID。

  • password (str | None) – AWS Secret Access Key。

  • extra (dict[str, Any] | None) – 連線額外元資料。

property extra_dejson[source]

與 airflow.models.Connection.extra_dejson 屬性相容。

property session_kwargs: dict[

傳遞給 boto3.session.Session 的額外關鍵字引數。

__bool__()[source]

返回 AwsConnectionWrapper 例項的真值。

這篇文章有幫助嗎？