DatabricksReposDeleteOperator¶

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

使用運算子¶

要使用此運算子，您需要提供 repo_path 或 repo_id。

參數	輸入
repo_path: 字串	現有 Databricks Repos 的路徑，例如 `/Repos/<user_email>/repo_name` (如果未提供 `repo_id`，則為必填)。
repo_id: 字串	現有 Databricks Repos 的 ID (如果未提供 `repo_path`，則為必填)。
databricks_conn_id: 字串	要使用的 Airflow 連線名稱。
databricks_retry_limit: 整數	如果 Databricks 後端無法連線時的重試次數。
databricks_retry_delay: 小數	重試之間等待的秒數。

範例¶

透過指定路徑刪除 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)