AC
С виду как будто-бы то, что нужно. Опробую, спасибо.
Size: a a a
2021 June 01
AK
Тогда при чем тут чат по airflow?)
AS
По простому тогда : мне нужно написать даг который постит твиты , я не знаю как , вот и решил спросить , может есть совет какой-то может кто уже сталкивался с этим
AC
А в чем вопрос?
Делаешь класс который генерит/получает твит - первая таска
Постишь твит - вторая таска
Самый простой вариант
Делаешь класс который генерит/получает твит - первая таска
Постишь твит - вторая таска
Самый простой вариант
AS
Как я знаю , если хочет отправить письмо например по электронке , то в эйрфлоу есть специальный конфиг , где ты настраиваешь почтовый клиент и используешь его для отправки писем , но с твитером должно как все иначе или как вообще ? Я прошу прощения за такое количество глупый вопросов , просто я новичок с этом всем (
ММ
интеграция с email стандартная для шедулеров, с твиттером - нет. придется написать самому
ММ
особо много там делать не придется - найти какой-нибудь python клиент, потыкать в него, написать функцию для его вызова и обернуть в PythonOperator, который добавить одним из шагов в даге
ММ
ну и когда выполнение дойдет до этого шага получишь свой твит
AS
Ладно , буду разбираться дальше
Спасибо за помощь
Спасибо за помощь
2021 June 02
VN
PA
сделать функцию и запихнуть ее в параметр дага коллбэк он фэилюр
VN
не совсем понимаю как передать контекст в функцию, чтобы в ней дернуть
context.get('exception')
context.get('exception')
PA
'on_failure_callback': message_on_fail,
PA
def message_on_fail(context):
PA
dag = context.get('task_instance').dag_id
task_id = context.get('task_instance').task_id
status = context.get('task_instance').state
date_time = context["execution_date"].strftime("%Y-%m-%d %H:%m")
log_url = context.get('task_instance').log_url🌌[
Напомните пожалуйста, а можно названия дагов на русском шпрехать :?
ММ
можно не надо
🌌[
А с разделителем
|AK
зачем сей изврат?)