气流 initdb：无法从“pendulum”导入名称“Pendulum”

Question

我在名为 engdados 的 Anaconda 环境之一中安装了气流。当我执行命令 airflow initdb 时，出现以下错误：airflow initdb: cannot import name 'Pendulum' from 'pendulum'。完整的回溯如下所示：

(engdados) guilherme@Athena-LNX:~$ airflow initdb
Traceback (most recent call last):
  File "/home/guilherme/anaconda3/envs/engdados/bin/airflow", line 25, in <module>
    from airflow.configuration import conf
  File "/home/guilherme/anaconda3/envs/engdados/lib/python3.8/site-packages/airflow/__init__.py", line 47, in <module>
    settings.initialize()
  File "/home/guilherme/anaconda3/envs/engdados/lib/python3.8/site-packages/airflow/settings.py", line 403, in initialize
    configure_adapters()
  File "/home/guilherme/anaconda3/envs/engdados/lib/python3.8/site-packages/airflow/settings.py", line 319, in configure_adapters
    from pendulum import Pendulum
ImportError: cannot import name 'Pendulum' from 'pendulum' (/home/guilherme/anaconda3/envs/engdados/lib/python3.8/site-packages/pendulum/__init__.py)
(engdados) guilherme@Athena-LNX:~$ service start mysql$
start: unrecognized service
(engdados) guilherme@Athena-LNX:~$ service mysql start$
Usage: /etc/init.d/mysql start|stop|restart|reload|force-reload|status|bootstrap
(engdados) guilherme@Athena-LNX:~$ airflow initdb
Traceback (most recent call last):
  File "/home/guilherme/anaconda3/envs/engdados/bin/airflow", line 25, in <module>
    from airflow.configuration import conf
  File "/home/guilherme/anaconda3/envs/engdados/lib/python3.8/site-packages/airflow/__init__.py", line 47, in <module>
    settings.initialize()
  File "/home/guilherme/anaconda3/envs/engdados/lib/python3.8/site-packages/airflow/settings.py", line 403, in initialize
    configure_adapters()
  File "/home/guilherme/anaconda3/envs/engdados/lib/python3.8/site-packages/airflow/settings.py", line 319, in configure_adapters
    from pendulum import Pendulum
ImportError: cannot import name 'Pendulum' from 'pendulum' (/home/guilherme/anaconda3/envs/engdados/lib/python3.8/site-packages/pendulum/__init__.py)

问题是：摆锤安装好了！当我执行conda list命令时，我可以看到摆锤，如下所示：

 Name                    Version                   Build  Channel

pendulum                  2.1.2                    pypi_0    pypi

到目前为止我检查过的内容：

engdados环境是否激活？是的

Pendulum是否安装在Anaconda环境上？是的

Pendulum the Anaconda 显示的版本与 conda 列表 (1.4.4) 中显示的版本不同。为什么？

我不知道发生了什么事。提前致谢。

Answer 1

在 pendulum 版本 2 中，该类pendulum.Pendulum被替换为pendulum.DateTime.

您的气流版本预计为 pendulum 1.x，但您的环境为 2.x。

您可以通过创建一个新环境并安装airflow 2.0（使用pendulum 2.x）来解决此问题。如果必须使用气流 < 2.0，则需要将摆固定为 < 2.0（例如使用 pip 约束）。