如何将zip文件的内容分配给Spark中的每个任务？

from zipfile import ZipFile
from pyspark import SparkContext

# 创建SparkContext
sc = SparkContext("local", "ZipFileExample")

# 加载zip文件为一个RDD
zip_rdd = sc.binaryFiles("path/to/zipfile.zip")

# 解压缩每个zip文件的内容并分配给每个任务
def process_zipfile(file_path, file_content):
    with ZipFile(file_path, 'r') as zip:
        # 解压缩文件内容
        extracted_files = []
        for file_name in zip.namelist():
            extracted_files.append((file_name, zip.read(file_name)))
        return extracted_files

result_rdd = zip_rdd.flatMap(lambda x: process_zipfile(x[0], x[1]))

# 打印结果
result_rdd.foreach(print)

# 停止SparkContext
sc.stop()