气流 initdb：无法从“钟摆”导入名称“钟摆”答案

【问题标题】：airflow initdb: cannot import name 'Pendulum' from 'pendulum'气流 initdb：无法从“钟摆”导入名称“钟摆”
【发布时间】：2020-12-18 20:00:28
【问题描述】：

我在名为 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 命令时，我可以看到 Pendulum 如下：

 Name                    Version                   Build  Channel

pendulum                  2.1.2                    pypi_0    pypi

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

engdados 环境激活了吗？是的

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

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

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

【问题讨论】：

标签： airflow pendulum

【解决方案1】：

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

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

您可以通过创建新环境并安装气流 2.0（使用 pendulum 2.x）来解决此问题。如果您必须使用气流

【讨论】：

谢谢你的线索。我已经在同一个环境中安装了 prefect，它弄乱了我所有的包。我只为气流重新创建了环境，一切都很好。祝你今天过得愉快！ ;)
奇怪的是，即使是最新的 Airflow（撰写本文时为 2.0）仍然使用相当 old version 的 Pendulum（2018-03-21 的 1.4.4）。
不，气流 2.0 使用钟摆 2。我不认为它是固定的，但除非您将其固定到 1.x，否则您应该得到 2。如果您固定到 1.x，我不会认为气流会起作用。

【解决方案2】：

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

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

【讨论】：