DatabricksReposDeleteOperator¶
使用 DatabricksReposDeleteOperator 透過 api/2.0/repos/ API 端點來刪除現有的 Databricks Repo。
使用 Operator¶
要使用此 Operator,您需要提供 repo_path 或 repo_id。
引數 |
輸入 |
|---|---|
repo_path: str |
現有 Databricks Repos 的路徑,例如, |
repo_id: str |
現有 Databricks Repos 的 ID(如果未提供 |
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)