DatabricksReposDeleteOperator

使用 DatabricksReposDeleteOperator 透過 api/2.0/repos/ API 端點來刪除現有的 Databricks Repo

使用 Operator

要使用此 Operator,您需要提供 repo_pathrepo_id

引數

輸入

repo_path: str

現有 Databricks Repos 的路徑,例如,/Repos/<user_email>/repo_name(如果未提供 repo_id 則必需)。

repo_id: str

現有 Databricks Repos 的 ID(如果未提供 repo_path 則必需)。

databricks_conn_id: string

要使用的 Airflow 連線名稱。

databricks_retry_limit: integer

如果 Databricks 後端無法訪問時重試的次數。

databricks_retry_delay: decimal

兩次重試之間的等待秒數。

示例

透過指定路徑刪除 Databricks Repo

DatabricksReposDeleteOperator 的示例用法如下

tests/system/databricks/example_databricks_repos.py

    # Example of deleting a Databricks Repo
    repo_path = "/Repos/user@domain.com/demo-repo"
    delete_repo = DatabricksReposDeleteOperator(task_id="delete_repo", repo_path=repo_path)

此條目有幫助嗎?