airflow.providers.google.cloud.links.dataproc

此模組包含 Google Dataproc 連結。

模組內容

類別

DataprocLink

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

DataprocListLink

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

DataprocClusterLink

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

DataprocJobLink

用於建構 Dataproc 工作連結的輔助類別。

DataprocWorkflowLink

用於建構 Dataproc 工作流程連結的輔助類別。

DataprocWorkflowTemplateLink

用於建構 Dataproc 工作流程範本連結的輔助類別。

DataprocBatchLink

用於建構 Dataproc 批次連結的輔助類別。

DataprocBatchesListLink

用於建構 Dataproc 批次列表連結的輔助類別。

函數

__getattr__(name)

屬性

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

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

基底類別： airflow.models.BaseOperatorLink

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

警告

此連結即將被棄用。

name = 'Dataproc 資源'[原始碼]
key = 'conf'[原始碼]
static persist(context, task_instance, url, resource)[原始碼]

連結至外部系統。

注意：此函數的舊簽章為 (self, operator, dttm: datetime)。在執行時仍支援該簽章，但已被棄用。

參數
傳回

外部系統連結

傳回類型

str

__attrs_post_init__()[原始碼]

基底類別： airflow.models.BaseOperatorLink

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

警告

此連結已被棄用。

name = 'Dataproc 資源列表'[原始碼]
key = 'list_conf'[原始碼]
static persist(context, task_instance, url)[原始碼]

連結至外部系統。

注意：此函數的舊簽章為 (self, operator, dttm: datetime)。在執行時仍支援該簽章，但已被棄用。

參數
傳回

外部系統連結

傳回類型

str

__attrs_post_init__()[原始碼]

基底類別： airflow.providers.google.cloud.links.base.BaseGoogleLink

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

name = 'Dataproc 叢集'[原始碼]
key = 'dataproc_cluster'[原始碼]
format_str[原始碼]
static persist(context, operator, cluster_id, region, project_id)[原始碼]

基底類別： airflow.providers.google.cloud.links.base.BaseGoogleLink

用於建構 Dataproc 工作連結的輔助類別。

name = 'Dataproc 工作'[原始碼]
key = 'dataproc_job'[原始碼]
format_str[原始碼]
static persist(context, operator, job_id, region, project_id)[原始碼]

基底類別： airflow.providers.google.cloud.links.base.BaseGoogleLink

用於建構 Dataproc 工作流程連結的輔助類別。

name = 'Dataproc 工作流程'[原始碼]
key = 'dataproc_workflow'[原始碼]
format_str[原始碼]
static persist(context, operator, workflow_id, project_id, region)[原始碼]

基底類別： airflow.providers.google.cloud.links.base.BaseGoogleLink

用於建構 Dataproc 工作流程範本連結的輔助類別。

name = 'Dataproc 工作流程範本'[原始碼]
key = 'dataproc_workflow_template'[原始碼]
format_str[原始碼]
static persist(context, operator, workflow_template_id, project_id, region)[原始碼]

基底類別： airflow.providers.google.cloud.links.base.BaseGoogleLink

用於建構 Dataproc 批次連結的輔助類別。

name = 'Dataproc 批次'[原始碼]
key = 'dataproc_batch'[原始碼]
format_str[原始碼]
static persist(context, operator, batch_id, project_id, region)[原始碼]

基底類別： airflow.providers.google.cloud.links.base.BaseGoogleLink

用於建構 Dataproc 批次列表連結的輔助類別。

name = 'Dataproc 批次列表'[原始碼]
key = 'dataproc_batches_list'[原始碼]
format_str[原始碼]
static persist(context, operator, project_id)[原始碼]

此條目是否有幫助？