airflow.providers.google.cloud.operators.cloud_run

模块内容

类

CloudRunCreateJobOperator

创建一个作业但不执行它。将创建的作业推送到 xcom。

CloudRunUpdateJobOperator

更新一个作业并等待操作完成。将更新的作业推送到 xcom。

CloudRunDeleteJobOperator

删除一个作业并等待操作完成。将删除的作业推送到 xcom。

CloudRunListJobsOperator

列出作业。

CloudRunExecuteJobOperator

执行一个作业并等待操作完成。将执行的作业推送到 xcom。

CloudRunCreateServiceOperator

创建一个服务但不执行它。将创建的服务推送到 xcom。

CloudRunDeleteServiceOperator

删除一个服务但不执行它。将删除的服务推送到 xcom。
class airflow.providers.google.cloud.operators.cloud_run.CloudRunCreateJobOperator(project_id, region, job_name, job, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

基类： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

创建一个作业但不执行它。将创建的作业推送到 xcom。

参数

  • project_id (str) – 必需。服务所属的 Google Cloud 项目的 ID。

  • region (str) – 必需。服务所属的 Google Cloud 区域的 ID。

  • job_name (str) – 必需。要创建的作业的名称。

  • job (dict | google.cloud.run_v2.Job) – 必需。包含要提交的作业配置的作业描述符。

  • gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'job_name')[源代码]
execute(context)[源代码]

在创建运算符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.cloud_run.CloudRunUpdateJobOperator(project_id, region, job_name, job, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

基类： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

更新一个作业并等待操作完成。将更新的作业推送到 xcom。

参数

  • project_id (str) – 必需。服务所属的 Google Cloud 项目的 ID。

  • region (str) – 必需。服务所属的 Google Cloud 区域的 ID。

  • job_name (str) – 必需。要更新的作业的名称。

  • job (dict | google.cloud.run_v2.Job) – 必需。包含要更新的作业新配置的作业描述符。name 字段将被 job_name 替换

  • gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'job_name')[源代码]
execute(context)[源代码]

在创建运算符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.cloud_run.CloudRunDeleteJobOperator(project_id, region, job_name, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

基类： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

删除一个作业并等待操作完成。将删除的作业推送到 xcom。

参数

  • project_id (str) – 必需。服务所属的 Google Cloud 项目的 ID。

  • region (str) – 必需。服务所属的 Google Cloud 区域的 ID。

  • job_name (str) – 必需。要删除的作业的名称。

  • gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'job_name')[源代码]
execute(context)[源代码]

在创建运算符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.cloud_run.CloudRunListJobsOperator(project_id, region, show_deleted=False, limit=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]

基类： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

列出作业。

参数

  • project_id (str) – 必需。服务所属的 Google Cloud 项目的 ID。

  • region (str) – 必需。服务所属的 Google Cloud 区域的 ID。

  • show_deleted (bool) – 如果为 true，则返回已删除（但未过期）的资源以及活动的资源。

  • limit (int | None) – 要列出的作业数。如果为空，将返回所有作业。

  • gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain')[source]
execute(context)[source]

在创建运算符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.cloud_run.CloudRunExecuteJobOperator(project_id, region, job_name, overrides=None, polling_period_seconds=10, timeout_seconds=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]

基类： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

执行一个作业并等待操作完成。将执行的作业推送到 xcom。

参数

  • project_id (str) – 必需。服务所属的 Google Cloud 项目的 ID。

  • region (str) – 必需。服务所属的 Google Cloud 区域的 ID。

  • job_name (str) – 必需。要更新的作业的名称。

  • overrides (dict[str, Any] | None) – 可选的覆盖值映射。

  • gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。

  • polling_period_seconds (float) – 可选。控制可延期运行结果轮询的频率。默认情况下，触发器将每 10 秒轮询一次。

  • timeout_seconds (float | None) – 可选。此请求的超时时间（以秒为单位）。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

  • deferrable (bool) – 以可延期模式运行运算符。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'job_name', 'overrides')[source]
execute(context)[source]

在创建运算符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

execute_complete(context, event)[source]
class airflow.providers.google.cloud.operators.cloud_run.CloudRunCreateServiceOperator(project_id, region, service_name, service, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]

基类： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

创建一个服务但不执行它。将创建的服务推送到 xcom。

参数

  • project_id (str) – 必需。服务所属的 Google Cloud 项目的 ID。

  • region (str) – 必需。服务所属的 Google Cloud 区域的 ID。

  • service_name (str) – 必需。要创建的服务的名称。

  • service (dict | google.cloud.run_v2.Service) – 包含要提交的服务的配置的服务描述符。

  • gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'service_name')[source]
execute(context)[source]

在创建运算符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.cloud_run.CloudRunDeleteServiceOperator(project_id, region, service_name, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]

基类： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

删除一个服务但不执行它。将删除的服务推送到 xcom。

参数

  • project_id (str) – 必需。服务所属的 Google Cloud 项目的 ID。

  • region (str) – 必需。服务所属的 Google Cloud 区域的 ID。

  • service_name (str) – 必需。要创建的服务的名称。

  • gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'service_name')[source]
execute(context)[source]

在创建运算符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

此条目是否有帮助？