IPFS分享文件简易教程

import os
import json
import subprocess
import time

# ---------------- 配置 ----------------
API_KEY = "ZXRoLTB4N2I3NTM3NmEyMjBmMGU1OWIzZWM4ZWY3ZmJlMjgwYjBiY2ZiNThjMzoweGY4NDM1MDc1YjRhNTM0MTNmMDAwYTA1NGYwNzkzZTBkNjhkODMzZTU5YjlhZWIxOTQ2MjE5YzVkZmU1ZDA1NjQwOGRmOTI4ZjFjMjk1ODZkNmFkODRhMGFhZWFlMzJkOTU3YzcxNGUyYWE0OTg4MzAwMDRkOWYzM2RlN2NhMmY0MWM="
RPC_URL = "https://gw.crustfiles.net/api/v0/add?pin=true&cid-version=1&raw-leaves=true"
UPLOAD_DIR = r"D:\新建文件夹"      # 要上传的目录
RESULT_JSON = "upload_​results.json"
MAX_RETRIES = 3           # 每个文件失败重试次数
RETRY_DELAY = 10          # 失败后延迟（秒）
# -------------------------------------


def upload_file(file_path):
    """用 curl 上传单个文件，成功返回 CID，失败返回 None"""
    for attempt in range(1, MAX_RETRIES + 1):
        print(f"[尝试 {attempt}] 上传: {file_path}")

        cmd = [
            "curl", "-s", "-X", "POST",
            "-H", f"Authorization: Basic {API_KEY}",
            "-F", f"file=@{file_path}",
            RPC_URL
        ]

        result = subprocess.run(cmd, capture_output=True)
        stdout = result.stdout.decode("utf-8", errors="ignore").strip()
        stderr = result.stderr.decode("utf-8", errors="ignore").strip()

        if result.returncode != 0:
            print(f"  ❌ curl 错误: {stderr}")
            time.sleep(RETRY_DELAY)
            continue

        try:
            data = json.loads(stdout)
            cid = data.get("Hash")
            if cid:
                print(f"  ✅ 成功: CID={cid}")
                return cid
            else:
                print(f"  ❌ 返回无 Hash: {stdout}")
        except Exception as e:
            print(f"  ❌ JSON 解析失败: {e} -> {stdout}")

        time.sleep(RETRY_DELAY)

    return None


def find_all_files(directory):
    """递归扫描目录下所有文件"""
    files = []
    for root, _, filenames in os.walk(directory):
        for name in filenames:
            files.append(os.path.join(root, name))
    return files


def main():
    file_list = find_all_files(UPLOAD_DIR)
    print(f"发现 {len(file_list)} 个文件，开始上传...")

    filenames = []
    cids = []

    for file_path in file_list:
        filenames.append(os.path.basename(file_path))  # 只保存文件名
        if not os.path.exists(file_path):
            print(f"⚠️ 文件不存在: {file_path}")
            cids.append(None)
            continue

        cid = upload_file(file_path)
        cids.append(cid)

    # 保存为两个数组的 JSON
    output = {
        "files": filenames,
        "cids": cids
    }

    with open(RESULT_JSON, "w", encoding="utf-8") as f:
        json.dump(output, f, ensure_ascii=False, indent=2)

    print(f"\n✅ 全部完成，结果已保存到 {RESULT_JSON}")


if __name__ == "__main__":
    main()