如何使用python将airflow错误日志写入s3存储桶

import logging
import boto3
from botocore.exceptions import NoCredentialsError

AWS_ACCESS_KEY_ID = 'your_access_key_id'
AWS_SECRET_ACCESS_KEY = 'your_secret_access_key'

def write_error_logs_to_s3(bucket_name, log_file_path):
    try:
        session = boto3.Session(aws_access_key_id=AWS_ACCESS_KEY_ID, aws_secret_access_key=AWS_SECRET_ACCESS_KEY)
        s3 = session.resource('s3')
        bucket = s3.Bucket(bucket_name)
        bucket.upload_file(log_file_path, 'airflow_error.log')
        logging.info("Airflow错误日志已成功写入S3存储桶。")
    except FileNotFoundError:
        logging.error("未找到Airflow错误日志文件。")
    except NoCredentialsError:
        logging.error("AWS凭证未配置或无效。")

bucket_name = 'your_bucket_name'
log_file_path = 'path_to_airflow_error_log_file'
write_error_logs_to_s3(bucket_name, log_file_path)