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)[源码]¶