此问题通常是由于缺少指向统计数据存储的数据库连接而引起的。要解决此问题,您可以按照以下步骤执行:
Step 1:登录 Airflow Web UI,进入 Admin > Connections 页面。
Step 2:点击右上角的“Create”按钮,创建一个指向您存储用户统计数据的数据库连接。
以下是一个连接 MySQL 数据库的示例代码:
conn_id = 'my_mysql_conn' conn_type = 'mysql' host = 'localhost' # MySQL 主机名 schema = 'airflow' # 数据库名称 user = 'myusername' # 用户名 password = 'mypassword' # 密码
from airflow.models import Connection from airflow.utils.db import create_session
conn = Connection(conn_id=conn_id, conn_type=conn_type, host=host, schema=schema, login=user, password=password)
session = create_session() session.add(conn) session.commit()
Step 3:重新加载用户统计信息页面,此时应该可以看到用户统计数据了。
如果您的数据存储不是 MySQL,可以在 Connection 创建代码中更改适当的参数。