Send to many — 한 곳에서 여러 곳으로 배포

# pip install requests
import os, time, requests

BASE = os.getenv("INNORIX_BASE_URL", "https://app.innorix.com")
HEADERS = {"x-api-key": os.environ["INNORIX_API_KEY"], "Content-Type": "application/json"}
# Every setting comes from an environment variable (second argument is the default).
TZ           = os.getenv("SCHEDULE_TZ", "Asia/Seoul")
SOURCE_ID    = os.environ["SOURCE_ID"]
SOURCE_PATH  = os.getenv("SOURCE_PATH", "D:/release/current")
TARGET_IDS   = [x.strip() for x in os.getenv("TARGET_IDS", "branch-01,branch-02,branch-03").split(",") if x.strip()]
TARGET_PATHS = [x.strip() for x in os.getenv("TARGET_PATHS", "C:/deploy").split(",") if x.strip()]
# TARGET_PATHS: 1 entry = same for every device, N = one per TARGET_IDS entry

def now_iso():
    return time.strftime("%Y-%m-%dT%H:%M:%S.000Z", time.gmtime())

def call(method, path, body=None, params=None):
    r = requests.request(method, BASE + path, headers=HEADERS,
                         json=body, params=params, timeout=30)
    if not r.ok:
        raise RuntimeError(f"API {r.status_code}: {r.text[:500]}")
    return (r.json() or {}).get("data")

def expand(paths, count):
    """1 path = same for every device, N paths = one per device."""
    if len(paths) == 1:
        return paths * count
    if len(paths) == count:
        return paths
    raise ValueError(f"TARGET_PATHS must have 1 entry or exactly {count}")

options = {"noSchedule": False, "target-action": "overwrite"}
paths = expand(TARGET_PATHS, len(TARGET_IDS))

details = [{
    "senderId": SOURCE_ID,
    "receiverId": target_id,
    "sourceItem": [{"filePath": SOURCE_PATH, "isDir": True}],
    "targetPath": paths[i],
    "step": 1,
    "transferOptions": options,
} for i, target_id in enumerate(TARGET_IDS)]

body = {
    "name": "branch-deploy",
    "flowName": "branch-deploy",
    "transferType": "normal",
    "timezone": TZ,
    "details": details,
    "schedules": [{"type": "none", "startDateType": "now",
                   "startDate": now_iso(), "timezone": TZ}],
    "step": 1,
    "isUpcoming": False,
}

automation_id = call("POST", "/api/automations", body)["automationId"]
print(f"automation created: {automation_id}  ({len(details)} targets)")

SKIP_ROW_TYPES = {"automation", "history", "flow"}
TERMINAL = {2, 4, 5, 9, 99}
STATUS = {-1: "queued", 0: "waiting", 1: "started", 2: "complete", 3: "paused",
          4: "error", 5: "cancelled", 6: "transferring", 7: "skipped", 8: "retry",
          9: "partial-complete", 11: "virus-scanning", 12: "syncing", 99: "fail"}

def monitor_ids(automation_id, expected, appear_wait=120):
    """Polls the list until the transfers start, collecting their monitorIds."""
    seen, deadline = [], time.time() + appear_wait
    while True:
        result = call("GET", "/api/transfers", params={"automationId": automation_id})
        records = result.get("data") if isinstance(result, dict) else result
        for r in records or []:
            if r.get("type") in SKIP_ROW_TYPES:
                continue
            mid = r.get("monitorId") or r.get("id")
            if mid and mid not in seen:
                seen.append(mid)
        if len(seen) >= expected or time.time() >= deadline:
            return seen
        time.sleep(3)

failed = 0
for mid in monitor_ids(automation_id, len(details)):
    while True:
        detail = call("GET", f"/api/transfers/{mid}") or {}
        status = detail.get("status")
        if detail.get("isTerminal", status in TERMINAL):
            print(f"  {mid}: {STATUS.get(status, status)} ({detail.get('fileCount', 0)} files)")
            if status != 2:
                failed += 1
            break
        time.sleep(3)

print("failed targets:", failed)