在WSL上安装并运行气流

Question

我按照这篇文章中的过程在Ubuntu WSL (Windows 10)下安装了气流。

但是当运行airflow db init时，我得到以下错误:

AttributeError: module 'wtforms.fields' has no attribute 'TextField'

完整的跟踪:

(airflow_env) sultani@Khalid:~/c/users/administrator/airflowhome$ airflow db init
DB: sqlite:///c/users/administrator/airflowhome/airflow.db
[2022-06-09 00:41:54,760] {db.py:1448} INFO - Creating tables
INFO  [alembic.runtime.migration] Context impl SQLiteImpl.
INFO  [alembic.runtime.migration] Will assume non-transactional DDL.
Traceback (most recent call last):
File "/home/sultani/.local/bin/airflow", line 8, in <module>
sys.exit(main())
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/__main__.py", line 38, in main
args.func(args)
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/cli/cli_parser.py", line 51, in command
return func(*args, **kwargs)
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/cli/commands/db_command.py", line 35, in initdb
db.initdb()
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/utils/session.py", line 71, in wrapper
return func(*args, session=session, **kwargs)
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/utils/db.py", line 648, in initdb
upgradedb(session=session)
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/utils/session.py", line 68, in wrapper
return func(*args, **kwargs)
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/utils/db.py", line 1449, in upgradedb
command.upgrade(config, revision=to_revision or 'heads')
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/command.py", line 322, in upgrade
script.run_env()
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/base.py", line 569, in run_env
util.load_python_file(self.dir, "env.py")
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/util/pyfiles.py", line 94, in load_python_file
module = load_module_py(module_id, path)
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/util/pyfiles.py", line 110, in load_module_py
spec.loader.exec_module(module)  # type: ignore
File "<frozen importlib._bootstrap_external>", line 848, in exec_module
File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/migrations/env.py", line 107, in <module>
run_migrations_online()
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/migrations/env.py", line 101, in run_migrations_online
context.run_migrations()
File "<string>", line 8, in run_migrations
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/runtime/environment.py", line 853, in run_migrations
self.get_context().run_migrations(**kw)
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/runtime/migration.py", line 611, in run_migrations
for step in self._migrations_fn(heads, self):
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/command.py", line 311, in upgrade
return script._upgrade_revs(revision, rev)
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/base.py", line 443, in _upgrade_revs
for script in reversed(list(revs))
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/revision.py", line 799, in iterate_revisions
revisions, heads = fn(
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/revision.py", line 1426, in _collect_upgrade_revisions
for rev in self._parse_upgrade_target(
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/revision.py", line 1218, in _parse_upgrade_target
return self.get_revisions(target)
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/revision.py", line 529, in get_revisions
resolved_id, branch_label = self._resolve_revision_number(
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/revision.py", line 753, in _resolve_revision_number
self._revision_map
File "/home/sultani/.local/lib/python3.8/site-packages/sqlalchemy/util/langhelpers.py", line 1095, in __get__
obj.__dict__[self.__name__] = result = self.fget(obj)
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/revision.py", line 191, in _revision_map
for revision in self._generator():
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/base.py", line 140, in _load_revisions
script = Script._from_filename(self, vers, file_)
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/script/base.py", line 1013, in _from_filename
module = util.load_python_file(dir_, filename)
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/util/pyfiles.py", line 94, in load_python_file
module = load_module_py(module_id, path)
File "/home/sultani/.local/lib/python3.8/site-packages/alembic/util/pyfiles.py", line 110, in load_module_py
spec.loader.exec_module(module)  # type: ignore
File "<frozen importlib._bootstrap_external>", line 848, in exec_module
File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
File "/home/sultani/.local/lib/python3.8/site-packages/airflow/migrations/versions/0073_2_0_0_prefix_dag_permissions.py", line 27, in <module>
from flask_appbuilder import SQLA
File "/home/sultani/.local/lib/python3.8/site-packages/flask_appbuilder/__init__.py", line 6, in <module>
from .base import AppBuilder  # noqa: F401
File "/home/sultani/.local/lib/python3.8/site-packages/flask_appbuilder/base.py", line 8, in <module>
from .api.manager import OpenApiManager
File "/home/sultani/.local/lib/python3.8/site-packages/flask_appbuilder/api/manager.py", line 8, in <module>
from flask_appbuilder.baseviews import BaseView
File "/home/sultani/.local/lib/python3.8/site-packages/flask_appbuilder/baseviews.py", line 21, in <module>
from .forms import GeneralModelConverter
File "/home/sultani/.local/lib/python3.8/site-packages/flask_appbuilder/forms.py", line 25, in <module>
from .models.mongoengine.fields import MongoFileField, MongoImageField
File "/home/sultani/.local/lib/python3.8/site-packages/flask_appbuilder/models/mongoengine/fields.py", line 4, in <module>
from ...upload import BS3FileUploadFieldWidget, BS3ImageUploadFieldWidget
File "/home/sultani/.local/lib/python3.8/site-packages/flask_appbuilder/upload.py", line 106, in <module>
class FileUploadField(fields.TextField):
AttributeError: module 'wtforms.fields' has no attribute 'TextField'

Answer 1

不幸的是，你链接的博客文章有几个问题:

• 至少有两个错误。首先，AIRFLOW_HOME变量前面缺失的/。此外，博客建议将/mnt/c更改为/c，但随后继续在AIRFLOW_HOME中使用/mnt/c，这将不起作用。

• 坏建议——一般来说，你不应该在WSL2项目中使用Windows驱动器(例如/mnt/c)。有性能问题和权限问题需要处理。

• 不必要的步骤—绝对没有理由将WSL自动挂载目录更改为/，即使您使用将气流安装到Windows驱动器的坏建议。我建议编辑您的WSL配置文件来改变这一点，除非由于其他原因，您希望在那里。从/etc/wsl.conf中删除root = /行

• 不必要的包和repos——没有理由添加Universe，因为它已经在WSL Ubuntu中存在(并且一直存在)。没有理由安装software-properties-common或python-setuptools——它们不是必需的。

• 最糟糕的是，它只是过时和/或冲突的官方文件。这是安装过程中最大的问题——您将在实际安装过程中看到一个错误，即存在不兼容的包版本。

所以让我推荐以下组合:

• Python最佳实践——博客实际上在某种程度上做到了这一点，使用虚拟环境来避免污染通用Python系统包。
• WSL2最佳实践—您可以参考上面链接的官方文档。这篇博文简直是一个糟糕的方式。
• 官方文件。

你可能想要删除你的Ubuntu WSL2安装，然后在这里重新开始，如果你不使用它做任何其他事情。我从一个干净的Ubuntu 20.04 WSL2安装开始演示:

sudo apt update && sudo apt upgrade -y
sudo apt install python3-pip python3-venv
mkdir -p ~/airflow/airflowhome
python3 -m venv ~/airflow/airflowenv
source ~/airflow/airflowenv/bin/activate
# Your prompt will change to "airflowenv"
pip3 install wheel # Not found in venv by default, but recommended for packages

在这一点上，我们开始直接从Apache的气流文档，没有实质性的变化，除了一个小的目录更改:

export AIRFLOW_HOME=~/airflow/airflowhome
AIRFLOW_VERSION=2.3.2
PYTHON_VERSION="$(python --version | cut -d " " -f 2 | cut -d "." -f 1-2)"
CONSTRAINT_URL="https://raw.githubusercontent.com/apache/airflow/constraints-${AIRFLOW_VERSION}/constraints-${PYTHON_VERSION}.txt"
pip install "apache-airflow==${AIRFLOW_VERSION}" --constraint "${CONSTRAINT_URL}"

仔细观察输出。您应该不会看到任何错误——之前使用博客说明的尝试显示了红色文本错误，这提前指出了问题。

:

airflow standalone

启动服务器。正如医生所说，要密切关注屏幕上的最后几行。它将列出您的管理员用户名和密码。您可以使用它通过您的Windows web浏览器登录http://localhost:8080。

您仍然可以将export AIRFLOW_HOME语句添加到~/.bashrc中，但由于每次都需要激活venv，因此最好只在那时执行。所以下次要运行它，你可以:

source ~/airflow/airflowenv/bin/activate
export AIRFLOW_HOME=~/airflow/airflowhome
airflow standalone

注意:任何时候执行source ~/airflow/airflowenv/bin/activate，都将处于Python虚拟环境中。要返回默认的Python系统环境，只需运行deactivate。

我自己不是一个气流用户，所以我不能帮助你更多。但这些步骤对我来说是有效的，至少可以让它在WSL2 Ubuntu上运行起来。

Answer 2

感谢回复，提供的博客中有几个问题，我设法在本地运行了气流。

1. /在C之前缺失，路径必须更改为AIRFLOW_HOME=/C/users/YOURNAME/airflowwhome .
2. 我必须从https://pypi.org/project/apache-airflow/安装气流其余步骤都很好。

因为我是新的气流，我需要解决一些其他的问题，现在在pycharm它给丢失的依赖当我创建dag文件在dag文件夹。