此模块包含 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 作业链接的助手类。
-
name = 'Dataflow 作业'[源代码]
-
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 管道链接的助手类。
-
name = 'Dataflow 管道'[源代码]
-
key = 'dataflow_pipeline_config'[源代码]
-
format_str[源代码]
-
static persist(operator_instance, context, project_id, location, pipeline_name)[源代码]