airflow.providers.amazon.aws.links.base_aws¶

Attributes¶

Base Helper class for constructing AWS Console Link.

airflow.providers.amazon.aws.links.base_aws.BASE_AWS_CONSOLE_LINK = 'https://console.{aws_domain}'[source]¶

class airflow.providers.amazon.aws.links.base_aws.BaseAwsLink[source]¶

Bases: airflow.sdk.BaseOperatorLink

Base Helper class for constructing AWS Console Link.

name: ClassVar[str][source]¶: Name of the link. This will be the button name on the task UI.

static get_aws_domain(aws_partition)[source]¶

format_link(**kwargs)[source]¶

Format AWS Service Link.

Some AWS Service Link should require additional escaping in this case this method should be overridden.

get_link(operator, *, ti_key)[source]¶

Link to Amazon Web Services Console.

Parameters:

operator (airflow.models.BaseOperator) – airflow operator
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – TaskInstance ID to return link for

Returns:

link to external system

Return type:

str

classmethod persist(context, operator, region_name, aws_partition, **kwargs)[source]¶

Store link information into XCom.