此模組包含 Google Dataflow 連結。
模組內容
屬性
-
airflow.providers.google.cloud.links.dataflow.DATAFLOW_BASE_LINK = '/dataflow/jobs'[原始碼]
-
airflow.providers.google.cloud.links.dataflow.DATAFLOW_JOB_LINK[原始碼]
-
airflow.providers.google.cloud.links.dataflow.DATAFLOW_PIPELINE_BASE_LINK = '/dataflow/pipelines'[原始碼]
-
airflow.providers.google.cloud.links.dataflow.DATAFLOW_PIPELINE_LINK[原始碼]
-
class airflow.providers.google.cloud.links.dataflow.DataflowJobLink[原始碼]
基底類別： airflow.providers.google.cloud.links.base.BaseGoogleLink
用於建構 Dataflow Job 連結的輔助類別。
-
name = 'Dataflow Job'[原始碼]
-
key = 'dataflow_job_config'[原始碼]
-
format_str[原始碼]
-
static persist(operator_instance, context, project_id, region, job_id)[原始碼]
-
class airflow.providers.google.cloud.links.dataflow.DataflowPipelineLink[原始碼]
基底類別： airflow.providers.google.cloud.links.base.BaseGoogleLink
用於建構 Dataflow Pipeline 連結的輔助類別。
-
name = 'Dataflow Pipeline'[原始碼]
-
key = 'dataflow_pipeline_config'[原始碼]
-
format_str[原始碼]
-
static persist(operator_instance, context, project_id, location, pipeline_name)[原始碼]