webhooks - 气流连接密码在 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 时,连接确实有效。
解决方案
通过粘贴到额外字段和密码字段来解决。
不是最好的解决方案,但气流仍然没有显示任何类型的密码。
推荐阅读
- python - 如何在 Python 中更改 Plotly scatter mapbox 中的颜色条?
- php - 如何通过在laravel中加入四个表来更新列
- docker - 我在 docker ps output 0.0.0.0:5432->5432/tcp,:::5432->5432/tcp 看到的端口映射有什么区别
- reactjs - 如何在反应中为道具分配随机值?
- react-admin - 将参数传递给 react-admin dataProvider getList
- clojure - 为什么 Clojure 的补码函数定义为多元函数?
- embedded - 使用 ECC 在 NAND 闪存的同一页上进行多次写入访问
- javascript - 如何按索引覆盖对象属性值?
- swift - 无法转换“Publishers.FlatMap”类型的返回表达式
, AnyPublisher<>>' 返回类型 'AnyPublisher<>' - sql - SQL 查询从日期中选择特定记录