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]

繼承自： 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 的鏈式帳戶清單，該帳戶將在請求中被模擬。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」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]

繼承自： 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 的鏈式帳戶清單，該帳戶將在請求中被模擬。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」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]

繼承自： 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 的鏈式帳戶清單，該帳戶將在請求中被模擬。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」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]

繼承自： 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 的鏈式帳戶清單，該帳戶將在請求中被模擬。如果設定為字串，則該帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」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]

這篇文章是否有幫助？