特定の EmailOperator タスクによって送信される電子メールの内容を動的に設定できるようにする方法を探しています。理想的には、できれば html_content 引数を使用して、xcom 呼び出しの結果に依存する電子メールのコンテンツを作成したいと考えています。
alert = EmailOperator(
task_id=alertTaskID,
to='please@dontreply.com',
subject='Airflow processing report',
html_content='raw content #2',
dag=dag
)
気流のドキュメントには、xcom 呼び出しをテンプレートに埋め込むことができると書かれていることに気付きました。おそらく、指定されたタスク ID のテンプレートを使用して xcom プルを作成し、結果を html_content として渡す方法はありますか? ありがとう