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

基礎: 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 所需的帳號鏈列表，該帳號將在請求中被模擬。如果設定為字串，則該帳號必須向原始帳號授予 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須向直接前一個身份授予 Service Account Token Creator IAM 角色，列表中第一個帳號將此角色授予原始帳號（模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'job_name')[source]¶

project_id[source]¶

region[source]¶

job_name[source]¶

job[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

建立運算子時派生。

Context 與渲染 Jinja 模板時使用的字典相同。

有關更多 context，請參閱 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)[source]¶

基礎: 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 所需的帳號鏈列表，該帳號將在請求中被模擬。如果設定為字串，則該帳號必須向原始帳號授予 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須向直接前一個身份授予 Service Account Token Creator IAM 角色，列表中第一個帳號將此角色授予原始帳號（模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'job_name')[source]¶

project_id[source]¶

region[source]¶

job_name[source]¶

job[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

建立運算子時派生。

Context 與渲染 Jinja 模板時使用的字典相同。

有關更多 context，請參閱 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)[source]¶

基礎: 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 所需的帳號鏈列表，該帳號將在請求中被模擬。如果設定為字串，則該帳號必須向原始帳號授予 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須向直接前一個身份授予 Service Account Token Creator IAM 角色，列表中第一個帳號將此角色授予原始帳號（模板化）。

template_fields = ('project_id', 'region', 'gcp_conn_id', 'impersonation_chain', 'job_name')[source]¶

project_id[source]¶

region[source]¶

job_name[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

建立運算子時派生。

Context 與渲染 Jinja 模板時使用的字典相同。

有關更多 context，請參閱 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 所需的帳號鏈列表，該帳號將在請求中被模擬。如果設定為字串，則該帳號必須向原始帳號授予 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須向直接前一個身份授予 Service Account Token Creator IAM 角色，列表中第一個帳號將此角色授予原始帳號（模板化）。

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

project_id[source]¶

region[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

show_deleted = False[source]¶

limit = None[source]¶

execute(context)[source]¶

建立運算子時派生。

Context 與渲染 Jinja 模板時使用的字典相同。

有關更多 context，請參閱 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 所需的帳號鏈列表，該帳號將在請求中被模擬。如果設定為字串，則該帳號必須向原始帳號授予 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須向直接前一個身份授予 Service Account Token Creator IAM 角色，列表中第一個帳號將此角色授予原始帳號（模板化）。
deferrable (bool) – 在可推遲模式下執行運算子。

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

project_id[source]¶

region[source]¶

job_name[source]¶

overrides = None[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

polling_period_seconds = 10[source]¶

timeout_seconds : float | None = None[source]¶

deferrable : bool = True[source]¶

operation: google.api_core.operation.Operation | None = None[source]¶

execute(context)[source]¶

建立運算子時派生。

Context 與渲染 Jinja 模板時使用的字典相同。

有關更多 context，請參閱 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 所需的帳號鏈列表，該帳號將在請求中被模擬。如果設定為字串，則該帳號必須向原始帳號授予 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須向直接前一個身份授予 Service Account Token Creator IAM 角色，列表中第一個帳號將此角色授予原始帳號（模板化）。

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

project_id[source]¶

region[source]¶

service[source]¶

service_name[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

建立運算子時派生。

Context 與渲染 Jinja 模板時使用的字典相同。

有關更多 context，請參閱 get_template_context。

類 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 所需的帳號鏈列表，該帳號將在請求中被模擬。如果設定為字串，則該帳號必須向原始帳號授予 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須向直接前一個身份授予 Service Account Token Creator IAM 角色，列表中第一個帳號將此角色授予原始帳號（模板化）。

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

project_id[source]¶

region[source]¶

service_name[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

建立運算子時派生。

Context 與渲染 Jinja 模板時使用的字典相同。

有關更多 context，請參閱 get_template_context。