Imap 附件至 Amazon S3¶
ImapAttachmentToS3Operator
Operator 通过 IMAP 协议将电子邮件附件从邮件服务器传输到 Amazon S3 Bucket。
前置任务¶
要使用这些 Operator,您必须做几件事
通过 pip 安装 API 库。
pip install 'apache-airflow[amazon]'详细信息请参阅 安装 Airflow®
设置连接.
Operator¶
Imap 附件至 Amazon S3 传输 Operator¶
要通过 IMAP 协议将电子邮件附件从邮件服务器保存到 Amazon S3 Bucket,您可以使用 ImapAttachmentToS3Operator
tests/system/amazon/aws/example_imap_attachment_to_s3.py
task_transfer_imap_attachment_to_s3 = ImapAttachmentToS3Operator(
task_id="transfer_imap_attachment_to_s3",
imap_attachment_name=imap_attachment_name,
s3_bucket=s3_bucket,
s3_key=s3_key,
imap_mail_folder=imap_mail_folder,
imap_mail_filter="All",
)