标签: airflow-webserver

如何修复 Airflow DAG 日志中的“无法从工作程序获取日志文件。不支持的 URL 协议”错误?

我正在通过此图像通过 docker 运行 Airflowapache/airflow:2.1.0 请参阅此线程以了解我遇到的初始错误。

目前我可以运行我以前现有的 DAG。但是,当我添加较新的 DAGS 时,我在日志文件中收到以下错误。我很确定这不是内存或计算的问题。

*** Log file does not exist: /opt/airflow/logs/my-task/my-task/2021-06-15T14:11:33.254428+00:00/1.log
*** Fetching from: http://:8793/log/my-task/my-task/2021-06-15T14:11:33.254428+00:00/1.log
*** Failed to fetch log file from worker. Unsupported URL protocol ''
Run Code Online (Sandbox Code Playgroud)

我已经尝试过的事情:

  • 重新启动我的容器
  • docker prune然后建造
  • 从前端删除 DAG

airflow airflow-scheduler airflow-webserver

10
推荐指数
2
解决办法
2万
查看次数

指向外部 postgres 后 120 秒内,gunicorn master 没有响应

我正在使用 Docker 部署最新版本的 Airflow,一切正常,直到我将数据库指向外部 Postgres 数据库。一旦数据库指向外部数据库,Web 服务器容器就不会启动。

该版本来自 apache/airflow:latest

日志内容如下

120秒内gunicorn master没有回复

在此输入图像描述

我在这里缺少什么?

postgresql gunicorn docker airflow airflow-webserver

8
推荐指数
0
解决办法
2484
查看次数

Airflow Web 服务器没有名为“airflow.www.fab_security”的模块

我在 Ubuntu 上运行 Airflow 1.10.12。使用本地执行器和 MySql,Airflow 运行良好。为了进行一些测试,我已经使用 RabbitMQ 迁移到 Celery 执行器。基于教程,这是我的配置文件:

[core]
executor = CeleryExecutor
[celery]
broker_url = pyamqp://rabbitmq:rabbitmq@localhost/
result_backend = db+mysql+pymysql://airflow:airflow@localhost:3306/airflow_db
Run Code Online (Sandbox Code Playgroud)

但是当我跑步时:

airflow webserver
Run Code Online (Sandbox Code Playgroud)

抛出以下错误:

Traceback (most recent call last):
  File "/usr/local/bin/airflow", line 37, in <module>
    args.func(args)
  File "/usr/local/lib/python3.8/dist-packages/airflow/utils/cli.py", line 76, in wrapper
    return f(*args, **kwargs)
  File "/usr/local/lib/python3.8/dist-packages/airflow/bin/cli.py", line 1076, in webserver
    app = cached_app_rbac(None) if settings.RBAC else cached_app(None)
  File "/usr/local/lib/python3.8/dist-packages/airflow/www_rbac/app.py", line 300, in cached_app
    app, _ = create_app(config, session, testing)
  File "/usr/local/lib/python3.8/dist-packages/airflow/www_rbac/app.py", line 65, in create_app
    app.config.from_pyfile(settings.WEBSERVER_CONFIG, silent=True) …
Run Code Online (Sandbox Code Playgroud)

celery airflow airflow-webserver

7
推荐指数
0
解决办法
1927
查看次数

如何重置本地气流网络服务器用户的密码

我忘记了本地气流网络服务器密码,可以重置吗?

我尝试创建一个新用户,但它说我的帐户已存在,所以我想重置密码。

airflow airflow-webserver

4
推荐指数
2
解决办法
1万
查看次数