如何在Pyspark中创建虚拟(0字节) HDFS文件

from pyspark import SparkContext, SparkConf
from hdfs import InsecureClient

conf = SparkConf().setAppName("HDFS Example")
sc = SparkContext(conf=conf)

hdfs_host = 'your_hdfs_host'
hdfs_port = your_hdfs_port
hdfs_user = 'your_hdfs_user'
client = InsecureClient(f"http://{hdfs_host}:{hdfs_port}", user=hdfs_user)

file_path = '/path/to/your/file'  # 虚拟文件路径
client.write(file_path, b'')  # 写入空字节串

file_status = client.status(file_path)
if file_status['length'] == 0:
    print("虚拟文件创建成功！")
else:
    print("虚拟文件创建失败！")