Pipeline Data: decision_intelligence (Issue-Level Strategic Recommendations)

Indeks Elasticsearch decision_intelligence memuat hasil sintesis intelijen strategis tingkat tinggi terhadap isu-isu publik kritis nasional. Pipeline ini merumuskan skor risiko komposit, akar masalah (root cause), proyeksi dampak sistemik (impact), serta arahan rekomendasi mitigasi taktis (recommended_actions) bagi pengambil kebijakan.

1. Prinsip Utama Arsitektur Pipeline

Pipeline decision_intelligence dirancang dengan prinsip efisiensi kognitif tinggi:

1. Global Intelligence Level (Bukan Scan Mentah): Engine decision-worker TIDAK membaca indeks articles secara langsung dan TIDAK melakukan query ke database PostgreSQL. Seluruh pemrosesan memanfaatkan data yang sudah dipadatkan oleh nexa-aggregation.
2. Evidence-Based Grounding: Indeks issue_dashboard bertindak sebagai primary evidence source yang menyuplai ringkasan artikel sampel (sample_articles), entitas tokoh/lembaga kunci (top_entities), dan kata kunci kritis (top_keywords) per isu.
3. Efisiensi Token & Respons Kilat: Ukuran prompt AI menjadi jauh lebih ringkas (hemat token hingga >85% dibanding membaca naskah artikel utuh), sementara waktu eksekusi inferensi AI batch harian berlangsung terkontrol.

2. Alur Eksekusi End-to-End & Jadwal Batch (03:00 WIB)

Pipeline dieksekusi secara otomatis setiap hari pada pukul 03:00 WIB (0 3 * * *), tepat setelah nexa-aggregation menyelesaikan kalkulasi agregasi harian pada pukul 02:00 WIB:

3. Sumber Data Masukan (Input Evidence Matrix)

decision-worker mengekstrak data dari 4 indeks Elasticsearch agregasi H-1:

4. Format Dokumen Elasticsearch (decision_intelligence)

Dokumen disimpan dengan skema penamaan ID unik: decision_{issue_slug}_{YYYY-MM-DD} (atau decision_national_{YYYY-MM-DD} untuk sintesis makro nasional):

{
  "doc_id": "decision_pilkada_jakarta_memanas_2026-09-26",
  "generated_at": "2026-09-26T03:00:00+07:00",
  "generated_from": {
    "start": "2026-09-25T00:00:00+07:00",
    "end": "2026-09-25T23:59:59+07:00"
  },
  "period": "24h",
  "issue": "Pilkada Jakarta memanas akibat polarisasi",
  "province": "DKI Jakarta",
  "priority": "KRITIS",
  "taxonomy": {
    "l1": "POLITIK",
    "leaf": "Pilkada Jakarta memanas akibat polarisasi"
  },
  "risk_score": 78,
  "root_cause": "Eskalasi gesekan massa simpatisan paslon di ruang siber dan lapangan menjelang tahapan penetapan paslon resmi KPU DKI.",
  "impact": "Potensi polarisasi sosial merembet ke ranah komunal di wilayah penyangga (Banten & Jabar), mengganggu stabilitas kamtibmas dan sentimen ekonomi ibu kota.",
  "recommended_actions": [
    "Polda Metro Jaya meningkatkan patroli siber terpadu dan mitigasi narasi provokatif di media sosial.",
    "Bawaslu & Sentra Gakkumdu segera memediasi tim sukses paslon guna menekan retorika ofensif.",
    "Pemprov DKI mengaktifkan forum Forkopimda bersama tokoh masyarakat untuk mendinginkan tensi publik."
  ],
  "confidence": 92,
  "evidence": {
    "issue_dashboard_id": "issue_pilkada_jakarta_memanas_2026-09-25",
    "province_dashboard_id": "province_dki_jakarta_2026-09-25",
    "national_dashboard_id": "national_2026-09-25",
    "trending_topic_id": "trend_pilkada_jakarta_memanas_2026-09-25"
  },
  "generated_by": "decision-worker",
  "document_version": 1
}

5. Spesifikasi Payload Kontrak AIOS

{
  "issue": "Pilkada Jakarta memanas akibat polarisasi",
  "taxonomy_path": "POLITIK > Pemilu > Pilkada",
  "avg_risk": 78,
  "total_event": 4500,
  "top_provinces": ["DKI Jakarta", "Banten", "Jawa Barat"],
  "top_entities": ["Bawaslu DKI", "KPU DKI", "Pasangan Calon A", "Polda Metro Jaya"],
  "top_keywords": ["kampanye hitam", "polarisasi", "protes", "pelanggaran", "demonstrasi"],
  "sample_articles": [
    "Massa simpatisan menggelar aksi di depan kantor Bawaslu menuntut investigasi dugaan pelanggaran.",
    "Polda Metro Jaya menyiagakan 2.500 personel gabungan mengamankan tahapan pemilu serentak di wilayah ibu kota."
  ],
  "national_context": {
    "national_risk": 60.7,
    "total_event": 28450
  }
}

6. Konsumsi Data Downstream

Dokumen pada indeks decision_intelligence dikonsumsi oleh:

1. Dashboard Overview — Panel Rekomendasi Intelijen:
   • Backend memfilter dokumen dengan confidence >= 60 dan menyajikan kartu arahan mitigasi langsung di antarmuka utama pimpinan.
2. Executive Briefing — Prioritas Tindak Lanjut:
   • Disajikan pada modal dan lembar cetak PDF eksekutif (/ew/briefing) untuk isu berstatus priority IN ['KRITIS', 'TINGGI'] terurut berdasarkan risk_score DESC.
3. API Gateway (/decision/recommendations):
   • Menyediakan feed JSON bagi sistem eksternal atau aplikasi mobile komando pimpinan.