Більше про @tasks

Щоб продовжити реалізацію вашого робочого процесу, додайте ще один крок для розбору та збереження змін у завантаженому файлі. Dag process_sales уже визначено, і до нього додано задачу pull_file. У цьому випадку для вас уже визначено Python-функцію parse_file(inputfile, outputfile).

Зверніть увагу: під час реалізації задач в Airflow ви не завжди розумітимете окремі кроки, які вам надають. Головне — розуміти, як обгорнути ці кроки у структуру Airflow. Тоді ви зможете реалізувати потрібний робочий процес.

Створіть задачу Airflow за допомогою методу parse_file.
Викличте цю задачу з потрібними аргументами.

道练习

Більше про @tasks

说明

.css-6su6fj{-webkit-flex-shrink:0;-ms-flex-negative:0;flex-shrink:0;}道练习

说明

道练习