我有一个与 Airflow v1.10.3 相关的问题。我们最近将气流从 v1.9 升级到 v1.10.3。通过新的升级,我们遇到了这样一种情况,即任何来自 UI 的 Celery 执行命令都没有在消息代理和 celery 工作者中排队/执行。
基于芹菜常见问题解答:https ://docs.celeryproject.org/en/latest/faq.html#why-is-task-delay-apply-the-worker-just-hanging ,它指向身份验证问题,用户没有访问。
我们在 v1.9 版本中使用以下配置进行了 Web 身份验证(Google Oauth):
[webserver]:
authenticate = True
auth_backend = airflow.contrib.auth.backends.google_auth
[google]:
client_id = <client id>
client_secret = <secret key>
oauth_callback_route = /oauth2callback
domain = <domain_name>.com
上述配置值是否仍然有效,或者我们是否需要设置 RBAC=True 并在 webserver_config.py 中提供 Google Oauth 凭据?
Webserver_config.py
from flask_appbuilder.security.manager import AUTH_OAUTH
AUTH_TYPE = AUTH_OAUTH
AUTH_USER_REGISTRATION = True
AUTH_USER_REGISTRATION_ROLE = "Admin"
OAUTH_PROVIDERS = [{
'name':'google',
'whitelist': ['@yourdomain.com'], # optional
'token_key':'access_token',
'icon':'fa-google',
'remote_app': {
'base_url':'https://www.googleapis.com/oauth2/v2/',
'request_token_params':{
'scope': 'email profile'
},
'access_token_url':'https://oauth2.googleapis.com/token',
'authorize_url':'https://accounts.google.com/o/oauth2/auth',
'request_token_url': None,
'consumer_key': '<your_client_id>',
'consumer_secret': '<your_client_secret>',
}
}]
很感谢任何形式的帮助。谢谢。