airflow - 如何在 Airflow 中的电子邮件运算符(operator)上附加文件

Question

每当我将文件参数添加到 email_task我运行失败。

email_task = EmailOperator(    
           task_id='email_sample_data',    
           to='sample@sample.com',    
           subject='Forecast for the day',    
           html_content= "Sample",
           files=['/home/airflow/sample.html'],    
           dag=dag)

我收到一个错误，提示找不到文件。 Airflow 在哪里选择我的文件，我需要在哪里上传文件，"file"参数的正确语法是什么？

Answer 1

Airflow 期望路径与 DAG 文件的存储位置相关。
但是，由于文件是模板化字段，您可以使用 template_search_path提供 Airflow 将查看的其他路径:

with DAG(
        ...
        template_searchpath = ['/home/airflow/'],
        ) as dag:
    email_task = EmailOperator(
        task_id='email_sample_data',
        to='sample@sample.com',
        subject='Forecast for the day',
        html_content="Sample",
        files=['/home/airflow/sample.html']
    )