レコード作成・更新

# WebサイトやAPIと通信するためのライブラリ
import requests

# 画像をBase64化するためのライブラリ
import base64

# JSON操作のためのライブラリ
import json

# ファイル操作や正規表現のためのライブラリ
import mimetypes

# その他標準ライブラリ
import re

# データ構造操作のためのライブラリ
from collections import defaultdict

# ファイルパス操作のためのライブラリ
from pathlib import Path

# 接続先URL
BASE_URL = "【URL】"
# サイトID
SITE_ID = 【サイトID】
# APIキー
API_KEY = "【APIキー】"
# 対象フォルダ
TARGET_FOLDER = r"【パス】"

# キーコード抽出用正規表現
KEY_REGEX = re.compile(r"^(KC\d+)$")

# Upsert のキー項目
UPSERT_KEYS = ["ClassA"]

def extract_keycode(filename: str) -> str | None:
    # KC001_FILENAME.txt -> KC001 / ルール外は None
    if "_" not in filename:
        return None
    head = filename.split("_", 1)[0].strip()
    if not head:
        return None
    m = KEY_REGEX.match(head)
    return m.group(1) if m else None

def file_to_attachment_obj(path: Path) -> dict:
    # Pleasanter AttachmentsA の要素を作る
    ctype, _ = mimetypes.guess_type(path.name)
    if not ctype:
        ctype = "application/octet-stream"
    b64 = base64.b64encode(path.read_bytes()).decode("ascii")
    return {
        "ContentType": ctype,
        "Name": path.name,
        "Base64": b64,
    }

def upsert_attachments(
    session: requests.Session, keycode: str, attachments: list[dict]
) -> dict:
    url = f"{BASE_URL}/api/items/{SITE_ID}/upsert"
    payload = {
        "ApiVersion": 1.1,
        "ApiKey": API_KEY,
        "Keys": UPSERT_KEYS,
        "ClassHash": {
            "ClassA": keycode,
        },
        "AttachmentsHash": {"AttachmentsA": attachments},
    }

    r = session.post(url, data=json.dumps(payload))
    if not r.ok:
        raise RuntimeError(f"Upsert失敗 key={keycode} HTTP {r.status_code}\n{r.text}")
    return r.json()

def main():
    folder = Path(TARGET_FOLDER)
    if not folder.is_dir():
        raise SystemExit(f"フォルダが見つかりません: {folder}")

    # キーコードごとに添付をまとめる（同一KCに複数ファイルがある場合もまとめて登録）
    grouped: dict[str, list[Path]] = defaultdict(list)

    for p in folder.iterdir():
        if not p.is_file():
            continue

        keycode = extract_keycode(p.name)
        if not keycode:
            # ルール外は処理対象外
            continue

        grouped[keycode].append(p)

    if not grouped:
        print("処理対象ファイルなし（命名規則に一致するファイルがありません）")
        return

    session = requests.Session()
    session.headers.update({"Content-Type": "application/json"})

    for keycode, paths in grouped.items():
        attachments = [file_to_attachment_obj(p) for p in paths]
        try:
            res = upsert_attachments(session, keycode, attachments)
            # Upsertのレスポンスを表示
            print(f"OK: key={keycode} 添付={len(attachments)}件 / response={res}")
        except Exception as e:
            print(f"NG: key={keycode} 添付={len(paths)}件")
            print(e)

if __name__ == "__main__":
    main()

>python api_record_upsert_p1.py

OK: key=KC001 添付=2件 / response={'Id': 9999, 'StatusCode': 200, 'Message': '" KC001 " を更新しました。'}
OK: key=KC002 添付=1件 / response={'Id': 9999, 'StatusCode': 200, 'Message': '" KC002 " を更新しました。'}
OK: key=KC003 添付=1件 / response={'Id': 9999, 'StatusCode': 200, 'Message': '" KC003 " を更新しました。'}
・・・・