Windows 폴더의 파일을 Amazon S3로 자동 업로드하기

Windows Server
      │
      │ 파일 생성
      ▼
┌─────────────────┐
│ 지정된 폴더      │
│                 │
│ D:\Reports      │
└────────┬────────┘
         │
         │ 파일 감지
         ▼
┌─────────────────┐
│ 자동 업로드 Flow │
└────────┬────────┘
         │
         │ Upload
         ▼
┌─────────────────┐
│    Amazon S3    │
│                 │
│ reports/daily/  │
└─────────────────┘

↓

↓

↓

↓

↓

┌──────────────────────┐
│ 업무 시스템           │
│                      │
│ Daily Report 생성    │
└──────────┬───────────┘
           │
           ▼
┌──────────────────────┐
│ Windows Folder       │
│                      │
│ D:\Reports\Daily     │
└──────────┬───────────┘
           │
           │ File Created
           ▼
┌──────────────────────┐
│ Upload Flow          │
│                      │
│ 파일 조건 확인        │
└──────────┬───────────┘
           │
           ▼
┌──────────────────────┐
│ Amazon S3            │
│                      │
│ reports/daily/       │
└──────────────────────┘

D:\Data\Export

s3://company-data/export/

┌────────────────────────┐
│ Windows Source         │
│                        │
│ Server-01              │
│ D:\Data\Export         │
└────────────┬───────────┘
             │
             │ Transfer
             ▼
┌────────────────────────┐
│ Amazon S3 Target       │
│                        │
│ company-data           │
│ /export/               │
└────────────────────────┘

Windows Server
      │
      ├── D:\Reports ────────► S3 /reports/
      │
      ├── D:\Images ─────────► S3 /images/
      │
      └── D:\Backup ─────────► S3 /backup/

D:\Data
│
├── Daily
│   ├── report-01.csv  ───────► S3 /reports/
│   ├── report-02.csv  ───────► S3 /reports/
│   └── temporary.txt  ───────► 제외
│
└── Backup
    ├── backup-01.zip  ───────► S3 /backup/
    └── backup-02.zip  ───────► S3 /backup/

                 ┌──────────────────┐
                 │ Windows Folder   │
                 │                  │
                 │ D:\Data\Export   │
                 └────────┬─────────┘
                          │
                          │ File Event
                          ▼
                 ┌──────────────────┐
                 │ Condition        │
                 │                  │
                 │ *.csv            │
                 └────────┬─────────┘
                          │
                          │ Matched
                          ▼
                 ┌──────────────────┐
                 │ File Transfer    │
                 └────────┬─────────┘
                          │
                          ▼
                 ┌──────────────────┐
                 │ Amazon S3        │
                 │ /data/export/    │
                 └──────────────────┘

Windows Server A ──┐
                   │
Windows Server B ──┼──► Amazon S3
                   │
Windows Server C ──┘

Windows Folder
       │
       ▼
  File Condition
       │
   ┌───┴────┐
   │        │
 CSV       ZIP
   │        │
   ▼        ▼
S3 Data   S3 Backup

RUN-20260902-001
│
├── Source
│   └── Windows / D:\Data\Export
│
├── Files
│   ├── report-01.csv     Completed
│   ├── report-02.csv     Completed
│   └── report-03.csv     Processing
│
└── Target
    └── Amazon S3 /data/export/

Windows File
      │
      ▼
File Upload
      │
      ▼
Amazon S3
      │
      ├──────────────► Data Processing
      │
      ├──────────────► Notification
      │
      └──────────────► Monitoring

Run 확인
    ↓
View Details
    ↓
Windows Source 확인
    ↓
파일 경로 및 상태 확인
    ↓
Amazon S3 Target 확인
    ↓
접근 및 저장 위치 확인
    ↓
환경 조정
    ↓
Retry
    ↓
새로운 Run 생성
    ↓
S3 반영 확인
    ↓
Completed

def create_watch_upload(source, source_path, target, target_path,
                        action="overwrite", watch_type=1):
    body = {
        "name": "windows to s3 watch",
        "flowName": "windows to s3 watch",
        "transferType": "sync",
        "isUpcoming": False,
        "timezone": "Asia/Seoul",
        "details": [{
            "senderId": source,
            "receiverId": target,
            "sourceItem": [{
                "hash": encode_path(source, source_path),
                "filePath": str(source_path or "").replace("\\", "/"),
                "isDir": True,
            }],
            "targetPath": encode_path(target, target_path),
            "step": 1,
            "transferOptions": {
                "noSchedule": True,
                "target-action": action,
                "send-fileoption": {},
                "syncType": 1,                  # one-way sync
                "watchFolderType": watch_type,  # 1 = on create, 2 = on modify
            },
        }],
        "schedules": [{
            "type": "none", "startDateType": "now",
            "startDate": now_iso(), "timezone": "Asia/Seoul",
        }],
        "step": 1,
    }

    return api("POST", "/api/automations", body)["automationId"]


automation_id = create_watch_upload(
    "device-win-01", "C:/data/export",
    "device-s3", "my-bucket/incoming")

static String createWatchUpload(InnorixClient client, String source, String sourcePath,
        String target, String targetPath, String action, int watchType) {
    Map<String, Object> detail = Json.newObj(
            "senderId", source,
            "receiverId", target,
            "sourceItem", Json.newArr(Json.newObj(
                    "hash", InnorixClient.encodePath(source, sourcePath),
                    "filePath", sourcePath.replace("\\", "/"),
                    "isDir", true)),
            "targetPath", InnorixClient.encodePath(target, targetPath),
            "step", 1,
            "transferOptions", Json.newObj(
                    "noSchedule", true,
                    "target-action", action,
                    "send-fileoption", Json.newObj(),
                    "syncType", 1,                  // one-way sync
                    "watchFolderType", watchType)); // 1 = on create, 2 = on modify

    Map<String, Object> body = Json.newObj(
            "name", "windows to s3 watch",
            "flowName", "windows to s3 watch",
            "transferType", "sync",
            "isUpcoming", false,
            "timezone", "Asia/Seoul",
            "details", Json.newArr(detail),
            "schedules", Json.newArr(Json.newObj(
                    "type", "none", "startDateType", "now",
                    "startDate", InnorixClient.nowIso(), "timezone", "Asia/Seoul")),
            "step", 1);

    return Json.str(client.apiObj("POST", "/api/automations", body, null), "automationId");
}

async function createWatchUpload(source, sourcePath, target, targetPath,
                                 action = "overwrite", watchType = 1) {
  const body = {
    name: "windows to s3 watch",
    flowName: "windows to s3 watch",
    transferType: "sync",
    isUpcoming: false,
    timezone: "Asia/Seoul",
    details: [{
      senderId: source,
      receiverId: target,
      sourceItem: [{
        hash: encodePath(source, sourcePath),
        filePath: String(sourcePath ?? "").replace(/\\/g, "/"),
        isDir: true,
      }],
      targetPath: encodePath(target, targetPath),
      step: 1,
      transferOptions: {
        noSchedule: true,
        "target-action": action,
        "send-fileoption": {},
        syncType: 1,                 // one-way sync
        watchFolderType: watchType,  // 1 = on create, 2 = on modify
      },
    }],
    schedules: [{
      type: "none", startDateType: "now",
      startDate: nowIso(), timezone: "Asia/Seoul",
    }],
    step: 1,
  };

  return (await api("POST", "/api/automations", body)).automationId;
}

const automationId = await createWatchUpload(
  "device-win-01", "C:/data/export",
  "device-s3", "my-bucket/incoming");

static async Task<string> CreateWatchUploadAsync(InnorixClient client, string source, string sourcePath,
    string target, string targetPath, string action = "overwrite", int watchType = 1)
{
    var detail = new JsonObject
    {
        ["senderId"] = source,
        ["receiverId"] = target,
        ["sourceItem"] = new JsonArray
        {
            new JsonObject
            {
                ["hash"] = InnorixClient.EncodePath(source, sourcePath),
                ["filePath"] = sourcePath.Replace("\\", "/"),
                ["isDir"] = true,
            }
        },
        ["targetPath"] = InnorixClient.EncodePath(target, targetPath),
        ["step"] = 1,
        ["transferOptions"] = new JsonObject
        {
            ["noSchedule"] = true,
            ["target-action"] = action,
            ["send-fileoption"] = new JsonObject(),
            ["syncType"] = 1,                 // one-way sync
            ["watchFolderType"] = watchType,  // 1 = on create, 2 = on modify
        },
    };

    var body = new JsonObject
    {
        ["name"] = "windows to s3 watch",
        ["flowName"] = "windows to s3 watch",
        ["transferType"] = "sync",
        ["isUpcoming"] = false,
        ["timezone"] = "Asia/Seoul",
        ["details"] = new JsonArray { detail },
        ["schedules"] = new JsonArray
        {
            new JsonObject
            {
                ["type"] = "none", ["startDateType"] = "now",
                ["startDate"] = InnorixClient.NowIso(), ["timezone"] = "Asia/Seoul",
            }
        },
        ["step"] = 1,
    };

    return J.Str(await client.ApiObjAsync("POST", "/api/automations", body), "automationId");
}

runs = api("GET", f"/api/automations/{automation_id}/executions") or []

for run in runs:
    print(run["startTime"], run["status"], run["monitorId"])

List<Object> runs = Json.asArr(client.api("GET", "/api/automations/" + automationId + "/executions"));

for (Object run : runs) {
    Map<String, Object> r = Json.asObj(run);
    System.out.println(Json.str(r, "startTime") + " " + Json.intOrNull(r, "status") + " " + Json.str(r, "monitorId"));
}

const runs = (await api("GET", `/api/automations/${automationId}/executions`)) || [];

for (const run of runs) {
  console.log(run.startTime, run.status, run.monitorId);
}

JsonArray runs = J.AsArr(await client.ApiAsync("GET", 
quot;/api/automations/{automationId}/executions"));

foreach (JsonNode run in runs)
    Console.WriteLine(
quot;{J.Str(run, "startTime")} {J.IntOrNull(run, "status")} {J.Str(run, "monitorId")}");

api("POST", f"/api/automations/{automation_id}/pause", {"pause": True})   # pause
api("POST", f"/api/automations/{automation_id}/pause", {"pause": False})  # resume
api("DELETE", f"/api/automations/{automation_id}")                        # delete automation (permanent)

client.api("POST", "/api/automations/" + automationId + "/pause", Json.newObj("pause", true));   // pause
client.api("POST", "/api/automations/" + automationId + "/pause", Json.newObj("pause", false));  // resume
client.api("DELETE", "/api/automations/" + automationId);                                        // delete automation (permanent)

await api("POST", `/api/automations/${automationId}/pause`, { pause: true });   // pause
await api("POST", `/api/automations/${automationId}/pause`, { pause: false });  // resume
await api("DELETE", `/api/automations/${automationId}`);                        // delete automation (permanent)

await client.ApiAsync("POST", 
quot;/api/automations/{automationId}/pause", new JsonObject { ["pause"] = true });   // pause
await client.ApiAsync("POST", 
quot;/api/automations/{automationId}/pause", new JsonObject { ["pause"] = false });  // resume
await client.ApiAsync("DELETE", 
quot;/api/automations/{automationId}");                                            // delete automation (permanent)

Windows 폴더에 파일 생성
   ↓
감시 자동화 실행 (sync)
   ↓
Amazon S3로 전송
   ↓
실행 이력·monitorId 확인