首页 > 解决方案 > 气流连接密码在 UI 中不可见,并且在保存连接时未连接到 slack

问题描述

因此,我正在尝试使用 SlackWebhookOperator 在气流和松弛之间创建连接。

首先,在气流用户界面中,我尝试存储的密码实际上并没有保存。而不是在 PW 领域获得 **********,我什么也没看到。这是我第一次看到这个,我之前设置的所有连接都存储了密码。

当我将 slack webhook 直接传递给主机时,我的集成运行,所以我知道它正在到达。

老实说,我是个新手,似乎找不到太多文档,但我担心我的环境表现得很奇怪。我尝试过创建多个连接,并且它们都以这种方式行事。

尝试调用松弛连接时我的 dag 代码:

import datetime
from airflow import models
from airflow.hooks.base_hook import BaseHook
from airflow.contrib.operators.slack_webhook_operator import SlackWebhookOperator   

default_dag_args = {
                    'start_date': datetime.datetime(2020, 12, 9),
                    'depends_on_past': False,  
                    'retries': 1,
                    'retry_delay': datetime.timedelta(minutes=5),
                    }
slack_connection = 'Test'
slack_webhook_token = BaseHook.get_connection(slack_connection).password

dag = models.DAG(
                'Test_Slack',
                schedule_interval= '@daily',
                default_args=default_dag_args,
                ) 
                
test_send_slack_message = SlackWebhookOperator(
        task_id = 'Slack_Test',
        http_conn_id = slack_connection,
        token = slack_webhook_token,
        message = 'Test',
        channel = '#channel',
        dag = dag
        
        )
test_send_slack_message.execute(context = None)

正如我所提到的,当我传入完整的 slack webhook url 时,连接确实有效。

标签: webhooksslack-apiairflow

解决方案


通过粘贴到额外字段和密码字段来解决。

不是最好的解决方案,但气流仍然没有显示任何类型的密码。


推荐阅读