airflow.providers.google.cloud.operators.dataform

模組內容

類別

DataformCreateCompilationResultOperator

在給定的專案和位置中建立新的 CompilationResult。

DataformGetCompilationResultOperator

提取單個 CompilationResult。

DataformCreateWorkflowInvocationOperator

在給定的儲存庫中建立新的 WorkflowInvocation。

DataformGetWorkflowInvocationOperator

提取單個 WorkflowInvocation。

DataformQueryWorkflowInvocationActionsOperator

在給定的 WorkflowInvocation 中傳回 WorkflowInvocationActions。

DataformCancelWorkflowInvocationOperator

請求取消正在執行的 WorkflowInvocation。

DataformCreateRepositoryOperator

建立儲存庫。

DataformDeleteRepositoryOperator

刪除儲存庫。

DataformCreateWorkspaceOperator

建立工作區。

DataformDeleteWorkspaceOperator

刪除工作區。

DataformWriteFileOperator

將新檔案寫入指定的工作區。

DataformMakeDirectoryOperator

在指定的工作區中建立新目錄。

DataformRemoveFileOperator

移除指定工作區中的檔案。

DataformRemoveDirectoryOperator

移除指定工作區中的目錄。

DataformInstallNpmPackagesOperator

在提供的工作區中安裝 NPM 依賴項。
class airflow.providers.google.cloud.operators.dataform.DataformCreateCompilationResultOperator(project_id, region, repository_id, compilation_result, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

在給定的專案和位置中建立新的 CompilationResult。

參數

  • project_id (str) – 必須填寫。工作所屬的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。工作所屬的 Google Cloud 區域 ID。

  • repository_id (str) – 必須填寫。工作所屬的 Dataform 儲存庫 ID。

  • compilation_result (google.cloud.dataform_v1beta1.types.CompilationResult | dict) – 必須填寫。要建立的編譯結果。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

template_fields = ('project_id', 'region', 'repository_id', 'compilation_result', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformGetCompilationResultOperator(project_id, region, repository_id, compilation_result_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

提取單個 CompilationResult。

參數

  • project_id (str) – 必須填寫。工作所屬的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。工作所屬的 Google Cloud 區域 ID。

  • repository_id (str) – 必須填寫。工作所屬的 Dataform 儲存庫 ID。

  • compilation_result_id (str) – Dataform Compilation Result 的 ID

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

template_fields = ('project_id', 'region', 'repository_id', 'compilation_result_id', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformCreateWorkflowInvocationOperator(project_id, region, repository_id, workflow_invocation, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, asynchronous=False, wait_time=10, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

在給定的儲存庫中建立新的 WorkflowInvocation。

參數

  • project_id (str) – 必須填寫。工作所屬的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。工作所屬的 Google Cloud 區域 ID。

  • repository_id (str) – 必須填寫。工作所屬的 Dataform 儲存庫 ID。

  • workflow_invocation (google.cloud.dataform_v1beta1.types.WorkflowInvocation | dict) – 必須填寫。要建立的工作流程調用資源。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (int | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

  • asynchronous (bool) – 從 Dataform API 傳回 workflow_invocation_id 的旗標。這對於提交長時間執行的工作流程，並使用 DataformWorkflowInvocationStateSensor 非同步等待它們非常有用

  • wait_time (int) – 檢查之間的秒數

template_fields = ('project_id', 'region', 'repository_id', 'workflow_invocation', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformGetWorkflowInvocationOperator(project_id, region, repository_id, workflow_invocation_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

提取單個 WorkflowInvocation。

參數

  • project_id (str) – 必須填寫。工作所屬的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。工作所屬的 Google Cloud 區域 ID。

  • repository_id (str) – 必須填寫。工作所屬的 Dataform 儲存庫 ID。

  • workflow_invocation_id (str) – 工作流程調用資源的 ID。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

template_fields = ('project_id', 'region', 'repository_id', 'workflow_invocation_id', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformQueryWorkflowInvocationActionsOperator(project_id, region, repository_id, workflow_invocation_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

在給定的 WorkflowInvocation 中傳回 WorkflowInvocationActions。

參數

  • project_id (str) – 必須填寫。工作所屬的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。工作所屬的 Google Cloud 區域 ID。

  • repository_id (str) – 必須填寫。工作所屬的 Dataform 儲存庫 ID。

  • workflow_invocation_id (str) – 工作流程調用資源的 ID。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

template_fields = ('project_id', 'region', 'repository_id', 'workflow_invocation_id', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformCancelWorkflowInvocationOperator(project_id, region, repository_id, workflow_invocation_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

請求取消正在執行的 WorkflowInvocation。

參數

  • project_id (str) – 必須填寫。工作所屬的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。工作所屬的 Google Cloud 區域 ID。

  • repository_id (str) – 必須填寫。工作所屬的 Dataform 儲存庫 ID。

  • workflow_invocation_id (str) – 工作流程調用資源的 ID。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

template_fields = ('project_id', 'region', 'repository_id', 'workflow_invocation_id', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformCreateRepositoryOperator(project_id, region, repository_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

建立儲存庫。

參數

  • project_id (str) – 必須填寫。工作所屬的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。工作所屬的 Google Cloud 區域 ID。

  • repository_id (str) – 必須填寫。工作所屬的 Dataform 儲存庫 ID。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

template_fields = ('project_id', 'region', 'repository_id', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformDeleteRepositoryOperator(project_id, region, repository_id, force=True, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

刪除儲存庫。

參數

  • project_id (str) – 必須填寫。儲存庫所在的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。儲存庫所在的 Google Cloud 區域 ID。

  • repository_id (str) – 必須填寫。應該刪除的 Dataform 儲存庫 ID。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

template_fields = ('project_id', 'region', 'repository_id', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformCreateWorkspaceOperator(project_id, region, repository_id, workspace_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[原始碼]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

建立工作區。

參數

  • project_id (str) – 必須填寫。工作區應位於的 Google Cloud 專案 ID。

  • region (str) – 必須填寫。工作區應位於的 Google Cloud 區域名稱。

  • repository_id (str) – 必須填寫。工作區所屬的 Dataform 儲存庫 ID。

  • workspace_id (str) – 必須填寫。將建立的新工作區 ID。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

template_fields = ('project_id', 'region', 'repository_id', 'workspace_id', 'impersonation_chain')[原始碼]
execute(context)[原始碼]

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformDeleteWorkspaceOperator(project_id, region, repository_id, workspace_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[source]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

刪除工作區。

參數

  • project_id (str) – 必要項目。工作區所在的 Google Cloud 專案 ID。

  • region (str) – 必要項目。工作區所在的 Google Cloud 區域 ID。

  • repository_id (str) – 必要項目。工作區所在的 Dataform 儲存庫 ID。

  • workspace_id (str) – 必要項目。應刪除的 Dataform 工作區 ID。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

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

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformWriteFileOperator(project_id, region, repository_id, workspace_id, filepath, contents, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[source]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

將新檔案寫入指定的工作區。

參數

  • project_id (str) – 必要項目。工作區所在的 Google Cloud 專案 ID。

  • region (str) – 必要項目。工作區所在的 Google Cloud 區域 ID。

  • repository_id (str) – 必要項目。工作區所在的 Dataform 儲存庫 ID。

  • workspace_id (str) – 必要項目。應在其中建立檔案的 Dataform 工作區 ID。

  • filepath (str) – 必要項目。檔案路徑，包含相對於工作區根目錄的檔案名稱。

  • contents (bytes) – 必要項目。要寫入的檔案內容。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

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

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformMakeDirectoryOperator(project_id, region, repository_id, workspace_id, directory_path, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[source]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

在指定的工作區中建立新目錄。

參數

  • project_id (str) – 必要項目。工作區所在的 Google Cloud 專案 ID。

  • region (str) – 必要項目。工作區所在的 Google Cloud 區域 ID。

  • repository_id (str) – 必要項目。工作區所在的 Dataform 儲存庫 ID。

  • workspace_id (str) – 必要項目。應在其中建立目錄的 Dataform 工作區 ID。

  • path – 必要項目。目錄的完整路徑，包含相對於工作區根目錄的目錄名稱。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

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

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformRemoveFileOperator(project_id, region, repository_id, workspace_id, filepath, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[source]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

移除指定工作區中的檔案。

參數

  • project_id (str) – 必要項目。工作區所在的 Google Cloud 專案 ID。

  • region (str) – 必要項目。工作區所在的 Google Cloud 區域 ID。

  • repository_id (str) – 必要項目。工作區所在的 Dataform 儲存庫 ID。

  • workspace_id (str) – 必要項目。目錄所在的 Dataform 工作區 ID。

  • filepath (str) – 必要項目。完整路徑，包含相對於工作區根目錄的檔案名稱。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

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

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformRemoveDirectoryOperator(project_id, region, repository_id, workspace_id, directory_path, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[source]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

移除指定工作區中的目錄。

參數

  • project_id (str) – 必要項目。工作區所在的 Google Cloud 專案 ID。

  • region (str) – 必要項目。工作區所在的 Google Cloud 區域 ID。

  • repository_id (str) – 必要項目。工作區所在的 Dataform 儲存庫 ID。

  • workspace_id (str) – 必要項目。目錄所在的 Dataform 工作區 ID。

  • path – 必要項目。目錄的完整路徑，包含相對於工作區根目錄的目錄名稱。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

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

在建立運算子時衍生。

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

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

class airflow.providers.google.cloud.operators.dataform.DataformInstallNpmPackagesOperator(project_id, region, repository_id, workspace_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, *args, **kwargs)[source]

繼承自： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

在提供的工作區中安裝 NPM 依賴項。

Requires “package.json” to be created in the workspace.

參數

  • project_id (str) – 必要項目。工作區所在的 Google Cloud 專案 ID。

  • region (str) – 必要項目。工作區所在的 Google Cloud 區域 ID。

  • repository_id (str) – 必要項目。工作區所在的 Dataform 儲存庫 ID。

  • workspace_id (str) – 必要項目。Dataform 工作區的 ID。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定應重試哪些錯誤（如果有的話）。

  • timeout (float | None) – 此請求的逾時時間。

  • metadata (collections.abc.Sequence[tuple[str, str]]) – 應與請求一起作為元數據傳送的字串。

  • gcp_conn_id (str) – 擷取連線資訊時要使用的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選填的服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中模擬身分。如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。如果設定為序列，則清單中的身分必須將「服務帳戶權杖建立者」IAM 角色授予緊接在前的身分，清單中的第一個帳戶將此角色授予原始帳戶（已範本化）。

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

在建立運算子時衍生。

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

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

此條目是否有幫助？