在SSH到远程计算机/边缘节点后，如何将文件从S3存储台下载到同一远程计算机中的特定路径？

Question

我对气流是相对较新的，并且正在尝试解决一个特定的问题。 我想知道如何通过SSHOPERATOR下载SSH之后的SSS居住在S3存储桶中的文件。 我可以简单地使用一些BASH脚本（我已经使用S3 URL尝试过，但它不起作用）？还是气流中有任何操作员可以作为我的DAG的一部分执行此操作？我尝试了PythOnoperator，但是它似乎仅在指定本地文件路径（在OP_KWARGS字典中）时才能起作用。 以下是我的样品气流代码；任何帮助将不胜感激。

# command to execute on remote
download_file_cmd = 'rm -rf airflow_pipeline && mkdir -p airflow_pipeline && cd airflow_pipeline'

download_to_edge_node = SSHOperator(
    task_id='download_file_to_edge_node',
    ssh_conn_id='itversity',
    command=download_file_cmd,
    dag=dag
)

task_download_from_s3 = PythonOperator(
    task_id='download_file_from_s3',
    python_callable=download_from_s3,
    op_kwargs={
        'key': 'orders.csv',
        'bucket_name': 'airflow-pipeline-files',
        'local_path': '/home/danish/test'
    }
)