为什么 Airflow Scheduler 只能作为非守护进程工作而作为守护进程失败？

Question

我已经在 Ubuntu 服务器上设置了气流。我作为守护进程启动了网络服务器。我可以使用启动调度程序

airflow scheduler

它工作正常并且dags运行。然后我停止它并删除 $AIRFLOW_HOME 中的所有气流调度程序文件（airflow-scheduler.err、airflow-scheduler.log、airflow-scheduler.out）

然后我尝试使用它作为守护进程启动它

airflow scheduler -D

它似乎可以正常启动而没有错误。但是，当我到达网络服务器时，它说：

“调度程序似乎没有运行。最后一次心跳是在 2 分钟前收到的。

DAG 列表可能不会更新，也不会安排新任务。”

当我查看airflow-scheduler.err 时，我看到：

Traceback (most recent call last):

  File "/home/emauser/.local/lib/python3.6/site-packages/sqlalchemy/pool/base.py", line 503, in <lambda>

  File "/home/emauser/.local/lib/python3.6/site-packages/sqlalchemy/pool/base.py", line 702, in _finalize_fairy

  File "/usr/lib/python3.6/logging/__init__.py", line 1337, in error

  File "/usr/lib/python3.6/logging/__init__.py", line 1444, in _log

  File "/usr/lib/python3.6/logging/__init__.py", line 1454, in handle

  File "/usr/lib/python3.6/logging/__init__.py", line 1516, in callHandlers

  File "/usr/lib/python3.6/logging/__init__.py", line 865, in handle

  File "/usr/lib/python3.6/logging/__init__.py", line 1071, in emit

  File "/usr/lib/python3.6/logging/__init__.py", line 1061, in _open

NameError: name 'open' is not defined

知道为什么我在日志模块的内置打开功能上出现错误吗？

Answer 1

在以守护程序模式重新启动调度程序之前，请确保没有其他调度程序进程正在运行。&nbsp;ps aux | grep airflow-scheduler如果有，杀死它们，然后将您的调度程序作为守护进程启动。