sxe-queue

Sentivex Evolution Engine API

POST/sxe/analysis/begin

Sxe Analysis Begin

OpenSearch Alerting Monitor (또는 사용자) 가 incident 분석 요청. body: { incident_uid, severity, vendor, source_index, ... } 또는 OpenSearch Alerting 의 messageBody (FreeMarker template) 그대로.

Responses

200 Successful Response
object
cURL
curl -X POST https://see.in-bridge.com/sxe/analysis/begin
JavaScript
const res = await fetch("https://see.in-bridge.com/sxe/analysis/begin", {
  method: "POST"
});
const data = await res.json();
Response 200
{}
GET/sxe/analysis_queue

분석 큐 상태 + 워커 핑(alive)

진단 — Alerting Monitor 가 push 한 큐의 최근 50개 + worker heartbeat. (path '/sxe/analysis/{uid}' 와 충돌 회피 — underscore 형식)

Responses

200 Successful Response
totalintegerrequired
pendingintegerrequired
processed_totalintegerrequired
workerQueueWorkerrequired
last_seen_tsnumber | null
last_seen_ago_secnumber | null
last_pop_uidstring | null
last_pop_ago_secnumber | null
alivebooleanrequired
recentany[]
cURL
curl -X GET https://see.in-bridge.com/sxe/analysis_queue
JavaScript
const res = await fetch("https://see.in-bridge.com/sxe/analysis_queue", {
  method: "GET"
});
const data = await res.json();
Response 200
{
  "total": 0,
  "pending": 0,
  "processed_total": 0,
  "worker": {
    "last_seen_ts": 0,
    "last_seen_ago_sec": 0,
    "last_pop_uid": "string",
    "last_pop_ago_sec": 0,
    "alive": true
  },
  "recent": [
    null
  ]
}
POST/sxe/analysis_queue/pop

Sxe Analysis Queue Pop

worker 가 호출 — Alerting 큐 (incidents) 에서 _분석 안 한_ incident_uid 1건 pop. 각 incident 별 1회만 처리 (`_processed_incident_uids`).

Responses

200 Successful Response
object
cURL
curl -X POST https://see.in-bridge.com/sxe/analysis_queue/pop
JavaScript
const res = await fetch("https://see.in-bridge.com/sxe/analysis_queue/pop", {
  method: "POST"
});
const data = await res.json();
Response 200
{}
POST/sxe/analysis_queue/mark_processed

Sxe Analysis Queue Mark

worker 가 분석 완료/실패 후 — uid 를 처리 set 에 추가 (수동 mark). body: { incident_uid }

Responses

200 Successful Response
object
cURL
curl -X POST https://see.in-bridge.com/sxe/analysis_queue/mark_processed
JavaScript
const res = await fetch("https://see.in-bridge.com/sxe/analysis_queue/mark_processed", {
  method: "POST"
});
const data = await res.json();
Response 200
{}