airflow.providers.google.cloud.hooks.cloud_run¶

類¶

`CloudRunHook`	Google Cloud Run 服務的 Hook。
`CloudRunAsyncHook`	Google Cloud Run 服務的非同步 Hook。
`CloudRunServiceHook`	Google Cloud Run 服務的 Hook。
`CloudRunServiceAsyncHook`	Google Cloud Run 服務的非同步 Hook。

模組內容¶

class airflow.providers.google.cloud.hooks.cloud_run.CloudRunHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Run 服務的 Hook。

引數：

gcp_conn_id (str) – 獲取連線資訊時使用的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號，用於使用短期憑據進行模擬，或者是一個賬號鏈，用於獲取鏈中最後一個賬號的 access_token，該賬號將在請求中被模擬。如果設定為字串，則該賬號必須授予原始賬號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須授予緊前身份 Service Account Token Creator IAM 角色，列表中的第一個賬號將此角色授予原始賬號。

get_conn()[source]¶

獲取 Cloud Run 連線。

返回值：: Cloud Run Jobs 客戶端物件。

delete_job(job_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶

create_job(job_name, job, region, project_id=PROVIDE_PROJECT_ID)[source]¶

update_job(job_name, job, region, project_id=PROVIDE_PROJECT_ID)[source]¶

execute_job(job_name, region, project_id=PROVIDE_PROJECT_ID, overrides=None)[source]¶

get_job(job_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶

list_jobs(region, project_id=PROVIDE_PROJECT_ID, show_deleted=False, limit=None)[source]¶

class airflow.providers.google.cloud.hooks.cloud_run.CloudRunAsyncHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Run 服務的非同步 Hook。

引數：

gcp_conn_id (str) – 獲取連線資訊時使用的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號，用於使用短期憑據進行模擬，或者是一個賬號鏈，用於獲取鏈中最後一個賬號的 access_token，該賬號將在請求中被模擬。如果設定為字串，則該賬號必須授予原始賬號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須授予緊前身份 Service Account Token Creator IAM 角色，列表中的第一個賬號將此角色授予原始賬號。

get_conn()[source]¶: 返回此 Hook 的連線。

async get_operation(operation_name)[source]¶

class airflow.providers.google.cloud.hooks.cloud_run.CloudRunServiceHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Run 服務的 Hook。

引數：

gcp_conn_id (str) – 獲取連線資訊時使用的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號，用於使用短期憑據進行模擬，或者是一個賬號鏈，用於獲取鏈中最後一個賬號的 access_token，該賬號將在請求中被模擬。如果設定為字串，則該賬號必須授予原始賬號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須授予緊前身份 Service Account Token Creator IAM 角色，列表中的第一個賬號將此角色授予原始賬號。

get_conn()[source]¶: 返回此 Hook 的連線。

get_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶

create_service(service_name, service, region, project_id=PROVIDE_PROJECT_ID)[source]¶

delete_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶

class airflow.providers.google.cloud.hooks.cloud_run.CloudRunServiceAsyncHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

Google Cloud Run 服務的非同步 Hook。

引數：

gcp_conn_id (str) – 獲取連線資訊時使用的連線 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號，用於使用短期憑據進行模擬，或者是一個賬號鏈，用於獲取鏈中最後一個賬號的 access_token，該賬號將在請求中被模擬。如果設定為字串，則該賬號必須授予原始賬號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須授予緊前身份 Service Account Token Creator IAM 角色，列表中的第一個賬號將此角色授予原始賬號。

get_conn()[source]¶: 返回此 Hook 的連線。

async create_service(service_name, service, region, project_id=PROVIDE_PROJECT_ID)[source]¶

async delete_service(service_name, region, project_id=PROVIDE_PROJECT_ID)[source]¶