Pipeline Data: knowledge_graph (Knowledge Graph & Jejaring Aktor)

Pipeline ini bertugas merangkum ribuan artikel berita siber harian menjadi struktur Graf Pengetahuan (Knowledge Graph) yang memetakan jejaring keterhubungan antar-aktor (tokoh publik, institusi negara, korporasi swasta, dan organisasi masyarakat) beserta isu strategis yang melibatkannya.

Pemrosesan graf dieksekusi secara otomatis oleh worker nexa-knowledge-graph yang mendelegasikan pemrosesan kognitif inferensi bahasa alami (Natural Language Processing) ke AIOS (Dify Workflow), kemudian menyimpan struktur graf utuh ke indeks Elasticsearch knowledge_graph dan tabel PostgreSQL knowledge_graphs.

Data ini menjadi tulang punggung visualisasi interaktif jejaring 2D/3D Force-Directed Graph pada modul /dashboard/knowledge-graph.

1. Alur Eksekusi Pemodelan Graf

[PostgreSQL: articles]
(Artikel terverifikasi hasil D1 AI pada jendela waktu H-1)
                       │
                       ▼ (Scheduler Harian: Pukul 01:00 WIB)
          [nexa-knowledge-graph Worker]
          • Filter jendela waktu tepat 24 jam H-1
          • Format payload ringkas (id, media_source, title, text, date)
                       │
                       ▼ (HTTP POST)
          [AIOS: Dify AI Workflow Engine]
          • Ekstraksi Entitas (Nodes: Tokoh, Organisasi, Lokasi, Isu)
          • Ekstraksi Hubungan (Edges: Keterlibatan, Afiliasi, Aliran, Konflik)
          • Analisis Sentimen & Topik Dominan
                       │
                       ▼ (Response JSON utuh: meta, nodes, edges)
          [Multi-Sink Persistence Engine]
                       ├─────────────────────────────────────┐
                       ▼                                     ▼
        [Elasticsearch: knowledge_graph]      [PostgreSQL: knowledge_graphs]
        (Pencarian Kilat & Visualisasi UI)    (Arsip Relasional & Redundansi)

2. Metodologi Pendelegasian Kognitif ke AIOS

Worker nexa-knowledge-graph dirancang dengan arsitektur ringan (decoupled):

1. Kurir Data Tanpa Beban NLP Lokal: Worker tidak melakukan ekstraksi manual regex di server lokal, melainkan bertindak sebagai orkestrator data yang mengirimkan batch artikel ke endpoint AIOS.
2. Ekstraksi Triplet Semantik Terstruktur: AIOS menjalankan prompt model fondasi untuk menghasilkan pasangan relasi semantik berbobot:
   • Simpul (Nodes): Memiliki atribut id, label, type (Person, Organization, Location, Topic), serta skor pengaruh awal.
   • Garis Penghubung (Edges): Memiliki atribut source, target, relation (e.g., "MENGINVESTIGASI", "TERAFILIASI_DENGAN", "MENOLAK"), serta bobot kekuatan hubungan (weight).

3. Analisis Sentralitas Jejaring (Network Analysis)

Struktur graf yang terbentuk dievaluasi menggunakan algoritma teori graf lanjutan:

• Degree Centrality: Menghitung jumlah koneksi langsung yang dimiliki suatu entitas untuk mengetahui seberapa aktif tokoh tersebut dalam pemberitaan.
• Betweenness Centrality: Mengukur frekuensi suatu entitas bertindak sebagai simpul jembatan perantara antar-kelompok yang berbeda. Aktor dengan nilai betweenness tinggi seringkali merupakan figur kunci penggerak di balik layar.
• PageRank: Menghitung bobot otoritas dan pengaruh hierarkis entitas berdasarkan mutu koneksi simpul-simpul yang menghubunginya.
• Community Detection: Mengelompokkan klaster-klaster lingkaran kekuasaan atau persekutuan narasi media secara terisolasi.

4. Struktur Dokumen di Elasticsearch knowledge_graph

{
  "_id": "kg_topic_nasional_2026-09-25",
  "generated_at": "2026-09-26T01:15:00Z",
  "period": {
    "start": "2026-09-25T00:00:00Z",
    "end": "2026-09-25T23:59:59Z"
  },
  "meta": {
    "total_articles": 142,
    "total_nodes": 38,
    "total_edges": 64
  },
  "nodes": [
    {
      "id": "node_tokoh_001",
      "label": "Bahlil Lahadalia",
      "type": "PERSON",
      "pagerank": 0.92,
      "degree": 14
    },
    {
      "id": "node_instansi_002",
      "label": "Kementerian ESDM",
      "type": "ORGANIZATION",
      "pagerank": 0.88,
      "degree": 19
    }
  ],
  "edges": [
    {
      "id": "edge_001",
      "source": "node_tokoh_001",
      "target": "node_instansi_002",
      "relation": "MEMIMPIN",
      "weight": 0.95
    }
  ]
}

5. Ringkasan Parameter Operasional Pipeline

6. Spesifikasi Payload Request & Response Pipeline

POST https://aios.internal/v1/workflows/run
Authorization: Bearer app-kg-workflow-secret-token
Content-Type: application/json

{
  "inputs": {
    "target_date": "2026-09-25",
    "cluster_id": "cluster_energi_transisi_01",
    "articles": [
      {
        "id": "art_19823",
        "title": "Menteri ESDM Tegaskan Komitmen Moratorium PLTU Batubara Baru",
        "content": "Jakarta - Menteri Energi dan Sumber Daya Mineral Bahlil Lahadalia memastikan pemerintah tidak lagi menerbitkan izin baru untuk PLTU batubara...",
        "published_at": "2026-09-25T10:00:00Z"
      }
    ]
  },
  "response_mode": "blocking",
  "user": "worker-nexa-kg"
}