FAB CLI 命令

注意

以下 CLI 命令来自 Airflow 2.9.0+ 中的 FAB provider。以前,它们是 Airflow 核心的一部分,因此如果您使用的 Airflow 版本低于 2.9.0,请参阅 Airflow 核心文档以获取可用 CLI 命令和参数列表。

Usage: airflow [-h] GROUP_OR_COMMAND ...

位置参数

GROUP_OR_COMMAND

可能选项: users, roles, sync-perm, fab-db

子命令

users

管理用户

airflow users [-h] COMMAND ...

位置参数

COMMAND

可能选项: add-role, create, delete, export, import, list, remove-role, reset-password

子命令

add-role

为用户添加角色

airflow users add-role [-h] [-e EMAIL] -r ROLE [-u USERNAME] [-v]
命名参数
-e, --email

用户的电子邮件

-r, --role

用户的角色。现有角色包括 Admin, User, Op, Viewer, 和 Public

-u, --username

用户的用户名

-v, --verbose

使日志输出更详细

默认值: False

create

创建一个用户

airflow users create [-h] -e EMAIL -f FIRSTNAME -l LASTNAME [-p PASSWORD] -r
                     ROLE [--use-random-password] -u USERNAME [-v]
命名参数
-e, --email

用户的电子邮件

-f, --firstname

用户的名

-l, --lastname

用户的姓

-p, --password

用户密码,创建用户时如果未使用 –use-random-password 则必填

-r, --role

用户的角色。现有角色包括 Admin, User, Op, Viewer, 和 Public

--use-random-password

不提示输入密码。改用随机字符串。创建用户时如果未使用 –password 则必填

默认值: False

-u, --username

用户的用户名

-v, --verbose

使日志输出更详细

默认值: False

示例: 要创建具有“Admin”角色且用户名为“admin”的用户,请运行

$ airflow users create

–username admin –firstname FIRST_NAME –lastname LAST_NAME –role Admin –email admin@example.org

delete

删除用户

airflow users delete [-h] [-e EMAIL] [-u USERNAME] [-v]
命名参数
-e, --email

用户的电子邮件

-u, --username

用户的用户名

-v, --verbose

使日志输出更详细

默认值: False

export

导出所有用户

airflow users export [-h] [-v] FILEPATH
位置参数
FILEPATH

将所有用户导出到 JSON 文件

命名参数
-v, --verbose

使日志输出更详细

默认值: False

import

导入用户

airflow users import [-h] [-v] FILEPATH
位置参数
FILEPATH

从 JSON 文件导入用户。示例格式

[
    {
        "email": "foo@bar.org",
        "firstname": "Jon",
        "lastname": "Doe",
        "roles": ["Public"],
        "username": "jondoe"
    }
]
命名参数
-v, --verbose

使日志输出更详细

默认值: False

list

列出用户

airflow users list [-h] [-o table, json, yaml, plain] [-v]
命名参数
-o, --output

可能选项: table, json, yaml, plain

输出格式。允许的值: json, yaml, plain, table (默认值: table)

默认值: “table”

-v, --verbose

使日志输出更详细

默认值: False

remove-role

从用户移除角色

airflow users remove-role [-h] [-e EMAIL] -r ROLE [-u USERNAME] [-v]
命名参数
-e, --email

用户的电子邮件

-r, --role

用户的角色。现有角色包括 Admin, User, Op, Viewer, 和 Public

-u, --username

用户的用户名

-v, --verbose

使日志输出更详细

默认值: False

reset-password

重置用户密码

airflow users reset-password [-h] [-e EMAIL] [-p PASSWORD]
                             [--use-random-password] [-u USERNAME] [-v]
命名参数
-e, --email

用户的电子邮件

-p, --password

用户密码,创建用户时如果未使用 –use-random-password 则必填

--use-random-password

不提示输入密码。改用随机字符串。创建用户时如果未使用 –password 则必填

默认值: False

-u, --username

用户的用户名

-v, --verbose

使日志输出更详细

默认值: False

示例: 要重置用户名为“admin”的用户,请运行

$ airflow users reset-password

–username admin

roles

管理角色

airflow roles [-h] COMMAND ...

位置参数

COMMAND

可能选项: add-perms, create, del-perms, delete, export, import, list

子命令

add-perms

添加角色权限

airflow roles add-perms [-h] -a [ACTION ...] -r [RESOURCE ...] [-v] [role ...]
位置参数
role

角色名称

命名参数
-a, --action

权限的操作

-r, --resource

权限名称

-v, --verbose

使日志输出更详细

默认值: False

create

创建角色

airflow roles create [-h] [-v] [role ...]
位置参数
role

角色名称

命名参数
-v, --verbose

使日志输出更详细

默认值: False

del-perms

删除角色权限

airflow roles del-perms [-h] [-a [ACTION ...]] -r [RESOURCE ...] [-v]
                        [role ...]
位置参数
role

角色名称

命名参数
-a, --action

权限的操作

-r, --resource

权限名称

-v, --verbose

使日志输出更详细

默认值: False

delete

删除角色

airflow roles delete [-h] [-v] [role ...]
位置参数
role

角色名称

命名参数
-v, --verbose

使日志输出更详细

默认值: False

export

从数据库导出角色(不含权限)到 JSON 文件

airflow roles export [-h] [-p] [-v] file
位置参数
file

将所有角色导出到 JSON 文件

命名参数
-p, --pretty

格式化输出 JSON 文件,按角色名称排序并缩进 4 个空格

默认值: False

-v, --verbose

使日志输出更详细

默认值: False

import

从 JSON 文件导入角色(不含权限)到数据库

airflow roles import [-h] [-v] file
位置参数
file

从 JSON 文件导入角色

命名参数
-v, --verbose

使日志输出更详细

默认值: False

list

列出角色

airflow roles list [-h] [-o table, json, yaml, plain] [-p] [-v]
命名参数
-o, --output

可能选项: table, json, yaml, plain

输出格式。允许的值: json, yaml, plain, table (默认值: table)

默认值: “table”

-p, --permission

显示角色权限

默认值: False

-v, --verbose

使日志输出更详细

默认值: False

sync-perm

更新现有角色和可选的 DAG 的权限

airflow sync-perm [-h] [--include-dags] [-v]

命名参数

--include-dags

如果传入此参数,DAG 特定权限也将同步。

默认值: False

-v, --verbose

使日志输出更详细

默认值: False

fab-db

管理 FAB

airflow fab-db [-h] COMMAND ...

位置参数

COMMAND

可能选项: downgrade, migrate, reset

子命令

downgrade

降级 FAB 元数据数据库的模式。您必须提供 –to-revision–to-version 之一。要打印但不执行命令,请使用选项 –show-sql-only。如果使用选项 –from-revision–from-version,您也必须使用 –show-sql-only,因为如果实际运行迁移,我们应该只从当前的 Alembic 版本进行迁移。

airflow fab-db downgrade [-h] [--from-revision FROM_REVISION]
                         [--from-version FROM_VERSION] [-s] [-r TO_REVISION]
                         [-n TO_VERSION] [-v] [-y]
命名参数
--from-revision

(可选)如果生成 sql,可以提供一个起始 Alembic 版本

--from-version

(可选)如果生成 sql,可以提供一个起始版本

-s, --show-sql-only

不实际运行迁移;只打印出用于离线迁移的 sql 脚本。如果使用 –from-revision–from-version 则必填。

默认值: False

-r, --to-revision

要降级到的 Alembic 版本。注意: 必须提供 –to-revision–to-version 之一。

-n, --to-version

(可选)如果提供此参数,只运行迁移到此版本为止。

-v, --verbose

使日志输出更详细

默认值: False

-y, --yes

不提示确认。请谨慎使用!

默认值: False

migrate

迁移 FAB 元数据数据库的模式。如果数据库不存在则创建它。要打印但不执行命令,请使用选项 --show-sql-only。如果使用选项 --from-revision--from-version,您也必须使用 --show-sql-only,因为如果实际运行迁移,我们应该只从当前的 Alembic 版本进行迁移。

airflow fab-db migrate [-h] [--from-revision FROM_REVISION]
                       [--from-version FROM_VERSION] [-s] [-r TO_REVISION]
                       [-n TO_VERSION] [-v]
命名参数
--from-revision

(可选)如果生成 sql,可以提供一个起始 Alembic 版本

--from-version

(可选)如果生成 sql,可以提供一个起始版本

-s, --show-sql-only

不实际运行迁移;只打印出用于离线迁移的 sql 脚本。如果使用 –from-revision–from-version 则必填。

默认值: False

-r, --to-revision

(可选)如果提供此参数,只运行迁移到此 Alembic 版本(含)为止。

-n, --to-version

(可选)要升级到的 Airflow 版本。注意: 必须提供 –to-revision–to-version 之一。

-v, --verbose

使日志输出更详细

默认值: False

reset

销毁并重建 FAB 元数据数据库

airflow fab-db reset [-h] [-s] [-v] [-y]
命名参数
-s, --skip-init

只删除表;不执行数据库初始化。

默认值: False

-v, --verbose

使日志输出更详细

默认值: False

-y, --yes

不提示确认。请谨慎使用!

默认值: False

这篇文章有帮助吗?