airflow.providers.google.cloud.links.dataproc¶

此模組包含 Google Dataproc 連結。

屬性¶

`DATAPROC_BASE_LINK`
`DATAPROC_JOB_LINK`
`DATAPROC_CLUSTER_LINK`
`DATAPROC_WORKFLOW_TEMPLATE_LINK`
`DATAPROC_WORKFLOW_LINK`
`DATAPROC_BATCH_LINK`
`DATAPROC_BATCHES_LINK`
`DATAPROC_JOB_LINK_DEPRECATED`
`DATAPROC_CLUSTER_LINK_DEPRECATED`

類¶

`DataprocLink`	用於構造 Dataproc 資源連結的輔助類。
`DataprocListLink`	用於構造 Dataproc 資源列表連結的輔助類。
`DataprocClusterLink`	用於構造 Dataproc 叢集連結的輔助類。
`DataprocJobLink`	用於構造 Dataproc 作業連結的輔助類。
`DataprocWorkflowLink`	用於構造 Dataproc 工作流連結的輔助類。
`DataprocWorkflowTemplateLink`	用於構造 Dataproc 工作流模板連結的輔助類。
`DataprocBatchLink`	用於構造 Dataproc 批次作業連結的輔助類。
`DataprocBatchesListLink`	用於構造 Dataproc 批次作業列表連結的輔助類。

函式¶

__getattr__(name)

模組內容¶

airflow.providers.google.cloud.links.dataproc.__getattr__(name)[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_BASE_LINK = 'https://console.cloud.google.com/dataproc'[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_JOB_LINK = 'https://console.cloud.google.com/dataproc/jobs/{job_id}?region={region}&project={project_id}'[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_CLUSTER_LINK = 'https://console.cloud.google.com/dataproc/clusters/{cluster_id}/monitoring?region={region}&proje...'[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_WORKFLOW_TEMPLATE_LINK = 'https://console.cloud.google.com/dataproc/workflows/templates/{region}/{workflow_template_id}?pr...'[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_WORKFLOW_LINK = 'https://console.cloud.google.com/dataproc/workflows/instances/{region}/{workflow_id}?project={pr...'[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_BATCH_LINK = 'https://console.cloud.google.com/dataproc/batches/{region}/{batch_id}/monitoring?project={project_id}'[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_BATCHES_LINK = 'https://console.cloud.google.com/dataproc/batches?project={project_id}'[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_JOB_LINK_DEPRECATED = 'https://console.cloud.google.com/dataproc/jobs/{resource}?region={region}&project={project_id}'[原始碼]¶

airflow.providers.google.cloud.links.dataproc.DATAPROC_CLUSTER_LINK_DEPRECATED = 'https://console.cloud.google.com/dataproc/clusters/{resource}/monitoring?region={region}&project...'[原始碼]¶

class airflow.providers.google.cloud.links.dataproc.DataprocLink[原始碼]¶

Bases: airflow.sdk.BaseOperatorLink

用於構造 Dataproc 資源連結的輔助類。

警告

此連結即將被棄用。

name = 'Dataproc 資源'[原始碼]¶: 連結的名稱。這將是任務 UI 上的按鈕名稱。

key = 'conf'[原始碼]¶

static persist(context, task_instance, url, resource)[原始碼]¶

get_link(operator, *, ti_key)[原始碼]¶

外部系統的連結。

引數:

operator (airflow.models.BaseOperator) – 此連結關聯的 Airflow 運算子物件。
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 要返回連結的任務例項 ID。

返回:

外部系統的連結

返回型別:

str

__attrs_post_init__()[原始碼]¶

class airflow.providers.google.cloud.links.dataproc.DataprocListLink[原始碼]¶

Bases: airflow.sdk.BaseOperatorLink

用於構造 Dataproc 資源列表連結的輔助類。

警告

此連結已棄用。

name = 'Dataproc 資源'[原始碼]¶: 連結的名稱。這將是任務 UI 上的按鈕名稱。

key = 'list_conf'[原始碼]¶

static persist(context, task_instance, url)[原始碼]¶

get_link(operator, *, ti_key)[原始碼]¶

外部系統的連結。

引數:

operator (airflow.models.BaseOperator) – 此連結關聯的 Airflow 運算子物件。
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 要返回連結的任務例項 ID。

返回:

外部系統的連結

返回型別:

str

__attrs_post_init__()[原始碼]¶

class airflow.providers.google.cloud.links.dataproc.DataprocClusterLink[原始碼]¶

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

用於構造 Dataproc 叢集連結的輔助類。

name = 'Dataproc 叢集'[原始碼]¶: 連結的名稱。這將是任務 UI 上的按鈕名稱。

key = 'dataproc_cluster'[原始碼]¶

format_str = 'https://console.cloud.google.com/dataproc/clusters/{cluster_id}/monitoring?region={region}&proje...'[原始碼]¶

static persist(context, operator, cluster_id, region, project_id)[原始碼]¶

class airflow.providers.google.cloud.links.dataproc.DataprocJobLink[原始碼]¶

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

用於構造 Dataproc 作業連結的輔助類。

name = 'Dataproc 作業'[原始碼]¶: 連結的名稱。這將是任務 UI 上的按鈕名稱。

key = 'dataproc_job'[原始碼]¶

format_str = 'https://console.cloud.google.com/dataproc/jobs/{job_id}?region={region}&project={project_id}'[原始碼]¶

static persist(context, operator, job_id, region, project_id)[原始碼]¶

class airflow.providers.google.cloud.links.dataproc.DataprocWorkflowLink[原始碼]¶

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

用於構造 Dataproc 工作流連結的輔助類。

name = 'Dataproc 工作流'[原始碼]¶: 連結的名稱。這將是任務 UI 上的按鈕名稱。

key = 'dataproc_workflow'[原始碼]¶

format_str = 'https://console.cloud.google.com/dataproc/workflows/instances/{region}/{workflow_id}?project={pr...'[原始碼]¶

static persist(context, operator, workflow_id, project_id, region)[原始碼]¶

class airflow.providers.google.cloud.links.dataproc.DataprocWorkflowTemplateLink[原始碼]¶

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

用於構造 Dataproc 工作流模板連結的輔助類。

name = 'Dataproc 工作流模板'[原始碼]¶: 連結的名稱。這將是任務 UI 上的按鈕名稱。

key = 'dataproc_workflow_template'[原始碼]¶

format_str = 'https://console.cloud.google.com/dataproc/workflows/templates/{region}/{workflow_template_id}?pr...'[原始碼]¶

static persist(context, operator, workflow_template_id, project_id, region)[原始碼]¶

class airflow.providers.google.cloud.links.dataproc.DataprocBatchLink[原始碼]¶

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

用於構造 Dataproc 批次作業連結的輔助類。

name = 'Dataproc 批次作業'[原始碼]¶: 連結的名稱。這將是任務 UI 上的按鈕名稱。

key = 'dataproc_batch'[原始碼]¶

format_str = 'https://console.cloud.google.com/dataproc/batches/{region}/{batch_id}/monitoring?project={project_id}'[原始碼]¶

static persist(context, operator, batch_id, project_id, region)[原始碼]¶

class airflow.providers.google.cloud.links.dataproc.DataprocBatchesListLink[原始碼]¶

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

用於構造 Dataproc 批次作業列表連結的輔助類。

name = 'Dataproc 批次作業列表'[原始碼]¶: 連結的名稱。這將是任務 UI 上的按鈕名稱。

key = 'dataproc_batches_list'[原始碼]¶

format_str = 'https://console.cloud.google.com/dataproc/batches?project={project_id}'[原始碼]¶

static persist(context, operator, project_id)[原始碼]¶