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]

Bases: 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]
execute(context)[source]

在建立運算子時衍生。

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

Bases: 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) – 必要。包含要更新的工作新配置的工作描述符。名稱欄位將被 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]
execute(context)[source]

在建立運算子時衍生。

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

Bases: 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]
execute(context)[source]

在建立運算子時衍生。

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]

Bases: 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]
execute(context)[source]

在建立運算子時衍生。

Context 與呈現 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]

Bases: 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]
execute(context)[source]

在建立運算子時衍生。

Context 與呈現 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]

Bases: 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]
execute(context)[source]

在建立運算子時衍生。

Context 與呈現 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]

Bases: 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]
execute(context)[source]

在建立運算子時衍生。

Context 與呈現 jinja 範本時使用的字典相同。

請參閱 get_template_context 以取得更多上下文。

這個條目是否有幫助？