使用python多处理将csv转换为json

import csv
import json
import multiprocessing

def csv_to_json(csv_file, json_file):
    with open(csv_file, 'r') as file:
        reader = csv.DictReader(file)
        rows = list(reader)
    
    with open(json_file, 'w') as file:
        json.dump(rows, file, indent=4)

def process_csv(csv_files):
    processes = []
    
    for csv_file in csv_files:
        json_file = csv_file.replace('.csv', '.json')
        process = multiprocessing.Process(target=csv_to_json, args=(csv_file, json_file))
        processes.append(process)
        process.start()
    
    for process in processes:
        process.join()

if __name__ == '__main__':
    csv_files = ['file1.csv', 'file2.csv', 'file3.csv']  # 替换为实际的CSV文件列表
    process_csv(csv_files)