Size: a a a

2021 April 22

A

Alex in Airflow
[email]
subject_template =
html_content_template =
источник

SC

Stanislav Chernov in Airflow
Нашел то что нужно, спасибо всем
источник

A

Alex in Airflow
это не шаблон письма)
источник

IS

Ivan Suroegin in Airflow
Скорее всего имелось ввиду поменять часть url в шаблоне письма с localhost на домен или ip адрес
источник

SC

Stanislav Chernov in Airflow
Судя по описанию base_url . как раз таки он в дефолт шаблон сделает подстановку из этого параметра
источник

SC

Stanislav Chernov in Airflow
Пока этого будет достаточно
источник

D

Dnz in Airflow
парни. что скажете про суперсет ?
источник

A

Alex in Airflow
надо брать)
источник

S

Shadle in Airflow
Привет, подскажите, пожалуйста, как на AirFlow при помощи каких операторов можно реализовать такой ETL процесс
Есть 2 базы данных
при появлении новых строк в таблице базы А сделать ETL в базу Б
и чтобы постоянно пендинговал это событие
источник

S

Shadle in Airflow
базы находятся на разных серверах
Из MSSQL в Postgresql
источник

S

Shadle in Airflow
Если есть мануал где-то, чтобы реализовать подобное премного буду благодарен
источник

OI

Oleg Ilinsky in Airflow
SQLSensor
но это не совсем триггер события. Это нужно раз в какой-то интервал или прям произвольно приходят строки и нужно чота грузить?
источник

S

Shadle in Airflow
строки приходят произвольно, по мере появления клиента в бд
источник

S

Shadle in Airflow
новый клиент появился, делаю ETL в postgres
источник

OI

Oleg Ilinsky in Airflow
Тогда это не про эирфлоу, к сожалению. У него нет триггера по событиям. Он может только запускать по расписанию и проверять условие.
источник

S

Shadle in Airflow
спасибо за ответ, возможно стоит просто делать тогда при помощи timedelta, что не очень хотелось
источник

yk

y k in Airflow
Это больше задачка на kafka connect, kafka синхронизация баз в риал тайме
источник

OI

Oleg Ilinsky in Airflow
+
и какой-нибудь спарк стриминг, если надо данные обрабатывать в процессе.
источник

OI

Oleg Ilinsky in Airflow
а в кафку какой-нибудь debezium может слать
источник

S

Shadle in Airflow
kafka+spark?
или можно только spark?
источник