有没有办法通过SimpleHttpOperator在Airflow中通过REST上传文件？

from airflow import DAG
from airflow.operators.http_operator import SimpleHttpOperator
from datetime import datetime

def upload_file():
    url = "http://example.com/upload"  # 替换为实际的上传URL
    file_path = "/path/to/file.txt"  # 替换为实际的文件路径
    
    files = {'file': open(file_path, 'rb')}
    response = requests.post(url, files=files)
    
    if response.status_code == 200:
        print("文件上传成功！")
    else:
        print("文件上传失败！")

dag = DAG('upload_file_dag', description='Upload file DAG', schedule_interval=None, start_date=datetime(2022, 1, 1))

upload_task = SimpleHttpOperator(
    task_id='upload_file_task',
    http_conn_id='http_default',
    endpoint='upload',  # 替换为实际的上传接口
    method='POST',
    python_callable=upload_file,
    dag=dag
)

upload_task