DatabricksReposDeleteOperator¶

使用 DatabricksReposDeleteOperator 通过 api/2.0/repos/ API 端点删除现有的 Databricks 存储库。

使用操作符¶

要使用此操作符，您需要提供 repo_path 或 repo_id。

参数	输入
repo_path: str	现有 Databricks 存储库的路径，例如 `/Repos/<user_email>/repo_name`（如果未提供 `repo_id`，则为必填项）。
repo_id: str	现有 Databricks 存储库的 ID（如果未提供 `repo_path`，则为必填项）。
databricks_conn_id: string	要使用的 Airflow 连接的名称。
databricks_retry_limit: integer	如果 Databricks 后端无法访问，则重试次数。
databricks_retry_delay: decimal	重试之间等待的秒数。

示例¶

通过指定路径删除 Databricks 存储库¶

以下是 DatabricksReposDeleteOperator 的一个示例用法

tests/system/databricks/example_databricks_repos.py[源代码]

    # Example of deleting a Databricks Repo
    repo_path = "/Repos/[email protected]/demo-repo"
    delete_repo = DatabricksReposDeleteOperator(task_id="delete_repo", repo_path=repo_path)