如何使用webhdfs rest api复制文件并将其存储在另一个目录中？

import requests

def copy_file_with_webhdfs(source_file, destination_file, namenode, port):
    url = f"http://{namenode}:{port}/webhdfs/v1{source_file}?op=RENAME&destination={destination_file}"
    response = requests.put(url)
    
    if response.status_code == 200:
        print("文件复制成功！")
    else:
        print("文件复制失败！")

# 示例用法
source_file = "/user/hadoop/source.txt"
destination_file = "/user/hadoop/destination.txt"
namenode = "namenode.example.com"
port = 50070

copy_file_with_webhdfs(source_file, destination_file, namenode, port)