要使用Airflow和AWS SES发送电子邮件,你可以按照以下步骤进行操作:
首先,确保你已经安装了Airflow和AWS SDK(boto3)。
创建一个Airflow DAG文件,包含以下代码示例:
from airflow import DAG
from airflow.operators.email_operator import EmailOperator
from datetime import datetime
default_args = {
'owner': 'airflow',
'start_date': datetime(2022, 1, 1)
}
dag = DAG(
'send_email_with_ses',
default_args=default_args,
schedule_interval='@daily'
)
email_task = EmailOperator(
task_id='send_email',
to='recipient@example.com',
subject='Airflow - AWS SES Example',
html_content='Hello from Airflow!
',
dag=dag
)
~/.aws/credentials
文件中添加AWS访问密钥:[default]
aws_access_key_id = YOUR_ACCESS_KEY
aws_secret_access_key = YOUR_SECRET_KEY
或者,你可以通过设置以下环境变量来配置AWS访问密钥:
export AWS_ACCESS_KEY_ID=YOUR_ACCESS_KEY
export AWS_SECRET_ACCESS_KEY=YOUR_SECRET_KEY
airflow scheduler
当DAG被触发时,Airflow将使用AWS SES发送电子邮件给指定的收件人。
请注意,上述示例假设你已经正确配置了Airflow和AWS SES。你需要根据自己的配置进行调整。