DatabricksReposCreateOperator¶

使用 DatabricksReposCreateOperator 通过 api/2.0/repos API 端点创建（并可选地检出）一个 Databricks Repos。

使用操作符¶

要使用此操作符，您至少需要提供 git_url 参数。

参数	输入
git_url: str	Git 仓库的必需 HTTPS URL
git_provider: str	可选的 Git 提供商名称。如果我们无法从 URL 中推断出其名称，则必须提供。有关支持的 Git 提供商的实际列表，请参阅 API 文档。
branch: str	要检出的现有 Git 分支的可选名称。
tag: str	要检出的现有 Git 标签的可选名称。
repo_path: str	可选的 Databricks Repos 路径，例如 `/Repos/<user_email>/repo_name`。如果未指定，它将在用户的目录中创建。
ignore_existing_repo: bool	如果具有给定路径的存储库已存在，则不抛出异常。
databricks_conn_id: string	要使用的 Airflow 连接的名称。
databricks_retry_limit: integer	如果 Databricks 后端不可访问，则重试的次数。
databricks_retry_delay: decimal	重试之间等待的秒数。

示例¶

创建一个 Databricks Repo¶

以下是 DatabricksReposCreateOperator 的一个示例用法

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

    # Example of creating a Databricks Repo
    repo_path = "/Repos/[email protected]/demo-repo"
    git_url = "https://github.com/test/test"
    create_repo = DatabricksReposCreateOperator(task_id="create_repo", repo_path=repo_path, git_url=git_url)