Пароли подключения к воздушному потоку не отображаются в пользовательском интерфейсе и не подключаются к Slack при сохранении подключения

Итак, я пытаюсь создать связь между воздушным потоком и слабиной, используя SlackWebhookOperator.

Во-первых, в пользовательском интерфейсе воздушного потока пароли, которые я пытаюсь сохранить, на самом деле не сохраняются. Вместо того, чтобы получить ********** в поле PW, я вообще ничего не вижу. Это первый раз, когда я вижу это, и все соединения, которые я установил ранее, сохраняют пароль.

Когда я передаю слабый веб-хук непосредственно на хост, моя интеграция запускается, поэтому я знаю, что он достигает.

Честно говоря, я такой новичок и не могу найти много документации, но меня беспокоит, что моя среда ведет себя странно. Я пытался создать несколько соединений, и все они действовали таким образом.

Мой код дага при попытке вызвать слабое соединение:

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)

Как я уже упоминал, соединение работает, когда я передаю полный слабый URL-адрес веб-перехватчика.

Уберите test_send_slack_message.execute(context = None). Airflow вызывает оператора, когда планировщик подхватывает его. То, что вы написали, - это явно запустить оператор до того, как он будет готов.

Elad Kalif 12.12.2020 13:36

Cпасибо за совет по этому поводу. Любые идеи, почему он не подбирает мой пароль?

Tristan 12.12.2020 13:48

какая у тебя версия воздушного потока? попробуйте снова добавить/отредактировать соединение. Если это ошибка, вам нужно сообщить об этом github.com/apache/airflow/issues с инструкциями по воспроизведению.

Elad Kalif 12.12.2020 13:51
Стоит ли изучать PHP в 2023-2024 годах?
Стоит ли изучать PHP в 2023-2024 годах?
Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.
Приемы CSS-макетирования - floats и Flexbox
Приемы CSS-макетирования - floats и Flexbox
Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...
Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest
В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...
Концепция локализации и ее применение в приложениях React ⚡️
Концепция локализации и ее применение в приложениях React ⚡️
Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
1
3
1 445
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Решено путем вставки в дополнительное поле и поле пароля.

Не лучшее решение, но воздушный поток по-прежнему не показывает какой-либо пароль.

Пароли не отображаются в журналах из соображений безопасности. Все поля пароля в подключениях скрыты.

Vikrant 14.12.2020 07:50

Да, я знаю, что сам текст будет скрыт, но исторически сложилось, что воздушный поток показывал, что по крайней мере был ввод текста. В этом примере значение пароля полностью исчезает. Я также получаю ошибку json, что может указывать на проблему с хранением паролей.

Tristan 14.12.2020 09:26

Другие вопросы по теме

Slack : Метод веб-API Slack: разговоры. метод истории не работает должным образом при использовании последних и самых старых параметров
Я создаю Slackbot на Python и хочу повторять сообщение, пока к этому сообщению не будет добавлена ​​реакция. Что я делаю не так?
Как отключить логирование в импортированных библиотеках?
«Ошибка — unhandledRejection: Ошибка: слушайте EADDRINUSE: адрес уже используется ::: 3000», когда я использую Slack Bolt для JavaScript с ngrok и Next.js
Нужна функция для преобразования Slack Markdown в HTML
Как применить «шестнадцатеричный дайджест» к хэш-значению HMAC SHA256 в политике управления API Azure?
Поля рабочих столов Nexudus Coworker имеют пустое значение массива для пользователей, у которых есть свои рабочие столы
Как упомянуть пользователя в слабом сообщении через слабый API Python
Slack-бот отвечает на ключевые слова в канале
В ответе API есть файл, не удается извлечь содержимое файла