气流initdb:不能从“摆”中导入“摆”的名称。

Question

我在我的Anaconda envs中安装了气流，名为engdados。当我执行命令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环境激活了吗？是

钟摆是否安装在Anaconda环境中？是

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

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

Answer 1

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

您的版本的气流预期摆1.x，但您的环境有2.x。

您可以通过制作一个新的env并安装气流2.0 (它使用摆式2.x)来修复这个问题。如果您必须使用气流< 2.0，您将需要钉摆到< 2.0 (例如使用pip约束)。

Answer 2

此外，如果在代码中使用摆，例如在自定义运算符中，则可以添加

try:
    from pendulum import DateTime as Pendulum
except ImportError:
    from pendulum import Pendulum