airflow.providers.google.cloud.links.dataflow¶

此模組包含 Google Dataflow 連結。

屬性¶

`DataflowJobLink`	用於構建 Dataflow Job 連結的輔助類。
`DataflowPipelineLink`	用於構建 Dataflow Pipeline 連結的輔助類。

airflow.providers.google.cloud.links.dataflow.DATAFLOW_BASE_LINK = '/dataflow/jobs'[原始碼]¶

airflow.providers.google.cloud.links.dataflow.DATAFLOW_JOB_LINK = '/dataflow/jobs/{region}/{job_id}?project={project_id}'[原始碼]¶

airflow.providers.google.cloud.links.dataflow.DATAFLOW_PIPELINE_BASE_LINK = '/dataflow/pipelines'[原始碼]¶

airflow.providers.google.cloud.links.dataflow.DATAFLOW_PIPELINE_LINK = '/dataflow/pipelines/{location}/{pipeline_name}?project={project_id}'[原始碼]¶

class airflow.providers.google.cloud.links.dataflow.DataflowJobLink[原始碼]¶

用於構建 Dataflow Job 連結的輔助類。

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

class airflow.providers.google.cloud.links.dataflow.DataflowPipelineLink[原始碼]¶

用於構建 Dataflow Pipeline 連結的輔助類。

format_str = '/dataflow/pipelines/{location}/{pipeline_name}?project={project_id}'[原始碼]¶

static persist(operator_instance, context, project_id, location, pipeline_name)[原始碼]¶