airflow.providers.google.cloud.links.datafusion¶
此模組包含 Google Data Fusion 連結。
模組內容¶
類別¶
Google 運算子的連結。 |
|
用於建構 Data Fusion Instance 連結的輔助類別。 |
|
用於建構 Data Fusion Pipeline 連結的輔助類別。 |
|
用於建構 Data Fusion Pipelines 列表連結的輔助類別。 |
屬性¶
- airflow.providers.google.cloud.links.datafusion.BASE_LINK = 'https://console.cloud.google.com/data-fusion'[source]¶
- airflow.providers.google.cloud.links.datafusion.DATAFUSION_PIPELINES_LINK = '{uri}/cdap/ns/{namespace}/pipelines'[source]¶
- airflow.providers.google.cloud.links.datafusion.DATAFUSION_PIPELINE_LINK = '{uri}/pipelines/ns/{namespace}/view/{pipeline_name}'[source]¶
- class airflow.providers.google.cloud.links.datafusion.BaseGoogleLink[source]¶
繼承自:
airflow.models.BaseOperatorLinkGoogle 運算子的連結。
防止在每個使用 URI 的連結前面加入
https://console.cloud.google.com。- get_link(operator, *, ti_key)[source]¶
連結到外部系統。
注意：此函數的舊簽名為
(self, operator, dttm: datetime)。 運行時仍然支援，但已被棄用。- 參數
operator (airflow.models.BaseOperator) – 此連結關聯的 Airflow 運算子物件。
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 要返回連結的 TaskInstance ID。
- 回傳
外部系統的連結
- 回傳類型
- class airflow.providers.google.cloud.links.datafusion.DataFusionInstanceLink[source]¶
繼承自:
BaseGoogleLink用於建構 Data Fusion Instance 連結的輔助類別。
- class airflow.providers.google.cloud.links.datafusion.DataFusionPipelineLink[source]¶
繼承自:
BaseGoogleLink用於建構 Data Fusion Pipeline 連結的輔助類別。
- class airflow.providers.google.cloud.links.datafusion.DataFusionPipelinesLink[source]¶
繼承自:
BaseGoogleLink用於建構 Data Fusion Pipelines 列表連結的輔助類別。