Я использовал аргумент files = ["abc.txt"]. Я получил информацию из документации по воздушному потоку ... https://airflow.readthedocs.io/en/stable/_modules/airflow/operators/email_operator.html
Но я получаю сообщение об ошибке, что файл не найден. У меня вопрос, откуда этот воздушный поток заберет мой файл. Это из GCS Bucket или папки DAG в среде композитора?
Куда мне нужно загрузить файл и каков правильный синтаксис аргумента "файлы"?
Заранее спасибо.
Файлы берутся из локальной файловой системы, и аргумент files действительно представляет собой список строк как files =["abc.txt"].
Чтобы загрузить файлы в композитор, вы можете использовать данные в папке GCS среды Composer Environment, затем вы можете получить доступ к этим данным из /home/airflow/gcs/data/
Пример взят из документации с добавленным свойством files является:
from airflow.operators import email_operator
# Send email confirmation
email_summary = email_operator.EmailOperator(
task_id='email_summary',
to=models.Variable.get('email'),
subject='Sample Email',
html_content="HTML content",
files=['/home/airflow/gcs/data/abc.txt'])
Вы также можете загрузить файл в локальную систему, а затем отправить его; однако вам необходимо убедиться, что загруженный файл и операторы электронной почты выполняются одним и тем же исполнителем.
