| :py:mod:`airflow.providers.amazon.aws.links.base_aws` |
| ===================================================== |
| |
| .. py:module:: airflow.providers.amazon.aws.links.base_aws |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.amazon.aws.links.base_aws.BaseAwsLink |
| |
| |
| |
| |
| Attributes |
| ~~~~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.amazon.aws.links.base_aws.BASE_AWS_CONSOLE_LINK |
| |
| |
| .. py:data:: BASE_AWS_CONSOLE_LINK |
| :annotation: = https://console.{aws_domain} |
| |
| |
| |
| .. py:class:: BaseAwsLink |
| |
| Bases: :py:obj:`airflow.models.BaseOperatorLink` |
| |
| Base Helper class for constructing AWS Console Link |
| |
| .. py:attribute:: name |
| :annotation: :ClassVar[str] |
| |
| |
| |
| .. py:attribute:: key |
| :annotation: :ClassVar[str] |
| |
| |
| |
| .. py:attribute:: format_str |
| :annotation: :ClassVar[str] |
| |
| |
| |
| .. py:method:: get_aws_domain(aws_partition) |
| :staticmethod: |
| |
| |
| .. py:method:: format_link(**kwargs) |
| |
| Format AWS Service Link |
| |
| Some AWS Service Link should require additional escaping |
| in this case this method should be overridden. |
| |
| |
| .. py:method:: get_link(operator, dttm = None, ti_key = None) |
| |
| Link to Amazon Web Services Console. |
| |
| :param operator: airflow operator |
| :param ti_key: TaskInstance ID to return link for |
| :param dttm: execution date. Uses for compatibility with Airflow 2.2 |
| :return: link to external system |
| |
| |
| .. py:method:: persist(context, operator, region_name, aws_partition, **kwargs) |
| :classmethod: |
| |
| Store link information into XCom |
| |
| |
| |
