0

我有一个与 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>',
    }
}]

很感谢任何形式的帮助。谢谢。

4

1 回答 1

0

根据我的经验,两者都可以。当然,当他们将基于 FAB 的 UI 称为“新 UI”时,旧的可能会被淘汰。

但是,您的问题听起来与用户身份验证无关,而是与芹菜访问有关。听起来气流和/或芹菜没有阅读celery_result_backend或其他重命名的选项之一,当他们应该。Celery config在他们的更新文档中搜索完整列表。

于 2019-11-04T17:16:03.323 回答