DatabricksReposCreateOperator

使用 DatabricksReposCreateOperator 通过 Databricks Repos 创建(并可选地签出)api/2.0/repos API 端点。

使用运算符

要使用此运算符,您至少需要提供 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: 十进制

重试之间等待的秒数。

示例

创建 Databricks Repo

DatabricksReposCreateOperator 的示例用法如下

tests/system/providers/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)

此条目是否有用?