API Reference — Snapshot Detection

curl -X POST http://localhost:4004/pipeline/0/stream_factory_01/NFV4D-FISO \
  -H "Content-Type: application/json" \
  -d '{
    "config": {
      "address": "http://ai-service:4006",
      "dump_interval": 5,
      "dump_confidence": 0.30,
      "areas": [
        {
          "name": "Zona Produksi",
          "roi_type": "whitelist",
          "points": [
            {"x": 0.1, "y": 0.1},
            {"x": 0.9, "y": 0.1},
            {"x": 0.9, "y": 0.9},
            {"x": 0.1, "y": 0.9}
          ]
        }
      ]
    }
  }'

curl -X POST http://localhost:4004/pipeline/0/stream_warehouse_03/NFV4D-PSMO \
  -H "Content-Type: application/json" \
  -d '{
    "config": {
      "address": "http://ai-service:4006",
      "dump_interval": 5,
      "dump_confidence": 0.30
    }
  }'

curl -X POST http://localhost:4004/pipeline/0/stream_lobby_07/NFV4D-OVOD \
  -H "Content-Type: application/json" \
  -d '{
    "config": {
      "address": "http://ai-service:4006",
      "dump_interval": 5,
      "classes": ["person", "backpack", "luggage"],
      "confidence": 0.5,
      "additional_params": {
        "box_th": 0.3,
        "text_th": 0.25
      }
    }
  }'

curl -X POST http://localhost:4004/pipeline/0/stream_publicarea_02/NFV4D-VMFG \
  -H "Content-Type: application/json" \
  -d '{
    "config": {
      "address": "http://ai-service:4008",
      "dump_interval": 10,
      "images_num": 4,
      "interval_capture": 0.5,
      "is_dump_collage": true
    }
  }'

curl -X POST http://localhost:4004/pipeline/0/stream_terminal_01/NFV4D-VLM \
  -H "Content-Type: application/json" \
  -d '{
    "config": {
      "address": "http://ai-service:4008",
      "dump_interval": 15,
      "persona": "public_safety"
    }
  }'

const ws = new WebSocket(
  'ws://localhost:4004/event_channel/0/stream_factory_01/NFV4D-FISO'
);

ws.onmessage = (msg) => {
  const event = JSON.parse(msg.data);
  console.log(event.primary_text, event.pipeline_data);
};

ws.onerror = (err) => console.error('WebSocket error', err);
ws.onclose = () => console.log('Disconnected');

import asyncio
import json
import websockets

async def listen():
    url = "ws://localhost:4004/event_channel/0/stream_factory_01/NFV4D-FISO"
    async with websockets.connect(url) as ws:
        async for msg in ws:
            event = json.loads(msg)
            print(event["primary_text"], event["pipeline_data"])

asyncio.run(listen())

{
  "analytic_id": "NFV4D-FISO",
  "stream_id": "stream_factory_01",
  "node_num": 1,
  "timestamp": 1714800000,
  "primary_text": "fire",
  "secondary_text": "0.812000",
  "pipeline_data": { "event_id": "1714800000-1a2b3c4d", "label": "fire", "confidence": 0.812 }
}

{
  "analytic_id": "NFV4D-PSMO",
  "stream_id": "stream_warehouse_03",
  "node_num": 1,
  "timestamp": 1714800120,
  "primary_text": "person smoking",
  "secondary_text": "0.421000",
  "pipeline_data": { "event_id": "1714800120-9f8e7d6c", "label": "person smoking", "confidence": 0.421 }
}

{
  "analytic_id": "NFV4D-OVOD",
  "stream_id": "stream_lobby_07",
  "node_num": 2,
  "timestamp": 1714800300,
  "primary_text": "Main Lobby: person",
  "secondary_text": "0.762000",
  "pipeline_data": { "event_id": "1714800300-2b3c4d5e", "dump": true }
}

{
  "analytic_id": "NFV4D-WLM",
  "stream_id": "stream_river_05",
  "node_num": 1,
  "timestamp": 1714800900,
  "primary_text": "900",
  "secondary_text": "",
  "pipeline_data": { "event_id": "1714800900-4d5e6f70", "level": 900 }
}

{
  "analytic_id": "NFV4D-FLOD",
  "stream_id": "stream_road_02",
  "node_num": 1,
  "timestamp": 1714801200,
  "primary_text": "waterlogged",
  "secondary_text": "87.300 %",
  "pipeline_data": {
    "event_id": "1714801200-5e6f7081",
    "waterlogged": 87.3,
    "attributes": { "classification": { "label": "waterlogged", "confidence": 87.3 } }
  }
}

{
  "analytic_id": "NFV4D-RIOT",
  "stream_id": "stream_publicarea_02",
  "node_num": 1,
  "timestamp": 1714800600,
  "primary_text": "Riot is Detected",
  "secondary_text": "",
  "pipeline_data": { "event_id": "1714800600-6f708192", "event": true, "answer": "yes" }
}

{
  "analytic_id": "NFV4D-VLM",
  "stream_id": "stream_terminal_01",
  "node_num": 1,
  "timestamp": 1714801500,
  "primary_text": "public safety event: suspicious",
  "secondary_text": "Two people arguing near the ticket counter, no physical contact observed.",
  "pipeline_data": {
    "event_id": "1714801500-708192a3",
    "event": true,
    "answer": "Two people arguing near the ticket counter, no physical contact observed.",
    "persona": "public_safety",
    "severity": "suspicious",
    "cot_answers": [
      "Two people are standing close, gesturing animatedly.",
      "Two people visible, body language agitated.",
      "No weapons or broken objects visible; raised voices only."
    ]
  }
}